UDP网络通信流程

UDP没有connect的过程，故发送数据时需要指明目的地址，不能使用read/write/send/recv. 采用sendto()和recvfrom()

ssize_t sendto (int __fd, __const void *__buf, size_t __n, int __flags, __CONST_SOCKADDR_ADR __addr, socklen_t __addr_len)

向某一主机发送字节序列

参数1：从本机哪个socket发送数据

参数2：欲发送的数据起始地址

参数3：欲发送的数据大小

参数4：说明数据处理方式

参数5：目的主机地址的起始位置

参数6：目的主机地址在内存中的大小

ssize_t recvfrom (int __fd, void *__restrict __buf, size_t __n, int __flags, __SOCKADDR_ARG __addr, socklen_t *__restrict __addr_len)

接收数据

参数5：存储数据的源地址

两个函数的返回值：成功，返回发送或接收的数据的大小；失败返回-1.

例子：UDP通信发送端发送一句话，接收端接收。

奇怪，这里的发送端又没有bind.

发送端

#include
     
      #include
      
       #include
       
        #include
        
         #include
         
          #include
          
           #include
           
            #include
            
             #include
             
              #include
              
               #include
               
                #include
                
                 int main(int argc, char **argv){ struct sockaddr_in s_addr; int sock; int addr_len; int len; char buff[128]; //创建socket IPv4 UDP 阻塞 if((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1) { perror("socket"); exit(errno); } else { printf("create socket.\n\r"); } s_addr.sin_family = AF_INET; s_addr.sin_port = htons(7838); if(argv[1]) { s_addr.sin_addr.s_addr = inet_addr(argv[1]); } else { printf("input server ip!\n"); exit(0); } addr_len = sizeof(s_addr); strcpy(buff, "hello i'm here"); len = sendto(sock, buff, strlen(buff), 0, (struct sockaddr *)&s_addr, addr_len); if(len < 0) { printf("\n\rsend error.\n\r"); return 3; } printf("send success.\n\r"); return 0;}

接收端

#include
     
      #include
      
       #include
       
        #include
        
         #include
         
          #include
          
           #include
           
            #include
            
             #include
             
              #include
              
               #include
               
                #include
                
                 int main(int argc, char **argv){ struct sockaddr_in s_addr; struct sockaddr_in c_addr; int sock; socklen_t addr_len; int len; char buff[128]; //创建socket IPv4 UDP if((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1) { perror("socket"); exit(errno); } else { printf("create socket.\n\r"); } memset(&s_addr, 0, sizeof(struct sockaddr_in)); s_addr.sin_family = AF_INET; s_addr.sin_port = htons(7838); s_addr.sin_addr.s_addr = INADDR_ANY; //绑定自己的IP信息 if((bind(sock, (struct sockaddr *)&s_addr, sizeof(s_addr))) == -1) { perror("bind"); exit(errno); } else { printf("bind address to socket.\n\r"); } addr_len = sizeof(c_addr); //一直接收消息 while(1) { //接收消息 len = recvfrom(sock, buff, sizeof(buff) - 1, 0, (struct sockaddr *)&c_addr, &addr_len); if(len < 0) { perror("recvfrom"); exit(errno); } buff[len] = '\0'; printf("recive come from %s:%d message:%s\n\r", inet_ntoa(c_addr.sin_addr), ntohs(c_addr.sin_port), buff); } return 0;}