Linux TCP 服务器禁用 Nagle 算法防止粘包并处理多个客户端

"#include <stdio.h>\n#include <stdlib.h>\n#include <string.h>\n#include <unistd.h>\n#include <arpa/inet.h>\n\n#define PORT 8080\n#define BUFFER_SIZE 1024\n\nint main() {\n int server_fd, new_socket, valread;\n struct sockaddr_in address;\n int opt = 1;\n int addrlen = sizeof(address);\n char buffer[BUFFER_SIZE] = {0};\n\n // 创建socket\n if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {\n perror("socket failed");\n exit(EXIT_FAILURE);\n }\n\n // 设置socket选项，禁用Nagle算法\n if (setsockopt(server_fd, IPPROTO_TCP, TCP_NODELAY, &opt, sizeof(opt))) {\n perror("setsockopt failed");\n exit(EXIT_FAILURE);\n }\n\n address.sin_family = AF_INET;\n address.sin_addr.s_addr = INADDR_ANY;\n address.sin_port = htons(PORT);\n\n // 绑定地址和端口\n if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) {\n perror("bind failed");\n exit(EXIT_FAILURE);\n }\n\n // 监听连接\n if (listen(server_fd, 3) < 0) {\n perror("listen failed");\n exit(EXIT_FAILURE);\n }\n\n printf("Server listening on port %d\n", PORT);\n\n while (1) {\n // 接受新的连接\n if ((new_socket = accept(server_fd, (struct sockaddr )&address, (socklen_t)&addrlen)) < 0) {\n perror("accept failed");\n exit(EXIT_FAILURE);\n }\n\n printf("New client connected\n");\n\n // 创建子进程处理客户端请求\n if (fork() == 0) {\n // 关闭服务器的socket\n close(server_fd);\n\n while (1) {\n // 从客户端接收数据\n if ((valread = read(new_socket, buffer, BUFFER_SIZE)) == 0) {\n printf("Client disconnected\n");\n break;\n }\n\n printf("Received: %s", buffer);\n\n // 清空缓冲区\n memset(buffer, 0, BUFFER_SIZE);\n\n // 向客户端发送响应\n char *response = "Hello from server\n";\n send(new_socket, response, strlen(response), 0);\n }\n\n // 关闭客户端的socket\n close(new_socket);\n\n exit(EXIT_SUCCESS);\n } else {\n // 关闭客户端的socket\n close(new_socket);\n }\n }\n\n return 0;\n}\n"\n