c语言怎么实现网络聊天室

要在C语言中实现一个网络聊天室，你需要使用套接字编程（socket programming）和多线程或多进程。以下是一个简单的实现步骤：

包含必要的头文件：

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

定义全局变量和函数原型：

#define PORT 8080
#define BUFFER_SIZE 1024

int client_sockets[100];
int client_count = 0;
pthread_mutex_t lock;

void *handle_client(void *arg);

主函数：

int main() {
    int server_fd, client_fd;
    struct sockaddr_in server_addr, client_addr;
    socklen_t client_addr_size;

    // 创建套接字
    server_fd = socket(AF_INET, SOCK_STREAM, 0);
    if (server_fd == -1) {
        perror("socket");
        exit(1);
    }

    // 配置服务器地址
    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_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) {
        perror("bind");
        exit(1);
    }

    // 监听连接
    if (listen(server_fd, 100) == -1) {
        perror("listen");
        exit(1);
    }

    pthread_mutex_init(&lock, NULL);

    printf("Server is running on port %d\n", PORT);

    while (1) {
        client_addr_size = sizeof(client_addr);
        client_fd = accept(server_fd, (struct sockaddr *)&client_addr, &client_addr_size);
        if (client_fd == -1) {
            perror("accept");
            continue;
        }

        pthread_t thread;
        pthread_create(&thread, NULL, handle_client, (void *)client_fd);
        pthread_detach(thread);
    }

    close(server_fd);
    return 0;
}

处理客户端连接的函数：

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

    while (1) {
        ssize_t received = recv(client_fd, buffer, BUFFER_SIZE, 0);
        if (received <= 0) {
            break;
        }

        pthread_mutex_lock(&lock);
        for (int i = 0; i< client_count; i++) {
            if (client_sockets[i] != client_fd) {
                send(client_sockets[i], buffer, received, 0);
            }
        }
        pthread_mutex_unlock(&lock);
    }

    pthread_mutex_lock(&lock);
    for (int i = 0; i< client_count; i++) {
        if (client_sockets[i] == client_fd) {
            client_sockets[i] = client_sockets[client_count - 1];
            client_count--;
            break;
        }
    }
    pthread_mutex_unlock(&lock);

    close(client_fd);
    return NULL;
}

编译并运行服务器：

gcc server.c -o server -lpthread
./server

创建一个客户端程序，用于连接到服务器并发送/接收消息。客户端程序的实现与上述服务器程序类似，但不需要监听和接受连接。你可以使用 connect() 函数连接到服务器，然后使用 send() 和 recv() 函数发送和接收消息。
编译并运行客户端：

gcc client.c -o client
./client

现在你可以运行多个客户端实例，它们将能够在聊天室中发送和接收消息。请注意，这个示例仅用于演示目的，实际应用中可能需要考虑更多的错误处理和功能。

最新问答

相关标签