#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <errno.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include <pthread.h> #define MAX_CLIENTS 10 #define BUFFER_SIZE 1024 int client_sockets[MAX_CLIENTS]; pthread_t threads[MAX_CLIENTS]; int num_clients = 0; void *client_handler(void *arg) { int client_socket = *(int *)arg; char buffer[BUFFER_SIZE]; while(1) { int recv_len = recv(client_socket, buffer, BUFFER_SIZE, 0); if(recv_len == -1) { perror("recv"); break; } if(recv_len == 0) { printf("Client disconnected\n"); break; } buffer[recv_len] = '\0'; printf("Received message: %s\n", buffer); for(int i = 0; i < num_clients; i++) { if(client_sockets[i] != client_socket) { send(client_sockets[i], buffer, strlen(buffer), 0); } } } close(client_socket); pthread_exit(NULL); } int main(int argc, char *argv[]) { int server_socket, client_socket; struct sockaddr_in server_addr, client_addr; socklen_t client_len = sizeof(client_addr); int port = 8888; if(argc > 1) { port = atoi(argv[1]); } server_socket = socket(AF_INET, SOCK_STREAM, 0); if(server_socket == -1) { perror("socket"); exit(EXIT_FAILURE); } memset(&server_addr, 0, sizeof(server_addr)); server_addr.sin_family = AF_INET; server_addr.sin_addr.s_addr = htonl(INADDR_ANY); server_addr.sin_port = htons(port); if(bind(server_socket, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) { perror("bind"); exit(EXIT_FAILURE); } if(listen(server_socket, MAX_CLIENTS) == -1) { perror("listen"); exit(EXIT_FAILURE); } printf("Server started on port %d\n", port); while(1) { client_socket = accept(server_socket, (struct sockaddr *)&client_addr, &client_len); if(client_socket == -1) { perror("accept"); continue; } printf("New client connected: %s\n", inet_ntoa(client_addr.sin_addr)); if(num_clients >= MAX_CLIENTS) { printf("Reached maximum number of clients\n"); close(client_socket); continue; } client_sockets[num_clients] = client_socket; pthread_create(&threads[num_clients], NULL, client_handler, (void *)&client_socket); num_clients++; } close(server_socket); return 0; }
时间: 2024-04-28 17:19:12 浏览: 11
这是一个使用 C 语言编写的简单的多客户端聊天室服务器程序。它使用了 TCP 协议和 POSIX 线程库。服务器监听指定端口,当客户端连接进来时,它会创建一个新的线程处理该客户端的消息。每当一个客户端发送消息时,服务器会将该消息广播给所有其他客户端。
客户端连接上服务器后,可以发送消息给其他客户端。服务器会将该消息广播到所有其他连接的客户端,使得所有客户端都能看到这个消息。当客户端关闭连接时,服务器会将该客户端从客户端列表中去除。
该程序还有一些限制,例如最多只支持 10 个客户端同时连接,如果达到了这个限制,新的客户端连接会被拒绝。
相关问题
#include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <sys/socket.h> #include <arpa/inet.h>分别有什么作用
这些引用中包含了C语言的头文件,这些头文件中定义了一些函数和变量,可以在程序中使用。具体来说:
- #include <stdio.h>:定义了输入输出函数,例如printf和scanf。
- #include <stdlib.h>:定义了一些通用的函数,例如malloc和free,用于动态内存分配和释放。
- #include <string.h>:定义了一些字符串处理函数,例如strcpy和strcat。
- #include <unistd.h>:定义了一些系统调用函数,例如fork和execve。
- #include <sys/socket.h>:定义了一些网络编程相关的函数和数据结构,例如socket和sockaddr。
- #include <arpa/inet.h>:定义了一些网络字节序和主机字节序之间的转换函数,例如htonl和ntohs。
这些头文件中的函数和变量可以帮助程序员更方便地编写程序,提高程序的可读性和可维护性。
虚拟机centos没有那个文件或目录 #include <winsock2.h>该怎么办
`#include <winsock2.h>` 是 Windows 平台的头文件,如果你在 CentOS 虚拟机上编译程序,应该使用 Linux 平台的头文件。具体来说,你需要包含 `<sys/socket.h>`、`<netinet/in.h>` 和 `<arpa/inet.h>` 这三个头文件来使用 Linux 平台的套接字 API。
另外,Linux 平台的套接字 API 在使用时需要链接 `libsocket` 库(或者 `libws2_32` 库,如果你在 Windows 平台上编译程序的话需要链接 `ws2_32.lib` 库)。你可以在编译时加上 `-lsocket` 参数来链接 `libsocket` 库,例如:
```
gcc -o server server.c -lsocket
```
以下是一个在 CentOS 上使用 Linux 平台的套接字 API 实现的服务器示例代码:
```c
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
int main() {
int server_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); // 创建套接字
if (server_socket < 0) {
perror("socket");
return 1;
}
struct sockaddr_in server_addr;
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
server_addr.sin_port = htons(8000);
int iResult = bind(server_socket, (struct sockaddr*)&server_addr, sizeof(server_addr)); // 绑定套接字
if (iResult < 0) {
perror("bind");
close(server_socket);
return 1;
}
iResult = listen(server_socket, SOMAXCONN); // 监听套接字
if (iResult < 0) {
perror("listen");
close(server_socket);
return 1;
}
printf("服务器已启动,等待连接...\n");
int counter = 0;
while (1) {
struct sockaddr_in client_addr;
socklen_t client_addr_len = sizeof(client_addr);
int client_socket = accept(server_socket, (struct sockaddr*)&client_addr, &client_addr_len); // 接受客户端连接
if (client_socket < 0) {
perror("accept");
close(server_socket);
return 1;
}
counter++; // 每当有一个新的客户端连接时,计数器加1
printf("客户端 %s:%d 已连接,是今天的第 %d 个客户端。\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port), counter);
char reply[1024];
sprintf(reply, "你是今天第%d个客户端", counter);
send(client_socket, reply, strlen(reply), 0); // 发送回复消息
close(client_socket);
}
close(server_socket);
return 0;
}
```
在 Linux 平台上,我们使用了 `socklen_t` 类型来表示套接字地址结构体的大小。另外,我们使用了 `close()` 函数来关闭套接字连接。