socket编程——UDP协议（C语言编程）

1、收发信息
                ssize_t sendto(int socket,void *message,size_t length,int flags,struct sockaddr *dest_addr,socklen_t dest_len);
                    返回值:length是多少,就返回多少
                    参数:dest_addr -->存放目标ip和端口号
                ssize_t recvfrom(int socket, void *buffer,size_t length,int flags, struct sockaddr *address,socklen_t *address_len);
                    返回值:跟recv差不多，但是重要区别是:recv函数断开连接就不会阻塞,返回0，recvfrom函数一直阻塞
                    参数:address -->存放对方的ip和端口号2、udp的广播和组播
                   第一个:广播
                      思路:
                        发送端                            接收端
                       socket()                          socket()
                       bind()//不可以使用具体的ip         bind()//必须使用系统定义的宏INADDR_ANY
                             使用系统定义的宏INADDR_ANY
                       设置套接字的属性为可以广播         recvfrom()
                       sendto()//必须使用广播地址         close()
                       close()
                   第二个:组播
                        发送端                                接收端
                       socket()                              socket()
                       bind()//不可以使用具体的ip             bind()//必须使用系统定义的宏INADDR_ANY
                             使用系统定义的宏INADDR_ANY       将接收端添加到组播组
                       设置套接字的属性为可以广播             recvfrom()
                       sendto()//必须使用组播地址(D类地址)    close()

代码实现：

发送端

int main()
{
	int udpsock;
	int ret;
	char buf[20];
	struct sockaddr_in bindaddr;
	bzero(&bindaddr,sizeof bindaddr);
	bindaddr.sin_family=PF_INET;
	bindaddr.sin_port=htons(10000);
	bindaddr.sin_addr.s_addr=inet_addr("192.168.22.9");
	
	//目标ip和端口号
	struct sockaddr_in destaddr;
	bzero(&destaddr,sizeof destaddr);
	destaddr.sin_family=PF_INET;
	destaddr.sin_port=htons(20000);
	destaddr.sin_addr.s_addr=inet_addr("192.168.22.9");
	
	//创建udp套接字
	udpsock=socket(PF_INET,SOCK_DGRAM,0);
	if(udpsock==-1)
	{
		perror("创建udp套接字!\n");
		return -1;
	}
	//绑定
	ret=bind(udpsock,(struct sockaddr *)&bindaddr,sizeof(bindaddr));
	if(ret==-1)
	{
		perror("绑定失败!\n");
		return -1;
	}
	while(1)
	{
		bzero(buf,20);
		printf("请输入要发送给对方的信息!\n");
		scanf("%s",buf);
		//发送信息给对方
		ret=sendto(udpsock,buf,20,0,(struct sockaddr *)&destaddr,sizeof(destaddr));
		printf("sendto 返回值是:%d\n",ret);
	}
	
	//挂机
	close(udpsock);
	return 0;
}

接收端：

/*
	udp单向通信
*/
int main()
{
	int udpsock;
	int ret;
	char buf[20]={0};
	struct sockaddr_in bindaddr;
	bzero(&bindaddr,sizeof bindaddr);
	bindaddr.sin_family=PF_INET;
	bindaddr.sin_port=htons(20000);
	bindaddr.sin_addr.s_addr=inet_addr("192.168.22.9");
	
	//目标ip和端口号
	struct sockaddr_in srcaddr;
	bzero(&srcaddr,sizeof srcaddr);
	int addrsize=sizeof srcaddr;
	
	//创建udp套接字
	udpsock=socket(PF_INET,SOCK_DGRAM,0);
	if(udpsock==-1)
	{
		perror("创建udp套接字!\n");
		return -1;
	}
	//绑定
	ret=bind(udpsock,(struct sockaddr *)&bindaddr,sizeof(bindaddr));
	if(ret==-1)
	{
		perror("绑定失败!\n");
		return -1;
	}
	while(1)
	{
		bzero(buf,20);
		//接收信息
		ret=recvfrom(udpsock,buf,8,0,(struct sockaddr *)&srcaddr,&addrsize);
		printf("recvfrom 返回值是:%d 内容是:%s\n",ret,buf);
	}
	//挂机
	close(udpsock);
	return 0;
}