「实现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;

}

四、


数据运维技术 » 「实现UDP聊天,附Linux代码」 (linux基于udp的聊天程序代码)