当前位置：首页 > news >正文

网络通信（基于UDP协议的Socket编程模型）

news 来源：原创 2024/9/20 12:40:14

被接收者需要完成的任务(服务端)：
1、创建socket内核对象，内核创建完成后会返回它的描述符
type：SOCK_DGRAM
2、准备本机地址(ip地址+端口号)
3、绑定(把本机地址与socket对象进行绑定)

for(;;)
{
4、接收请求，同时接收发送者的地址
5、返回结果，按发送者的地址进行返回
}
6、关闭Socket对象

发送者需要完成的任务：
1、创建socket内核对象，内核创建完成后会返回它的描述符
type：SOCK_DGRAM
2、准备接收者的地址(ip地址+端口号)

for(;;)
{
3、发送请求，根据接收者的地址发送数据
4、接收结果，并接收返回者的地址
}
5、关闭Socket对象

size_t sendto(int sockfd, const void *buf, size_t len, int flags,const struct sockaddr *dest_addr, socklen_t addrlen);
功能：UDP专用的数据发送函数。
dest_addr：收件人的地址。
addrlen：地址长度。ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,struct sockaddr *src_addr, socklen_t *addrlen);
功能：UDP专用的数据接收函数。
src_addr：发件人的地址，也是数据返回时的地址
addrlen：地址长度，既是输入也是输出

服务端：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>int main(int argc,const char* argv[])
{int sockfd = socket(AF_INET,SOCK_DGRAM,0);if(0 > sockfd){perror("socket");return -1;}struct sockaddr_in addr;addr.sin_family = AF_INET;addr.sin_port = htons(3344);addr.sin_addr.s_addr = inet_addr("10.0.2.15");socklen_t addrlen = sizeof(addr);if(bind(sockfd,(struct sockaddr*)&addr,addrlen)){perror("bind");return -2;}char buf[BUFSIZ];for(;;){int ret = recvfrom(sockfd,buf,BUFSIZ,0,(struct sockaddr*)&addr,&addrlen);if(0 >= ret)break;printf("recv:%s byte:%d from:%s:%hu\n",buf,ret,inet_ntoa(addr.sin_addr),ntohs(addr.sin_port));strcat(buf,",return!");ret = sendto(sockfd,buf,strlen(buf)+1,0,(struct sockaddr*)&addr,addrlen);if(0 >= ret)break;}printf("通信结束！\n");close(sockfd);return 0;
}

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>int main(int argc,const char* argv[])
{int sockfd = socket(AF_INET,SOCK_DGRAM,0);if(0 > sockfd){perror("socket");return -1;}	struct sockaddr_in addr;addr.sin_family = AF_INET;addr.sin_port = htons(3344);addr.sin_addr.s_addr = inet_addr("10.0.2.15");socklen_t addrlen = sizeof(addr);if(connect(sockfd,(struct sockaddr*)&addr,addrlen)){perror("connect");return -2;}char buf[BUFSIZ];for(;;){printf(">>>");scanf("%s",buf);//int ret = sendto(sockfd,buf,strlen(buf)+1,0,//		(struct sockaddr*)&addr,addrlen);int ret = send(sockfd,buf,strlen(buf)+1,0);if(0 >= ret || !strcmp("quit",buf))break;// ret = recvfrom(sockfd,buf,BUFSIZ,0,//		(struct sockaddr*)&addr,&addrlen);ret = recv(sockfd,buf,BUFSIZ,0);if(0 >= ret)break;printf("recv:%s byte:%d from:%s:%hu\n",buf,ret,inet_ntoa(addr.sin_addr),ntohs(addr.sin_port));}printf("通信结束！\n");close(sockfd);return 0;
}