用linux写的多线程聊天室

使用Linux编写多线程聊天室通常涉及以下几个基础概念：

基础概念

多线程：多线程是指在一个进程中运行多个线程，每个线程执行不同的任务。多线程可以提高程序的并发性和响应速度。
套接字编程：套接字（Socket）是网络编程的基础，用于实现不同计算机之间的通信。
线程同步：在多线程环境中，线程同步是确保多个线程安全访问共享资源的关键技术，常用的同步机制包括互斥锁（Mutex）、信号量（Semaphore）等。

类型

基于TCP的多线程聊天室：使用TCP协议保证数据传输的可靠性，适用于需要稳定通信的场景。
基于UDP的多线程聊天室：使用UDP协议，传输速度快但不保证数据可靠性，适用于对实时性要求高的场景。

应用场景

在线客服系统：多线程聊天室可以用于构建高效的在线客服系统，支持多个客服同时与客户交流。
在线教育平台：在在线教育平台中，多线程聊天室可以用于师生之间的实时交流。
社交应用：多线程聊天室是社交应用中实现实时聊天功能的基础。

示例代码

以下是一个简单的基于TCP的多线程聊天室服务器示例代码：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include <sys/socket.h>
#include <netinet/in.h>

#define MAX_CLIENTS 10
#define BUFFER_SIZE 1024

int client_sockets[MAX_CLIENTS] = {0};
int client_count = 0;

void *handle_client(void *arg) {
    int client_socket = *(int *)arg;
    char buffer[BUFFER_SIZE];
    int read_size;

    while ((read_size = recv(client_socket, buffer, BUFFER_SIZE, 0)) > 0) {
        buffer[read_size] = '\0';
        printf("Received: %s", buffer);

        for (int i = 0; i < client_count; i++) {
            if (client_sockets[i] != client_socket) {
                send(client_sockets[i], buffer, read_size, 0);
            }
        }
    }

    for (int i = 0; i < client_count; i++) {
        if (client_sockets[i] == client_socket) {
            client_sockets[i] = client_sockets[client_count - 1];
            client_count--;
            break;
        }
    }

    close(client_socket);
    free(arg);
    return NULL;
}

int main(int argc, char *argv[]) {
    int server_socket, client_socket;
    struct sockaddr_in server_addr, client_addr;
    socklen_t client_addr_size;

    if (argc != 2) {
        fprintf(stderr, "Usage: %s <port>\n", argv[0]);
        exit(1);
    }

    server_socket = socket(AF_INET, SOCK_STREAM, 0);
    if (server_socket == -1) {
        perror("Socket failed");
        exit(1);
    }

    server_addr.sin_family = AF_INET;
    server_addr.sin_addr.s_addr = INADDR_ANY;
    server_addr.sin_port = htons(atoi(argv[1]));

    if (bind(server_socket, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) {
        perror("Bind failed");
        close(server_socket);
        exit(1);
    }

    listen(server_socket, 3);

    printf("Chat server started on port %s\n", argv[1]);

    while (1) {
        client_addr_size = sizeof(client_addr);
        client_socket = accept(server_socket, (struct sockaddr *)&client_addr, &client_addr_size);

        if (client_count < MAX_CLIENTS) {
            client_sockets[client_count++] = client_socket;
            pthread_t thread_id;
            int *new_sock = malloc(sizeof(int));
            *new_sock = client_socket;
            if (pthread_create(&thread_id, NULL, handle_client, (void *)new_sock) != 0) {
                perror("Could not create thread");
                return 1;
            }
            pthread_detach(thread_id);
        } else {
            send(client_socket, "Chat room is full", 18, 0);
            close(client_socket);
        }
    }

    close(server_socket);
    return 0;
}