博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
广播通信
阅读量:5992 次
发布时间:2019-06-20

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

广播:可以把数据发送给本地子网上的每个机器。

如果多个进程都发送广播数据,网络就会阻塞

对于UDP来说,存在一个特定的广播地址,255.255.255.255

 

发送方程序在创建套接字后使用setsockopt函数打开SO_BROADCAST选项,然后设置广播地址255.255.255.255,向端口号4567不断发送广播数据。

发送代码如下:

SOCKET s = ::socket(AF_INET,SOCK_DGRAM,0);//有效的SO_BROADCAST选项BOOL bBroadcast = TRUE;::setsockopt(s,SOL_SOCKET,SO_BROADCAST,(char*)&bBroadcast,sizeof(BOOL));//设置广播地址SOCKADDR_IN bcast;bcast.sin_family = AF_INET;bcast.sin_addr.s_addr = INADDR_BROADCAST;bcast.sin_port = htons(4567);//发送广播printf("开始向4567发送广播数据...\n");char sz[] = "this is just a test.\n";while(TRUE){    ::sendto(s,sz,strlen(sz),0,(sockaddr*)&bcast,sizeof(bcast));    ::Sleep(5000);}

接收方代码:

SOCKET s = ::socket(AF_INET,SOCK_DGRAM,0);//绑定一个本地地址,指明广播端口号SOCKADDR_IN sin;sin.sin_family = AF_INET;sin.sin_addr.S_un.S_addr = INADDR_ANY;sin.sin_port = ::ntohs(4567);if(::bind(s,(sockaddr*)&sin,&sizeof(sin))==SOCKET_ERROR){    printf("bind() failed!\n");    return;}//接收广播printf("开始在4567接收广播数据...\n");char sz[256];while(TRUE){    int nRet = ::recvfrom(s,sz,256,0,(sockaddr*)&addRemote,&nLen);    if(nRet>0)    {        sz[nRet] = '\0';        printf(sz);    }}

完整源代码如下:(可运行)

sender.cpp:

/////// sender.cpp文件#include "initsock.h"#include "stdio.h"#include 
CInitSock theSock;void main(){ SOCKET s = ::socket(AF_INET, SOCK_DGRAM, 0); // 有效SO_BROADCAST选项 BOOL bBroadcast = TRUE; ::setsockopt(s, SOL_SOCKET, SO_BROADCAST, (char*)&bBroadcast, sizeof(BOOL)); // 设置广播地址,这里的广播端口号(电台)是4567 SOCKADDR_IN bcast; bcast.sin_family = AF_INET; bcast.sin_addr.s_addr = INADDR_BROADCAST; // ::inet_addr("255.255.255.255"); bcast.sin_port = htons(4567); // 发送广播 printf(" 开始向4567端口发送广播数据... \n \n"); char sz[] = "This is just a test. \r\n"; while(TRUE) { ::sendto(s, sz, strlen(sz), 0, (sockaddr*)&bcast, sizeof(bcast)); ::Sleep(5000); }}/* ::send(s, sz, strlen(sz), 0); sockaddr_in addr; addr.sin_family = AF_INET; addr.sin_port = ntohs(3333); addr.sin_addr.S_un.S_addr = ADDR_ANY; if(::bind(s, (sockaddr*)&addr, sizeof(addr)) == SOCKET_ERROR) { printf(" bind() failed \n"); return; } */

recver.cpp:

/////// recver.cpp文件#include "initsock.h"#include "stdio.h"#include 
CInitSock theSock;void main(){ SOCKET s = ::socket(AF_INET, SOCK_DGRAM, 0); // 首先要绑定一个本地地址,指明广播端口号 SOCKADDR_IN sin; sin.sin_family = AF_INET; sin.sin_addr.S_un.S_addr = INADDR_ANY; sin.sin_port = ::ntohs(4567); if(::bind(s, (sockaddr*)&sin, sizeof(sin)) == SOCKET_ERROR) { printf(" bind() failed \n"); return; } // 接收广播 printf(" 开始在4567端口接收广播数据... \n\n"); SOCKADDR_IN addrRemote; int nLen = sizeof(addrRemote); char sz[256]; while(TRUE) { int nRet = ::recvfrom(s, sz, 256, 0, (sockaddr*)&addrRemote, &nLen); if(nRet > 0) { sz[nRet] = '\0'; printf(sz); } }}

运行结果:

转载地址:http://dgvlx.baihongyu.com/

你可能感兴趣的文章
基于场景的测试
查看>>
学点PYTHON基础的东东--数据结构,算法,设计模式---访问者模式
查看>>
[MySQL FAQ]系列 -- Too many open files
查看>>
TCP/IP模型各个层次的功能和协议
查看>>
C 游戏所要看的书
查看>>
Ehcache详细解读(转)
查看>>
UIImagePickerController本地化控件文字
查看>>
CSS3 页面跳转的动画效果
查看>>
Android中的跨进程通信方法实例及特点分析(二):ContentProvider
查看>>
POJ 2676/2918 数独(dfs)
查看>>
Linux kernel Panic 相关知识
查看>>
iOS 从相机或相册获取图片并裁剪
查看>>
ansilbe 入门001、ansible的介绍
查看>>
C++14介绍
查看>>
iOS-- 快速集成iOS基于RTMP的视频推流
查看>>
BZOJ1497: [NOI2006]最大获利[最小割 最大闭合子图]
查看>>
使用Ecplise git commit时出现"There are no stages files"
查看>>
Linux中变量#,#,@,0,0,1,2,2,*,$$,$?的含义
查看>>
C语言 · 核桃的数量
查看>>
第一百五十六节,封装库--JavaScript,延迟加载
查看>>