28UDP

Posted 2020-11-19 gd-luojialin

UDP通信流程步骤：

服务端： 等待(被动)接收发送

1： 创建 socket：  socket()

2： 绑定端口：      bind()

3： 读取消息：      read()

4： 发送消息：      write()

5： 关闭套接字：  close()

 

客户端：主动发送接收

1： 创建 socket：   socket()

2： 发送数据：        write()

3： 接受结果：         read()

4： 关闭套接字：     close()

 

UDP通信流程图:

 

 

UDP通信

1.没有固定连接

2.客户端发完包，就不管了，也不知道服务端是不是收到了

 

UDP创建套接字、绑定套接字的方式与TCP一样，可参考TCP。

 

发送消息

sendto(int sockfd, void* buf,  size_t len,  int flags,

          struct sockaddr *to,  socklen_t tolen);

 

sockaddr由sockaddr_in转换。

UDP 没有accept创建新的通信fd，需要指定目标地址

函数可以用于TCP通信，后面两个参数会忽略

 

接收消息

recvfrom(int sockfd, void *buf,  size_t len ,  int flags,

             sturct sockaddr *from,  socklen_t *fromlen)

 

UDP 没有 accept 函数来获取对端地址，这里增加了2个参数

函数可以用于TCP通信

 

 

例子：

#include<stdio.h>

#include<stdlib.h>

#include<string.h>

#include<sys/socket.h>

#include<netinet/in.h>

#include<arpa/inet.h>

#include<unistd.h>

#define SRV_PORT  8888

#define CLT_PORT  6666

 

void Udp_server()

{

      int fd;

      int iRet;

      struct sockaddr_in addr;

      socklen_t addrlen = sizeof(addr);

      //创建套接字

      fd = socket(PF_INET, SOCK_DGRAM, 0);

      if (fd < 0)

      {

           perror("Fail to socket!");

           return;

      }

 

      addr.sin_family = AF_INET;

      addr.sin_port = htons(SRV_PORT);

      addr.sin_addr.s_addr = htonl(INADDR_ANY);

      //绑定，可以让客户端知道通过什么IP地址和端口号来连接

      iRet = bind(fd, (struct sockaddr*)&addr, addrlen);

      if (iRet)

      {

           perror("Fail to bind!");

           close(fd);

           return;

      }

     

      struct sockaddr_in srcaddr;

      char szBuf[1000];

      char szMsg[] = "[UDP]I Received!";

      while(1)

      {

           //接收，并获取客户端的IP和端口号(struct sockaddr*)&srcaddr

           memset(szBuf, 0, 1000);

           iRet = recvfrom(fd, szBuf, 1000, 0, (struct sockaddr*)&srcaddr, &addrlen);

           if (iRet < 0)

           {

                 perror("Fail to recvfrom!");

                 break;

           }

          

           printf("Recv:%s ", szBuf);  

     

           //发送

           fprintf(stderr,"Echo:");

           scanf("%s",szMsg);

           sendto(fd, szMsg, strlen(szMsg), 0, (struct sockaddr*)&srcaddr, addrlen);

 

      }

      close(fd);

 

      return;

}

 

void Udp_client()

{

      int fd;

      int iRet;

      struct sockaddr_in addr;

      socklen_t  addrlen = sizeof(addr);

 

      fd = socket(PF_INET, SOCK_DGRAM, 0);

      if (fd < 0)

      {

           perror("Fail to socket!");

           return;

      }

      /*

      addr.sin_family = AF_INET;

      addr.sin_port = htons(CLT_PORT);

      addr.sin_addr.s_addr = htonl(INADDR_ANY);

 

      iRet = bind(fd, (struct sockaddr*)&addr, addrlen);

      if (iRet)

      {

           perror("Fail to bind!");

           close(fd);

           return;

      }

      */

      struct sockaddr_in srvaddr;

      char szIp[16] = ;

      int  port;

 

      fprintf(stderr, "Input server IP and port:");

      scanf("%s%d", szIp, &port);

     

      srvaddr.sin_family = AF_INET;

      srvaddr.sin_port = htons((short)port);

      srvaddr.sin_addr.s_addr = inet_addr(szIp);

 

      char szBuf[100];

      char szRcv[1000];

      while(1)

      {

           memset(szBuf, 0, 100);

           fprintf(stderr, "->");

           read(STDIN_FILENO, szBuf, 100);

          

           sendto(fd, szBuf, strlen(szBuf), 0, (struct sockaddr*)&srvaddr, addrlen);

          

           memset(szRcv, 0, 1000);

           iRet = recvfrom(fd, szRcv, 1000, 0, (struct sockaddr*)&srvaddr, &addrlen);

           if (iRet < 0)

           {

                 perror("Fail to recvfrom!");

                 break;

           }

 

           printf("Recv:%s ", szRcv);

 

      }

      close(fd);

 

      return;

          

}

 

int main(int argc, char** argv)

{

      if (argc!=2

         || (strcmp(argv[1], "s") && strcmp(argv[1], "c"))

           )

      {

           printf("Usage: %s [ c | s ] ", argv[0]);  

           printf(" s: For start udp server ");

           printf(" c: For start udp client ");

           return 0;

      }

      if (argv[1][0] == ‘s‘)

      {

           Udp_server();

      }

      else if (argv[1][0] == ‘c‘)

      {

           Udp_client();

      }

      return 0;

}

 

 

UDP打洞：

打洞就是让对方不需要通过服务器的转换，直接使用公网IP地址进行通信。

解析：

一般的主机都是使用私有IP地址（在不同的局域网中私有IP地址可以重复的），对方主机通过路由路转换成公有IP地址，再进行通信。

打洞，当主机A向某一服务器发送数据时，此时在服务器上，显示的是主机A的公网IP地址和端口号，要做的就是将该IP地址和端口号再一次返回给主机A。那么主机A就知道了自己的公网IP和端口号。此时主机B就可以直接对主机A发送数据，进而可以相互通信。