Linux使用并发程序编写多人聊天室

要在Linux上编写一个多人聊天室，你可以使用并发编程来处理多个客户端的连接和通信。以下是一个简单的示例程序，可以作为你开始的基础：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <pthread.h>

#define MAX_CLIENTS 10

int client_sockets[MAX_CLIENTS];
pthread_t client_threads[MAX_CLIENTS];

void *client_handler(void *arg) {
    int client_socket = *(int *)arg;
    char buffer[1024];
    ssize_t read_size;

    while ((read_size = recv(client_socket, buffer, sizeof(buffer), 0)) > 0) {
        // 处理接收到的消息，例如广播给所有客户端
        for (int i = 0; i < MAX_CLIENTS; i++) {
            if (client_sockets[i] != 0 && client_sockets[i] != client_socket) {
                send(client_sockets[i], buffer, read_size, 0);
            }
        }

        memset(buffer, 0, sizeof(buffer));
    }

    // 客户端断开连接
    for (int i = 0; i < MAX_CLIENTS; i++) {
        if (client_sockets[i] == client_socket) {
            client_sockets[i] = 0;
            break;
        }
    }

    close(client_socket);
    pthread_exit(NULL);
}

int main() {
    int server_socket, client_socket;
    struct sockaddr_in server_addr, client_addr;
    socklen_t client_addr_len;

    // 创建服务器套接字
    server_socket = socket(AF_INET, SOCK_STREAM, 0);
    if (server_socket == -1) {
        perror("Failed to create socket");
        exit(EXIT_FAILURE);
    }

    // 设置服务器地址
    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = INADDR_ANY;
    server_addr.sin_port = htons(8888);

    // 绑定服务器套接字到指定地址和端口
    if (bind(server_socket, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
        perror("Failed to bind");
        exit(EXIT_FAILURE);
    }

    // 监听连接
    if (listen(server_socket, 3) < 0) {
        perror("Failed to listen");
        exit(EXIT_FAILURE);
    }

    printf("Server started. Waiting for connections...\n");

    // 接受客户端连接并处理
    int index = 0;
    while ((client_socket = accept(server_socket, (struct sockaddr *)&client_addr, &client_addr_len)) > 0) {
        printf("New client connected: %s:%d\n", inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));

        // 将客户端套接字添加到数组中
        client_sockets[index] = client_socket;

        // 创建一个线程来处理客户端
        if (pthread_create(&client_threads[index], NULL, client_handler, (void *)&client_socket) < 0) {
            perror("Failed to create thread");
            exit(EXIT_FAILURE);
        }

        index++;
    }

    if (client_socket < 0) {
        perror("Failed to accept connection");
        exit(EXIT_FAILURE);
    }

    // 关闭服务器套接字
    close(server_socket);

    return 0;
}

这个简单的聊天室程序使用了多线程来同时处理多个客户端连接。它创建了一个服务器套接字并绑定到指定的地址和端口。然后，它监听连接并接受客户端连接。每当有一个新的客户端连接时，它会创建一个新的线程来处理该客户端。

在 `client_handler` 函数中，我们使用 `recv` 函数来接收客户端发送的消息，并将消息广播给所有其他客户端。当客户端断开连接时，它将从套接字数组中移除，并关闭套接字。

请注意，此示例程序仅提供了基本的框架，你可能需要根据你的实际需求进行修改和扩展。同时，你还需要处理客户端之间的消息协议、错误处理等方面的问题。