1. 广播的方式是发送给同一网段下的所有主机,过多的广播数据会占用大量带宽,会造成广播风暴, 影响正常通信;
2. 所以 主机之间一对 一组 的通信模式,即组播,只有加入了同一个组的主机可以收到此组内的所有数据 ;
3. 组播的 IP 地址: 224.0.0.0~239.255.255.255
组播创建步骤:
1、发送端:
创建报式套接字,填充接收端的IP和端口,发送数据
2、接收端(类似服务器:
创建报式套接字,加入多播组,绑定组播IP和端口,绑定自身IP和端口号,recvfrom
发送端代码
#include<stdio.h>
#include<sys/socket.h>
#include<arpa/inet.h>
#include<sys/ipc.h>
#include<netinet/in.h>
#include<unistd.h>
#include<string.h>
#include<sys/types.h>#define ERR_MSG(msg) do{\fprintf(stderr,"__%d__:",__LINE__);\perror(msg);\
}while(0)
#define PORT 8888 //端口号 1024~49151
#define GRP_IP "224.1.2.3" //组播IP 224.0.0.0~239.255.255.255
int main(int argc, const char *argv[])
{//创建报式套接字int sfd=socket(AF_INET,SOCK_DGRAM,0);if(sfd<0){ERR_MSG("socket");return -1;}//绑定发送端的IP和端口,非必须绑定//接收端必填struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(PORT);sin.sin_addr.s_addr = inet_addr(GRP_IP);char buf[128]="";ssize_t res = 0;while(1){//发送数据包bzero(buf,sizeof(buf));printf("请输入>>>");fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1]=0;//填写发送方if(sendto(sfd,buf,sizeof(buf),0,(struct sockaddr*)&sin,sizeof(sin))<0){ERR_MSG("sendto");return -1;}printf("sendto success\n");}close(sfd);return 0;
}
接收端代码
#include<stdio.h>
#include<sys/socket.h>
#include<arpa/inet.h>
#include<sys/ipc.h>
#include<netinet/in.h>
#include<unistd.h>
#include<string.h>
#include<sys/types.h>#define ERR_MSG(msg) do{\fprintf(stderr,"__%d__:",__LINE__);\perror(msg);\
}while(0)
#define PORT 8888 //端口号 1024~49151
#define GRP_IP "224.1.2.3" //组播IP 224.0.0.0~239.255.255.255
int main(int argc, const char *argv[])
{//创建报式套接字int sfd=socket(AF_INET,SOCK_DGRAM,0);if(sfd<0){ERR_MSG("socket");return -1;}//加入多播组struct ip_mreqn mq;mq.imr_multiaddr.s_addr = inet_addr(GRP_IP); //组播IPmq.imr_address.s_addr=inet_addr("192.168.31.168"); //本机IPmq.imr_ifindex=2; //网络设备索引号if(setsockopt(sfd,IPPROTO_IP,IP_ADD_MEMBERSHIP,&mq,sizeof(mq))<0){ERR_MSG("setsockopt");return -1;}printf("加入多播组成功\n");//填充接收端自身的地址信息结构体struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(PORT);sin.sin_addr.s_addr = inet_addr(GRP_IP);//绑定接收端的IP和端口,必须绑定if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))<0){ERR_MSG("bind");return -1;}printf("bind success\n");char buf[128]="";ssize_t res = 0;struct sockaddr_in cin;socklen_t addrlen = sizeof(cin);while(1){//接收数据包bzero(buf,sizeof(buf));res=recvfrom(sfd,buf,sizeof(buf),0,(struct sockaddr*)&cin,&addrlen);if(res<0){ERR_MSG("recvfrom");return -1;}printf("[%s:%d]:%s\n",inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),buf);}close(sfd);return 0;
}
