登录/ 注册
 找回密码
 立即注册
关闭

CSDN热搜

程序园 精品问答 技术交流 资源下载
返回列表 发新帖
首页 › 业界区 › 安全 ›UDP的广播和组播

UDP的广播和组播

崆蛾寺 2025-6-10 10:50:45
UDP的广播和组播

设计程序，创建UDP套接字，首先检查UDP套接字的广播选项是否启动，如果没有启动，则启动UDP套接字的广播选项。
  1. #include <sys/socket.h>
  2. #include <netinet/in.h>
  3. #include
  4. #include <stdio.h>
  5. #include <errno.h>
  6. #include <sys/socket.h>
  7. #include <netinet/in.h>
  8. #include <netinet/ip.h>
  9. #include
  10. #include <sys/socket.h>
  11. #include <netinet/in.h>
  12. #include <netinet/udp.h>
  13. #include <stdlib.h>
  14. #include <string.h>
  15. #include <sys/types.h>
  17. int main()
  18. {
  19.     //1.创建socket套接字
  20.     int udp_socket = socket(AF_INET, SOCK_DGRAM, 0);
  21.         if (udp_socket == -1)
  22.         {
  23.                 fprintf(stderr, "udp socket error,errno:%d,%s\n",errno,strerror(errno));
  24.                 exit(1);
  25.         }
  27.     //2.获取UDP套接字的广播属性
  28.         int flag = -1;
  29.         socklen_t len = 4;
  30.         getsockopt(udp_socket,SOL_SOCKET,SO_BROADCAST,(void *)&flag,&len);
  32.         printf("flag = %d\n",flag); // 0
  34.         //3.设置UDP套接字的广播属性
  35.         int optval = 1;
  36.         setsockopt(udp_socket,SOL_SOCKET,SO_BROADCAST,&optval,sizeof(optval));
  38.         //4.获取UDP套接字的广播属性
  39.         flag = -1;
  40.         getsockopt(udp_socket,SOL_SOCKET,SO_BROADCAST,(void *)&flag,&len);
  41.         printf("flag = %d\n",flag); // 非0
  43.     //5.利用循环每隔5s想广播地址发送数据包
  44.         char buf[128] = "I am teacher,this is test packet";
  45.        
  46.         struct sockaddr_in  dest_addr;
  47.         dest_addr.sin_family                 = AF_INET;                                                 //协议族，是固定的
  48.         dest_addr.sin_port                   = htons(atoi(argv[1]));                        //服务器端口，必须转换为网络字节序
  49.         dest_addr.sin_addr.s_addr   = inet_addr(argv[2]);                        //服务器地址 "192.168.64.xxx"  
  51.         while(1)
  52.         {
  53.                 sendto(udp_socket,buf,strlen(buf),0, (struct sockaddr *)&dest_addr, sizeof(dest_addr));
  54.                 sleep(5);
  55.         }
  56.        
  58.         return 0;
  59.    
  60. }
复制代码
小组实现，小组中的每位成员都需要设计程序，要求程序可以加入到一个多播组中并等待服务器发送数据包，并且程序还需要具有发送功能，如果收到数据包则把消息内容输出到终端， 消息内容格式 [消息来源IP  消息时间 ] : 消息内容
  1. #include <stdio.h>
  2. #include <pthread.h>
  3. #include <sys/socket.h>
  4. #include <netinet/in.h>
  5. #include
  6. #include <stdio.h>
  7. #include <errno.h>
  8. #include <sys/socket.h>
  9. #include <netinet/in.h>
  10. #include <netinet/ip.h>
  11. #include
  12. #include <sys/socket.h>
  13. #include <netinet/in.h>
  14. #include <netinet/udp.h>
  15. #include <stdlib.h>
  16. #include <string.h>
  17. #include <sys/types.h>
  18. #include <time.h>
  19. #include <unistd.h>
  20. #include <locale.h>
  22. #define MULADDR "192.168.136.200"
  23. #define PORT 6666
  24. struct sockaddr_in dest_addr;
  25. int udp_socket;
  27. //发送信息
  28. void * send_msg(void *)
  29. {
  30.     char buf[128] = "HELLO WORLD";
  31.     //向多播组发送内容
  32.     while(1)
  33.     {
  34.         sendto(udp_socket, buf, strlen(buf), 0, (struct sockaddr *)&dest_addr, sizeof(dest_addr));
  35.         sleep(5);
  36.     }
  37.     return NULL;
  38. }
  40. //接收信息
  41. // void * recv_msg(void *)
  42. // {
  43. //     struct sockaddr_in source_addr;
  44. //     socklen_t addr_len = sizeof(source_addr);  // 声明变量并初始化
  45. //     char recvbuf[128];
  46. //     // 获取当前时间
  47. //     time_t current_time = time(NULL);
  48. //     // 转换为本地时间
  49. //     struct tm *tm_now = localtime(&current_time);
  50. //     // 使用strftime格式化时间
  51. //     char buffer[128];
  52. //     strftime(buffer, sizeof(buffer), "%Y-%m-%d %H-%M-%S",tm_now);
  53. //     while(1)
  54. //     {
  55. //         //接收收到的信息
  56. //         recvfrom(udp_socket,recvbuf,sizeof(recvbuf),0,(struct sockaddr *)&source_addr, &addr_len);
  57. //         // 打印时间
  58. //         printf("来自：%s，当前时间是：%s，内容：%s\n", inet_ntoa(source_addr.sin_addr),buffer,recvbuf);
  59. //         bzero(recvbuf,sizeof(recvbuf));
  60. //     }
  61. // }
  62. // 接收信息
  63. void *recv_msg(void *) {
  64.     struct sockaddr_in source_addr;
  65.     socklen_t addr_len = sizeof(source_addr);  // 定义地址长度变量
  66.     char recvbuf[128];
  67.    
  68.     while (1) {
  69.         // 重置地址长度，防止被前次调用修改
  70.         addr_len = sizeof(source_addr);
  71.         
  72.         // 接收数据
  73.         ssize_t recv_size = recvfrom(
  74.             udp_socket,
  75.             recvbuf,
  76.             sizeof(recvbuf) - 1,  // 预留一个字节给字符串终止符
  77.             0,
  78.             (struct sockaddr *)&source_addr,
  79.             &addr_len  // 正确传递地址长度变量的指针
  80.         );
  82.         // 处理接收结果
  83.         if (recv_size > 0) {
  84.             recvbuf[recv_size] = '\0';  // 添加字符串终止符
  85.             // 获取当前时间（实时更新）
  86.             time_t now = time(NULL);
  87.             struct tm *tm_info = localtime(&now);
  88.             char time_buf[128];
  89.             strftime(time_buf, sizeof(time_buf), "%Y-%m-%d %H:%M:%S", tm_info);
  90.             printf("来自：%s，时间：%s，内容：%s\n",
  91.                   inet_ntoa(source_addr.sin_addr), time_buf, recvbuf);
  92.         } else if (recv_size == -1) {
  93.             perror("recvfrom 错误");
  94.             break;
  95.         }
  96.     }
  97.     return NULL;
  98. }
  100. int main()
  101. {
  102.     //1.创建socket套接字
  103.     udp_socket = socket(AF_INET, SOCK_DGRAM, 0);
  104.         if (udp_socket == -1)
  105.         {
  106.                 fprintf(stderr, "udp socket error,errno:%d,%s\n",errno,strerror(errno));
  107.                 exit(1);
  108.         }
  110.     //2.设置UDP套接字的组播属性，并加入组播组
  111.     // struct ip_mreqn {
  112.     //     struct in_addr imr_multiaddr; /* IP multicast group
  113.     //                                      address */
  114.     //     struct in_addr imr_address;   /* IP address of local
  115.     //                                      interface */
  116.     //     int            imr_ifindex;   /* interface index */
  117.     // };
  118.     struct ip_mreq mreq;
  119.     mreq.imr_multiaddr.s_addr=inet_addr(MULADDR);
  120.     mreq.imr_interface.s_addr=htonl(INADDR_ANY);
  121.         setsockopt(udp_socket,IPPROTO_IP,IP_ADD_MEMBERSHIP,&mreq,sizeof(mreq));
  124.     //3.创建的的套接字和本地端口和ip绑定
  125.     struct sockaddr_in host_addr;
  126.     host_addr.sin_family=AF_INET;
  127.     host_addr.sin_port=htons(PORT);
  128.     host_addr.sin_addr.s_addr=htonl(INADDR_ANY);
  129.     bind(udp_socket,(struct sockaddr *)&host_addr,sizeof(host_addr));
  131.     // 4.向目标主机发送消息,需要设置目标端口和目标地址
  133.         memset(&dest_addr, 0, sizeof(dest_addr));
  134.     dest_addr.sin_family = AF_INET;
  135.     dest_addr.sin_port = htons(PORT);
  136.     dest_addr.sin_addr.s_addr = inet_addr(MULADDR);
  138.     pthread_t recv_thread,send_thread;
  139.     pthread_create(&recv_thread,NULL,recv_msg,NULL);
  140.     pthread_create(&send_thread,NULL,send_msg,NULL);
  142.     pthread_join(recv_thread,NULL);
  143.     pthread_join(send_thread,NULL);
  145.     close(udp_socket);
  146.     return 0;
  147. }
复制代码
来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

使用道具 举报
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册
发帖
崆蛾寺
2025-6-10 10:50:45

0

粉丝关注

16

主题发布

板块介绍填写区域，请于后台编辑
微信扫一扫