UDP实现服务器和客户端的通信

Love The Way You Lie 2021-09-19 01:04 620阅读 0赞

一 服务端

  1. #include <sys/types.h>  
  2. #include <sys/stat.h>  
  3. #include <fcntl.h>  
  4. #include <stdio.h>  
  5. #include <stdlib.h>  
  6. #include <string.h>  
  7. #include <strings.h>  
  8. #include <unistd.h>  
  9. #include <errno.h>  
  10. #include <sys/stat.h>  
  11. #include <dirent.h>  
  12. #include <sys/mman.h>  
  13. #include <sys/wait.h>  
  14. #include <signal.h>  
  15. #include <sys/ipc.h>  
  16. #include <sys/shm.h>  
  17. #include <sys/msg.h>  
  18. #include <sys/sem.h>  
  19. #include <pthread.h>  
  20. #include <semaphore.h>  
  21. #include <poll.h>  
  22. #include <sys/epoll.h>  
  23. #include <sys/socket.h>  
  24. #include <netinet/in.h>  
  25. #include <arpa/inet.h>  
  26. #include <netinet/in.h>  
  29. char rbuf[50];  
  31. int main()  
  32. {  
  33.     int sockfd;  
  34.     int size;  
  35.     int ret;  
  36.     int on =1;  
  37.     struct sockaddr_in saddr;  
  38.     struct sockaddr_in raddr;  
  40.     //设置地址信息，ip信息  
  41.     size = sizeof(struct sockaddr_in);  
  42.     bzero(&saddr,size);  
  43.     saddr.sin_family = AF_INET;  
  44.     saddr.sin_port = htons(8888);  
  45.     saddr.sin_addr.s_addr = htonl(INADDR_ANY);  
  47.     //创建udp 的套接字  
  48.     sockfd = socket(AF_INET,SOCK_DGRAM,0);  
  49.     if(sockfd<0)  
  50.     {  
  51.         perror("socket failed");  
  52.         return -1;  
  53.     }  
  55.     //设置端口复用  
  56.     setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on));   
  58.     //绑定地址信息，ip信息  
  59.     ret = bind(sockfd,(struct sockaddr*)&saddr,sizeof(struct sockaddr));  
  60.     if(ret<0)  
  61.     {  
  62.         perror("sbind failed");  
  63.         return -1;  
  64.     }  
  66.     socklen_t  val = sizeof(struct sockaddr);  
  67.     //循环接收客户端发来的消息  
  68.     while(1)  
  69.     {  
  70.         puts("waiting data");  
  71.         // 没有数据过来时，就在recvfrom函数上阻塞着
  72.         ret=recvfrom(sockfd,rbuf,50,0,(struct sockaddr*)&raddr,&val);  
  73.         if(ret <0)  
  74.         {  
  75.             perror("recvfrom failed");  
  76.         }  
  78.         printf("the data :%s\n",rbuf);  
  79.         bzero(rbuf,50);  
  80.     }  
  81.     //关闭udp套接字，这里不可达的。  
  82.     close(sockfd);  
  83.     return 0;  
  84. }

二 客户端

  1. #include <sys/types.h>  
  2. #include <sys/stat.h>  
  3. #include <fcntl.h>  
  4. #include <stdio.h>  
  5. #include <stdlib.h>  
  6. #include <string.h>  
  7. #include <strings.h>  
  8. #include <unistd.h>  
  9. #include <errno.h>  
  10. #include <sys/stat.h>  
  11. #include <dirent.h>  
  12. #include <sys/mman.h>  
  13. #include <sys/wait.h>  
  14. #include <signal.h>  
  15. #include <sys/ipc.h>  
  16. #include <sys/shm.h>  
  17. #include <sys/msg.h>  
  18. #include <sys/sem.h>  
  19. #include <pthread.h>  
  20. #include <semaphore.h>  
  21. #include <poll.h>  
  22. #include <sys/epoll.h>  
  23. #include <sys/socket.h>  
  24. #include <netinet/in.h>  
  25. #include <arpa/inet.h>  
  26. #include <netinet/in.h>  
  28. char wbuf[50];  
  30. int main()  
  31. {  
  32.     int sockfd;  
  33.     int size,on = 1;  
  34.     struct sockaddr_in saddr;  
  35.     int ret;  
  37.     size = sizeof(struct sockaddr_in);  
  38.     bzero(&saddr,size);  
  40.     //设置地址信息，ip信息  
  41.     saddr.sin_family = AF_INET;  
  42.     saddr.sin_port = htons(8888);  
  43.     saddr.sin_addr.s_addr = inet_addr("192.168.0.110");//192.168.0.110为服务端所在的ip  
  45.     sockfd= socket(AF_INET,SOCK_DGRAM,0);  //创建udp 的套接字  
  46.     if(sockfd<0)  
  47.     {  
  48.         perror("failed socket");  
  49.         return -1;  
  50.     }  
  51.     //设置端口复用  
  52.     setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on));  
  54.     //循环发送信息给服务端  
  55.     while(1)  
  56.     {  
  57.         puts("please enter data:");  
  58.         scanf("%s",wbuf);  
  59.         ret=sendto(sockfd,wbuf,50,0,(struct sockaddr*)&saddr,  
  60.             sizeof(struct sockaddr));  
  61.         if(ret<0)  
  62.         {  
  63.             perror("sendto failed");  
  64.         }  
  66.         bzero(wbuf,50);  
  67.     }  
  68.     close(sockfd);  
  69.     return 0;  
  70. }

三 运行

1 先启动服务端

  1. [root@localhost test]# g++ test.cpp -o test
  2. [root@localhost test]# ./test
  3. waiting data

2 在启动客户端，并输入数据

  1. [root@localhost test]# g++ client.cpp -o client
  2. [root@localhost test]# ./client
  3. please enter data:
  4. 明天你来吗？

3 服务端结果

  1. [root@localhost test]# ./test
  2. waiting data
  3. the data :明天你来吗？
  4. waiting data

发表评论

表情：
评论列表 （有 0 条评论，620人围观）

还没有评论，来说两句吧...

相关阅读