博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Linux系统下UDP发送和接收广播消息小例子
阅读量:6839 次
发布时间:2019-06-26

本文共 2558 字,大约阅读时间需要 8 分钟。

[cpp] 
 
  1. // 发送端  
  2. #include <iostream>  
  3. #include <stdio.h>  
  4. #include <sys/socket.h>  
  5. #include <unistd.h>  
  6. #include <sys/types.h>  
  7. #include <netdb.h>  
  8. #include <netinet/in.h>  
  9. #include <arpa/inet.h>  
  10. #include <string.h>  
  11.   
  12.   
  13. using namespace std;  
  14.   
  15. int main()  
  16. {  
  17.     setvbuf(stdout, NULL, _IONBF, 0);   
  18.     fflush(stdout);   
  19.   
  20.     int sock = -1;  
  21.     if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1)   
  22.     {     
  23.         cout<<"socket error"<<endl;   
  24.         return false;  
  25.     }     
  26.       
  27.     const int opt = 1;  
  28.     //设置该套接字为广播类型,  
  29.     int nb = 0;  
  30.     nb = setsockopt(sock, SOL_SOCKET, SO_BROADCAST, (char *)&opt, sizeof(opt));  
  31.     if(nb == -1)  
  32.     {  
  33.         cout<<"set socket error..."<<endl;  
  34.         return false;  
  35.     }  
  36.   
  37.     struct sockaddr_in addrto;  
  38.     bzero(&addrto, sizeof(struct sockaddr_in));  
  39.     addrto.sin_family=AF_INET;  
  40.     addrto.sin_addr.s_addr=htonl(INADDR_BROADCAST);  
  41.     addrto.sin_port=htons(6000);  
  42.     int nlen=sizeof(addrto);  
  43.   
  44.     while(1)  
  45.     {  
  46.         sleep(1);  
  47.         //从广播地址发送消息  
  48.         char smsg[] = {
    "abcdef"};  
  49.         int ret=sendto(sock, smsg, strlen(smsg), 0, (sockaddr*)&addrto, nlen);  
  50.         if(ret<0)  
  51.         {  
  52.             cout<<"send error...."<<ret<<endl;  
  53.         }  
  54.         else  
  55.         {         
  56.             printf("ok ");    
  57.         }  
  58.     }  
  59.   
  60.     return 0;  
  61. }  

 

[cpp] 
 
  1. // 接收端 http://blog.csdn.net/robertkun  
  2.   
  3. #include <iostream>  
  4. #include <stdio.h>  
  5. #include <sys/socket.h>  
  6. #include <unistd.h>  
  7. #include <sys/types.h>  
  8. #include <netdb.h>  
  9. #include <netinet/in.h>  
  10. #include <arpa/inet.h>  
  11. #include <string.h>  
  12.   
  13.   
  14. using namespace std;  
  15.   
  16. int main()  
  17. {  
  18.     setvbuf(stdout, NULL, _IONBF, 0);   
  19.     fflush(stdout);   
  20.   
  21.     // 绑定地址  
  22.     struct sockaddr_in addrto;  
  23.     bzero(&addrto, sizeof(struct sockaddr_in));  
  24.     addrto.sin_family = AF_INET;  
  25.     addrto.sin_addr.s_addr = htonl(INADDR_ANY);  
  26.     addrto.sin_port = htons(6000);  
  27.       
  28.     // 广播地址  
  29.     struct sockaddr_in from;  
  30.     bzero(&from, sizeof(struct sockaddr_in));  
  31.     from.sin_family = AF_INET;  
  32.     from.sin_addr.s_addr = htonl(INADDR_ANY);  
  33.     from.sin_port = htons(6000);  
  34.       
  35.     int sock = -1;  
  36.     if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1)   
  37.     {     
  38.         cout<<"socket error"<<endl;   
  39.         return false;  
  40.     }     
  41.   
  42.     const int opt = 1;  
  43.     //设置该套接字为广播类型,  
  44.     int nb = 0;  
  45.     nb = setsockopt(sock, SOL_SOCKET, SO_BROADCAST, (char *)&opt, sizeof(opt));  
  46.     if(nb == -1)  
  47.     {  
  48.         cout<<"set socket error..."<<endl;  
  49.         return false;  
  50.     }  
  51.   
  52.     if(bind(sock,(struct sockaddr *)&(addrto), sizeof(struct sockaddr_in)) == -1)   
  53.     {     
  54.         cout<<"bind error..."<<endl;  
  55.         return false;  
  56.     }  
  57.   
  58.     int len = sizeof(sockaddr_in);  
  59.     char smsg[100] = {0};  
  60.   
  61.     while(1)  
  62.     {  
  63.         //从广播地址接受消息  
  64.         int ret=recvfrom(sock, smsg, 100, 0, (struct sockaddr*)&from,(socklen_t*)&len);  
  65.         if(ret<=0)  
  66.         {  
  67.             cout<<"read error...."<<sock<<endl;  
  68.         }  
  69.         else  
  70.         {         
  71.             printf("%s\t", smsg);     
  72.         }  
  73.   
  74.         sleep(1);  
  75.     }  
  76.   
  77.     return 0;  
  78. }  

自已在Linux虚拟机下测试可以成功, 前提是要把主机设置在同一网段内, 还有就是不要忘记关闭Linux的防火墙.. 可以使用setup命令进行设置。

(我在测试的时候只能发送不收接收,折磨了我半天,后来才想到是Linux防火墙的问题。。)

 

关于虚拟机的网卡配置,建议选择桥接模式。NAT的模式的话,是受限制的,可能会收不到广播消息。

具体的参考网上的文章吧。。

祝你成功。。

你可能感兴趣的文章
关于 Delphi 中流的使用(6) 用流读写结构化文件
查看>>
复杂的结构化存取(一)
查看>>
web前端性能优化
查看>>
如何通过jq和php实现返回父级页面(附带记忆功能)
查看>>
Centos下运行gpg --gen-key生成key时出现卡住解决方案笔记
查看>>
Java时间操作工具类
查看>>
网页简单配置捉取网购信息
查看>>
Go语言int类型绑定方法
查看>>
awk深入应用
查看>>
VMware记录(一)- vCenter Server 服务安装提示无法解析此完全限定域名
查看>>
fedora21 下解决IDEA中文无法输入、显示问题
查看>>
openSuse 13.1 的触摸板,回来了
查看>>
saltstack之远程触发文件备份、回滚
查看>>
Struts2教程2:处理一个form多个submit
查看>>
php文件上传的经验分享
查看>>
MySQL SQL优化
查看>>
代码编辑器——sublime
查看>>
MogileFS高级应用(二)最后有疑问
查看>>
mail spy
查看>>
第19课:Spark高级排序彻底解密
查看>>