linux C语言udp 多线程接受消息并打印
时间: 2023-07-05 14:12:08 浏览: 98
C# UDP多线程发送接收
下面是一个使用 C 语言在 Linux 下通过 UDP 多线程接收消息并打印的示例程序:
```c
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>
#define PORT 8888
#define BUFFER_SIZE 1024
void *receive_message(void *arg) {
int sockfd = *(int *)arg;
struct sockaddr_in client_addr;
char buffer[BUFFER_SIZE];
// 接收消息
int len, n;
len = sizeof(client_addr);
while (1) {
n = recvfrom(sockfd, (char *)buffer, BUFFER_SIZE, MSG_WAITALL, (struct sockaddr *)&client_addr, &len);
buffer[n] = '\0';
printf("Received message: %s\n", buffer);
}
return NULL;
}
int main() {
int sockfd;
struct sockaddr_in server_addr;
// 创建 socket
if ((sockfd = socket(AF_INET, SOCK_DGRAM, 0)) < 0) {
perror("socket creation failed");
exit(EXIT_FAILURE);
}
// 设置服务器地址
memset(&server_addr, 0, sizeof(server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = INADDR_ANY;
server_addr.sin_port = htons(PORT);
// 绑定 socket
if (bind(sockfd, (const struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
perror("bind failed");
exit(EXIT_FAILURE);
}
// 创建线程接收消息
pthread_t tid;
if (pthread_create(&tid, NULL, receive_message, &sockfd) != 0) {
perror("thread creation failed");
exit(EXIT_FAILURE);
}
// 等待线程结束
if (pthread_join(tid, NULL) != 0) {
perror("thread join failed");
exit(EXIT_FAILURE);
}
// 关闭 socket
close(sockfd);
return 0;
}
```
在该示例程序中,首先创建了一个 UDP Socket,并绑定到本地地址和端口上。然后创建一个线程负责接收消息,并在主线程中等待该线程结束。在接收消息的线程中,通过 recvfrom 函数接收消息,并打印接收到的消息。
可以通过编译并运行该程序,在另一台计算机上使用相同的端口发送消息,即可在该程序的控制台看到接收到的消息。
阅读全文