「实现UDP聊天,附Linux代码」 (linux基于udp的聊天程序代码)
实现UDP聊天,附Linux代码
近年来,随着互联网和移动设备的普及,聊天工具成为了人们日常生活和工作不可或缺的一部分,而其中UDP协议在实现轻量级即时通讯方面发挥着重要的作用。本文将详细介绍如何通过UDP协议在Linux系统下实现简单的聊天功能,并附上相关代码。
一、UDP介绍
UDP(User Datagram Protocol)用户数据报协议是一种无连接的传输层协议,它不保证可靠性和完整性,但可以快速进行数据传输,因此常用于实时性较强的应用场景,例如音视频传输、视频游戏等。与TCP协议相比,UDP没有建立连接和拆除连接的过程,传输速度更快且开销更小;但UDP也缺少数据包的确认和重传机制,容易发生丢包现象。
二、UDP聊天实现过程
1.初始化
在使用UDP协议进行通信前,必须进行一些初始化工作。下面的函数完成对socket的初始化,本例使用的是IPv4:
sockfd = socket(AF_INET, SOCK_DGRAM, 0);
if (sockfd
perror(“Error opening socket\n”);
exit(1);
}
memset(&servaddr, 0, sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
servaddr.sin_port = htons(PORT);
2.发送数据
使用UDP协议发送数据时,需要指定目标主机的IP地址和端口号。下面的函数可以实现将数据发送到目标地址:
sendto(sockfd, (const char *)msg, strlen(msg), MSG_CONFIRM, (const struct sockaddr *) &cliaddr,
sizeof(cliaddr));
其中,msg为要发送的消息,cliaddr包含目标主机的IP和端口号。
3.接收数据
使用UDP协议接收数据时,需要设置套接字为非阻塞模式,以避免进程被挂起。下面的函数可以实现从指定端口号接收数据:
n = recvfrom(sockfd, (char *)buffer, MAXLINE, MSG_WTALL, (struct sockaddr *) &cliaddr,
&len);
其中,buffer为接收数据的缓冲区,MAXLINE为缓冲区的大小,cliaddr为接收地址信息。
4.绑定端口
在使用UDP协议进行通信时,需要为套接字绑定一个端口号。在下列代码中,我们使用固定的端口号,但也可以随机选择一个端口号:
if ((bind(sockfd, (const struct sockaddr *)&servaddr, sizeof(servaddr)))
perror(“Error binding to socket\n”);
exit(1);
}
因为UDP协议是无连接的,所以多个进程可以通过同一个端口号进行通信。但如果多个进程绑定到同一个端口号,则只有最后一个进程能够接收到数据包。
三、完整代码实现
下面是一个运行良好的UDP聊天程序,它能够实现双方之间的交互。需要注意的是,该程序是基于Linux系统开发的,Windows环境下需要进行相应的修改:
#include
#include
#include
#include
#include
#include
#include
#include
#define PORT 8080
#define MAXLINE 1024
int mn() {
int sockfd;
char buffer[MAXLINE];
char *hello = “Hello from server”;
struct sockaddr_in servaddr, cliaddr;
// Creating socket file descriptor
sockfd = socket(AF_INET, SOCK_DGRAM, 0);
if (sockfd
perror(“socket creation fled”);
exit(EXIT_FLURE);
}
memset(&servaddr, 0, sizeof(servaddr));
memset(&cliaddr, 0, sizeof(cliaddr));
// Filling server information
servaddr.sin_family = AF_INET; // IPv4
servaddr.sin_addr.s_addr = INADDR_ANY;
servaddr.sin_port = htons(PORT);
// Bind the socket with the server address
if (bind(sockfd, (const struct sockaddr *)&servaddr, sizeof(servaddr))
perror(“bind fled”);
exit(EXIT_FLURE);
}
int len, n;
len = sizeof(cliaddr); //len is value/result
while (1) {
n = recvfrom(sockfd, (char *)buffer, MAXLINE, MSG_WTALL, (struct sockaddr *)&cliaddr,
&len);
buffer[n] = ‘\0’;
printf(“Client : %s\n”, buffer);
if (strcmp(buffer, “exit”) == 0) {
printf(“Client Exit…\n”);
break;
}
printf(“Server : “);
fgets(buffer, MAXLINE, stdin);
sendto(sockfd, (const char *)buffer, strlen(buffer), MSG_CONFIRM, (const struct sockaddr *)&cliaddr,
len);
if (strcmp(buffer, “exit\n”) == 0) {
printf(“Server Exit…\n”);
break;
}
bzero(buffer, MAXLINE);
}
close(sockfd);
return 0;
}
四、