从TCP三次握手到守护进程：Linux网络编程实战与日志分析

从TCP三次握手到守护进程：Linux网络编程实战与日志分析

发布时间：2026/8/22 17:28:50
从TCP三次握手到守护进程：Linux网络编程实战与日志分析 1. 从一次失败的远程调试说起为什么需要理解TCP通信全貌上周我帮一个刚入行的同事排查一个线上服务间歇性连接失败的问题。他的服务端程序在Linux上跑客户端偶尔会报“Connection refused”。他翻遍了业务逻辑代码没找到问题最后把日志发给我看。我扫了一眼发现他的服务端在accept之后直接开始读写数据但日志里完全没有记录listen调用是否成功、bind的端口是否被占用、甚至服务进程是不是还活着。整个通信过程对他而言就像一个黑盒只知道一头一尾中间TCP协议栈到底在干嘛一概不知。这让我意识到很多开发者虽然每天都在用socket、bind、listen、accept这些系统调用但对它们背后代表的TCP协议通信流程、状态变迁尤其是三次握手和四次挥手的具体发生时机缺乏直观的、代码层面的认知。理解TCP协议通信的完整流程不仅仅是背下“三次握手建立连接四次挥手断开连接”这个口诀。更重要的是你要能清晰地回答在我的代码中listen执行时内核在做什么accept返回的那个新套接字对应的是TCP连接的哪个状态客户端调用close和服务端调用close触发的挥手过程一样吗为什么我的服务进程退出后端口还会处于TIME_WAIT状态导致短时间内无法重启这些问题只有当你亲手模拟实现一遍TCP协议的通信骨架并将关键节点的状态变化通过日志记录下来才能有刻骨铭心的理解。更进一步对于网络服务程序我们通常希望它能在后台稳定运行不受终端关闭的影响这就需要引入“守护进程”的概念。今天我们就围绕这个目标进行一次深度实践用C语言在Linux上模拟一个基础的TCP Echo服务器和客户端实现一个简单的日志函数来记录通信全流程的关键事件最后将服务器改造为守护进程。我们不仅会写出可以运行的代码更会深入每一个系统调用背后的协议原理把抽象的概念变成屏幕上滚动的、可追溯的日志行。2. TCP协议通信流程全景与代码映射在动手写代码之前我们必须把TCP协议的标准通信流程从教科书上的图示翻译成我们即将要写的每一行代码。这是一个典型的C/S模型我们分服务器和客户端两条线来梳理。2.1 服务器端从创建套接字到等待连接服务器端的流程是一个被动的、等待连接的过程。它的核心任务是为每一个到来的客户端连接准备一个独立的“会话通道”。第一步创建监听套接字socket这是所有网络通信的起点。socket()系统调用向内核申请一个通信端点并指定协议族如IPv4的AF_INET和套接字类型如面向字节流的SOCK_STREAM对应TCP协议。调用成功会返回一个文件描述符fd这是后续所有操作的句柄。此时这个套接字还没有和任何网络地址绑定也不能进行通信它只是一个“原材料”。第二步绑定地址与端口bindbind()调用将上一步创建的“裸”套接字与一个具体的本地IP地址和端口号绑定。对于服务器这通常是通配地址INADDR_ANY表示监听所有本地网卡和一个众所周知的端口如8080。这一步至关重要它告诉操作系统“所有发往本机这个端口的数据包都交给这个套接字来处理。”如果端口已被占用bind会失败。第三步开始监听listenlisten()调用将这个已绑定的套接字从一个“普通”套接字转变为“监听”套接字。它的作用是创建一个连接队列通常分为“未完成连接队列”和“已完成连接队列”并开始等待客户端的连接请求SYN包。调用listen后服务器才真正具备了接受连接的能力。参数backlog指定了已完成连接队列的最大长度它影响着服务器在高并发下能暂时存放多少已建立但尚未被accept取走的连接。第四步接受连接accept这是一个阻塞默认情况下调用。accept()从监听套接字的“已完成连接队列”中取出一个客户端连接。如果队列为空进程就会在这里睡眠直到有连接到来。accept成功会返回一个全新的套接字文件描述符。这个新套接字才是与客户端进行数据读写的通道。而最初的监听套接字它的使命就是不断地accept产生新的通信套接字。这里有一个关键理解监听套接字只用于接受连接从不用于收发数据数据收发全部通过accept返回的新套接字进行。2.2 客户端发起连接的主动方客户端的流程相对直接是连接的发起者。第一步创建套接字socket与服务器端相同客户端也需要先创建一个套接字。第二步连接服务器connect这是客户端最核心的一步。connect()系统调用会向服务器指定的IP和端口发起TCP连接请求也就是发送SYN包。这个调用会触发TCP三次握手过程。在握手成功完成之前connect默认是阻塞的。一旦connect成功返回就意味着从客户端的视角看TCP连接已经建立成功可以开始发送数据了。2.3 数据交换与连接终止连接建立后双方通过read/recv和write/send在这些已连接的套接字上进行全双工的数据交换。当一方决定关闭连接时会调用close()或shutdown()关闭自己的套接字。这里有一个巨大的误区close调用并不直接对应发送FIN包。close调用会将套接字引用计数减1。只有当引用计数减到0即所有进程都关闭了这个套接字时内核协议栈才会开始正常的TCP连接终止序列即发送FIN包开始四次挥手过程。另一方收到FIN后会回应ACK并可能继续发送剩余数据最终也关闭自己的这一端。注意理解close与FIN发送的异步性是理解连接关闭和TIME_WAIT状态产生的关键。很多时候你快速重启服务器失败就是因为上一个连接还处于TIME_WAIT状态端口未被释放。3. 三次握手与四次挥手在代码执行流中的精确发生点现在我们把经典的协议状态图嵌入到上述代码执行流程中看看握手和挥手究竟发生在哪一行代码的前后。3.1 三次握手连接建立的舞蹈三次握手的目标是同步双方的初始序列号ISN协商参数建立连接。第一次握手SYN发生在客户端调用connect()时。connect函数内部客户端TCP协议栈会构建一个SYN报文设置SYN标志位包含客户端的初始序列号client_isn发送给服务器。此时客户端进入SYN_SENT状态。在代码层面你调用connect然后这个函数阻塞住了就是在等待这次握手的结果。第二次握手SYN-ACK服务器端的TCP协议栈一直在监听端口。当收到客户端的SYN包后如果接受连接监听队列未满服务器TCP协议栈会回复一个SYN-ACK报文同时设置SYN和ACK标志位包含服务器的初始序列号server_isn并对客户端的client_isn进行确认ackclient_isn1。此时服务器端内核将该连接放入“未完成连接队列”服务器进入SYN_RCVD状态。注意这个过程完全由内核自动完成发生在你的服务器应用程序调用accept()从队列中取出连接之前。listen调用只是开启了接收SYN包的大门。第三次握手ACK客户端收到服务器的SYN-ACK后其TCP协议栈会发送一个ACK报文确认server_isn。发送完毕后客户端认为连接已建立状态变为ESTABLISHED。同时connect()函数成功返回代码继续向下执行。 服务器端在收到这个ACK后会将对应的连接从“未完成连接队列”移到“已完成连接队列”状态也变为ESTABLISHED。此时这个连接才在accept的取用范围内。关键结论accept()调用本身不参与三次握手。它只是从“已完成连接队列”里取出一个已经完成握手的连接。握手过程在connect调用和内核后台处理中完成。因此accept的阻塞是在等待一个“已经建立好”的连接而不是在等待握手完成。3.2 四次挥手连接终止的优雅告别假设客户端先发起关闭。第一次挥手FIN客户端应用程序调用close(cli_sock)。如前所述当这是该套接字的最后一个引用时客户端TCP协议栈会发送一个FIN报文表示客户端数据已发送完毕。客户端进入FIN_WAIT_1状态。代码层面close调用通常立即返回但FIN的发送和后续挥手过程在后台异步进行。第二次挥手ACK服务器端TCP协议栈收到FIN后立即回复一个ACK报文进行确认。服务器端进入CLOSE_WAIT状态。此时从客户端到服务器的数据传输通道关闭但服务器到客户端的方向仍然可以发送数据。在服务器应用程序中如果此时调用read会返回0读到EOF这通常是服务器感知到客户端已关闭的信号。第三次挥手FIN当服务器应用程序也处理完所有数据并调用close(svr_conn_sock)关闭连接套接字时服务器TCP协议栈会发送FIN报文。服务器进入LAST_ACK状态。第四次挥手ACK客户端收到服务器的FIN后回复ACK确认。客户端随后进入TIME_WAIT状态等待2MSLMaximum Segment Lifetime报文最大生存时间通常为2分钟后才彻底关闭连接释放资源。服务器在收到这个ACK后连接关闭。关键理解TIME_WAIT状态发生在主动关闭连接的一方此例中是客户端。它的存在有两个主要目的一是可靠地终止TCP连接防止最后一个ACK丢失导致服务器重传FIN二是让旧连接的重复报文在网络中消逝避免被新建立的、相同四元组源IP、源端口、目的IP、目的端口的连接错误接收。这也是为什么服务器重启时如果上次是它主动关闭了大量连接可能会遇到“Address already in use”错误的原因之一。4. 模拟实现一个带日志的TCP Echo服务器理论清晰了我们开始用代码实现。我们先实现一个最基础的、带日志功能的TCP Echo服务器。所谓Echo就是服务器把客户端发来的任何数据原封不动地发回去。4.1 日志函数的设计与实现在调试网络程序时打印日志到标准输出stdout是不够的尤其是对于守护进程。我们需要一个简单的日志函数能输出到文件并包含时间戳、进程ID、日志级别和自定义信息。// simple_logger.h #ifndef SIMPLE_LOGGER_H #define SIMPLE_LOGGER_H typedef enum { LOG_LEVEL_DEBUG, LOG_LEVEL_INFO, LOG_LEVEL_WARN, LOG_LEVEL_ERROR } log_level_t; void log_init(const char *log_file); void log_message(log_level_t level, const char *format, ...); void log_close(void); // 方便使用的宏 #define LOG_DEBUG(...) log_message(LOG_LEVEL_DEBUG, __VA_ARGS__) #define LOG_INFO(...) log_message(LOG_LEVEL_INFO, __VA_ARGS__) #define LOG_WARN(...) log_message(LOG_LEVEL_WARN, __VA_ARGS__) #define LOG_ERROR(...) log_message(LOG_LEVEL_ERROR, __VA_ARGS__) #endif// simple_logger.c #include stdio.h #include stdlib.h #include stdarg.h #include time.h #include unistd.h #include string.h #include simple_logger.h static FILE *log_fp NULL; static const char *level_strings[] {DEBUG, INFO, WARN, ERROR}; void log_init(const char *log_file) { if (log_file) { log_fp fopen(log_file, a); // 以追加模式打开 if (!log_fp) { perror(fopen log file failed); log_fp stdout; // 失败则回退到标准输出 } } else { log_fp stdout; } // 设置文件流为行缓冲确保每条日志能及时写入 setlinebuf(log_fp); LOG_INFO(Logger initialized. PID: %d, getpid()); } void log_message(log_level_t level, const char *format, ...) { if (!log_fp) return; // 未初始化则忽略 time_t now; struct tm *local_time; char time_buf[64]; time(now); local_time localtime(now); strftime(time_buf, sizeof(time_buf), %Y-%m-%d %H:%M:%S, local_time); // 打印固定的头部信息时间、PID、日志级别 fprintf(log_fp, [%s][PID:%5d][%-5s] , time_buf, getpid(), level_strings[level]); // 打印用户自定义的格式化信息 va_list args; va_start(args, format); vfprintf(log_fp, format, args); va_end(args); fprintf(log_fp, \n); } void log_close(void) { if (log_fp log_fp ! stdout) { LOG_INFO(Logger closing.); fclose(log_fp); } log_fp NULL; }这个日志器虽然简单但具备了核心功能按级别输出、带时间戳和进程ID、支持格式化字符串、可输出到文件。我们在网络程序的每个关键节点调用它。4.2 TCP Echo服务器核心代码现在我们编写服务器主程序在每个关键系统调用前后插入日志。// tcp_echo_server.c #include stdio.h #include stdlib.h #include string.h #include unistd.h #include signal.h #include sys/socket.h #include netinet/in.h #include arpa/inet.h #include simple_logger.h #define PORT 8080 #define BACKLOG 5 #define BUFFER_SIZE 1024 int main() { int server_fd, client_fd; struct sockaddr_in server_addr, client_addr; socklen_t client_addr_len sizeof(client_addr); char buffer[BUFFER_SIZE]; ssize_t bytes_read; // 1. 初始化日志输出到文件 server.log log_init(server.log); LOG_INFO(TCP Echo Server starting...); // 2. 创建套接字 (对应 socket() 系统调用) server_fd socket(AF_INET, SOCK_STREAM, 0); if (server_fd 0) { LOG_ERROR(Socket creation failed); perror(socket); exit(EXIT_FAILURE); } LOG_INFO(Socket created. fd%d, server_fd); // 设置 SO_REUSEADDR 选项避免 TIME_WAIT 状态导致 bind 失败 int opt 1; if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR, opt, sizeof(opt))) { LOG_WARN(setsockopt(SO_REUSEADDR) failed, but continue...); } // 3. 绑定地址 (对应 bind() 系统调用) memset(server_addr, 0, sizeof(server_addr)); server_addr.sin_family AF_INET; server_addr.sin_addr.s_addr INADDR_ANY; // 监听所有网卡 server_addr.sin_port htons(PORT); // 主机字节序转网络字节序 if (bind(server_fd, (struct sockaddr*)server_addr, sizeof(server_addr)) 0) { LOG_ERROR(Bind failed on port %d, PORT); perror(bind); close(server_fd); exit(EXIT_FAILURE); } LOG_INFO(Bind successful. IP: %s, Port: %d, inet_ntoa(server_addr.sin_addr), ntohs(server_addr.sin_port)); // 4. 开始监听 (对应 listen() 系统调用) if (listen(server_fd, BACKLOG) 0) { LOG_ERROR(Listen failed); perror(listen); close(server_fd); exit(EXIT_FAILURE); } LOG_INFO(Listening started. Backlog size: %d. Waiting for connections..., BACKLOG); // 主循环接受并处理连接 while (1) { // 5. 接受连接 (对应 accept() 系统调用) // 这个调用会阻塞直到有客户端完成三次握手连接进入已完成队列 LOG_INFO(Blocking on accept()...); client_fd accept(server_fd, (struct sockaddr*)client_addr, client_addr_len); if (client_fd 0) { LOG_ERROR(Accept failed); perror(accept); continue; // 接受失败继续等待下一个连接 } // 连接建立成功此时三次握手已完成。 LOG_INFO(New connection accepted! Client fd%d, IP:%s, Port:%d, client_fd, inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port)); // 处理客户端数据 (这是一个简单的Echo处理) while ((bytes_read read(client_fd, buffer, BUFFER_SIZE - 1)) 0) { buffer[bytes_read] \0; // 确保字符串终止 LOG_DEBUG(Received %zd bytes from fd%d: [%.*s], bytes_read, client_fd, (int)bytes_read, buffer); // Echo 回去 if (write(client_fd, buffer, bytes_read) ! bytes_read) { LOG_ERROR(Failed to echo data back to fd%d, client_fd); break; } LOG_DEBUG(Echoed %zd bytes back to fd%d, bytes_read, client_fd); } // 读取结束判断是正常关闭还是出错 if (bytes_read 0) { // read 返回 0 表示对端已关闭连接发送了FIN LOG_INFO(Client fd%d closed the connection (read返回0). Starting TCP挥手过程., client_fd); } else if (bytes_read 0) { LOG_ERROR(Error reading from fd%d, client_fd); perror(read); } // 6. 关闭连接套接字 (对应 close() 系统调用) // 服务器调用close触发服务器端的FIN发送如果是最后一个引用 LOG_INFO(Closing connection fd%d, client_fd); if (close(client_fd) 0) { LOG_ERROR(Failed to close fd%d, client_fd); perror(close); } LOG_INFO(Connection fd%d closed., client_fd); } // 理论上循环不会退出这里是为了完整性 LOG_INFO(Server shutting down.); close(server_fd); log_close(); return 0; }4.3 配套的简单TCP客户端为了测试服务器我们需要一个客户端。// tcp_echo_client.c #include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/socket.h #include netinet/in.h #include arpa/inet.h #include simple_logger.h #define SERVER_IP 127.0.0.1 #define SERVER_PORT 8080 #define BUFFER_SIZE 1024 int main(int argc, char *argv[]) { int sock_fd; struct sockaddr_in server_addr; char buffer[BUFFER_SIZE]; ssize_t bytes_sent, bytes_recv; log_init(client.log); LOG_INFO(TCP Echo Client starting. Connecting to %s:%d, SERVER_IP, SERVER_PORT); // 1. 创建套接字 sock_fd socket(AF_INET, SOCK_STREAM, 0); if (sock_fd 0) { LOG_ERROR(Socket creation failed); perror(socket); exit(EXIT_FAILURE); } LOG_INFO(Socket created. fd%d, sock_fd); // 2. 设置服务器地址 memset(server_addr, 0, sizeof(server_addr)); server_addr.sin_family AF_INET; server_addr.sin_port htons(SERVER_PORT); if (inet_pton(AF_INET, SERVER_IP, server_addr.sin_addr) 0) { LOG_ERROR(Invalid address / Address not supported); perror(inet_pton); close(sock_fd); exit(EXIT_FAILURE); } // 3. 连接服务器 (对应 connect() 系统调用触发三次握手) LOG_INFO(Attempting to connect... (This triggers TCP三次握手)); if (connect(sock_fd, (struct sockaddr*)server_addr, sizeof(server_addr)) 0) { LOG_ERROR(Connection failed); perror(connect); close(sock_fd); exit(EXIT_FAILURE); } LOG_INFO(Connection established! TCP三次握手 completed.); // 4. 发送数据 const char *message Hello, TCP Server!; bytes_sent write(sock_fd, message, strlen(message)); if (bytes_sent 0) { LOG_ERROR(Send failed); perror(write); } else { LOG_INFO(Sent %zd bytes: %s, bytes_sent, message); } // 5. 接收回显数据 bytes_recv read(sock_fd, buffer, BUFFER_SIZE - 1); if (bytes_recv 0) { LOG_ERROR(Receive failed); perror(read); } else if (bytes_recv 0) { LOG_INFO(Server closed the connection prematurely.); } else { buffer[bytes_recv] \0; LOG_INFO(Received %zd bytes echo: %s, bytes_recv, buffer); } // 6. 关闭连接 (对应 close() 系统调用触发四次挥手的第一步) LOG_INFO(Closing socket (Initiating TCP四次挥手)...); if (close(sock_fd) 0) { LOG_ERROR(Failed to close socket); perror(close); } LOG_INFO(Socket closed. Client exiting.); log_close(); return 0; }4.4 编译、运行与日志分析在Linux终端中分别编译服务器和客户端gcc -o tcp_echo_server tcp_echo_server.c simple_logger.c gcc -o tcp_echo_client tcp_echo_client.c simple_logger.c首先在一个终端启动服务器./tcp_echo_server然后在另一个终端运行客户端./tcp_echo_client观察服务器和客户端日志文件server.log和client.log你会看到类似以下的输出清晰地标记了每个系统调用和其对应的协议事件server.log 片段[2023-10-27 10:00:00][PID:12345][INFO ] TCP Echo Server starting... [2023-10-27 10:00:00][PID:12345][INFO ] Socket created. fd3 [2023-10-27 10:00:00][PID:12345][INFO ] Bind successful. IP: 0.0.0.0, Port: 8080 [2023-10-27 10:00:00][PID:12345][INFO ] Listening started. Backlog size: 5. Waiting for connections... [2023-10-27 10:00:05][PID:12345][INFO ] Blocking on accept()... [2023-10-27 10:00:05][PID:12345][INFO ] New connection accepted! Client fd4, IP:127.0.0.1, Port:34567 [2023-10-27 10:00:05][PID:12345][DEBUG] Received 19 bytes from fd4: [Hello, TCP Server!] [2023-10-27 10:00:05][PID:12345][DEBUG] Echoed 19 bytes back to fd4 [2023-10-27 10:00:05][PID:12345][INFO ] Client fd4 closed the connection (read返回0). Starting TCP挥手过程. [2023-10-27 10:00:05][PID:12345][INFO ] Closing connection fd4 [2023-10-27 10:00:05][PID:12345][INFO ] Connection fd4 closed.client.log 片段[2023-10-27 10:00:05][PID:67890][INFO ] TCP Echo Client starting. Connecting to 127.0.0.1:8080 [2023-10-27 10:00:05][PID:67890][INFO ] Socket created. fd3 [2023-10-27 10:00:05][PID:67890][INFO ] Attempting to connect... (This triggers TCP三次握手) [2023-10-27 10:00:05][PID:67890][INFO ] Connection established! TCP三次握手 completed. [2023-10-27 10:00:05][PID:67890][INFO ] Sent 19 bytes: Hello, TCP Server! [2023-10-27 10:00:05][PID:67890][INFO ] Received 19 bytes echo: Hello, TCP Server! [2023-10-27 10:00:05][PID:67890][INFO ] Closing socket (Initiating TCP四次挥手)... [2023-10-27 10:00:05][PID:67890][INFO ] Socket closed. Client exiting.通过日志我们可以清晰地看到服务器在accept()处阻塞。客户端调用connect()日志提示“触发三次握手”。客户端connect()成功返回日志提示“三次握手完成”。此时在服务器内核中该连接已进入已完成队列。服务器accept()返回获得新fd4日志打印“New connection accepted”。这验证了accept只是从队列中取连接不参与握手。数据收发。客户端先调用close()日志提示“发起四次挥手”。服务器read()返回0日志提示“客户端关闭连接开始TCP挥手过程”。这对应服务器收到了客户端的FIN。服务器调用close()关闭连接套接字。5. 将服务器守护进程化脱离终端稳定运行目前我们的服务器运行在前台终端关闭或CtrlC都会导致进程终止。对于线上服务我们需要将其变为守护进程Daemon使其在后台运行脱离控制终端不会因为用户登出而停止。5.1 守护进程化的标准步骤创建一个标准的守护进程通常需要以下步骤这些步骤主要是为了与当前环境“脱钩”并避免产生不必要的副作用创建子进程父进程退出fork()后让父进程退出子进程继续。这保证了子进程不是进程组的首进程为后续setsid创造条件同时让终端认为命令已执行完毕。子进程创建新会话调用setsid()。这个调用有三个重要作用让子进程成为新会话的首进程。让子进程成为新进程组的组长进程。让子进程脱离原来的控制终端。这是成为守护进程的关键一步。再次fork父进程退出这是“双重fork”技巧。目的是确保守护进程永远不会重新获得控制终端因为只有会话首进程才能打开控制终端。再次fork后产生孙子进程让孙子进程成为最终的守护进程而子进程退出。清除文件创建掩码调用umask(0)。避免从父进程继承来的文件掩码影响守护进程创建文件的权限。改变工作目录调用chdir(“/”)。将当前工作目录切换到根目录避免守护进程阻止某个挂载点被卸载。关闭不需要的文件描述符关闭从父进程继承的所有打开的文件描述符通常是遍历0到sysconf(_SC_OPEN_MAX)只保留必要的如日志文件、监听套接字。重定向标准输入、输出、错误将stdin、stdout、stderr重定向到/dev/null或指定的日志文件防止守护进程在后台意外读写终端。5.2 实现守护进程化函数我们将上述步骤封装成一个函数// daemonize.c #include stdio.h #include stdlib.h #include unistd.h #include sys/stat.h #include fcntl.h #include sys/resource.h #include simple_logger.h void daemonize(const char *cmd) { int i, fd0, fd1, fd2; pid_t pid; struct rlimit rl; LOG_INFO(Starting daemonize process for: %s, cmd); // 1. 清除文件创建掩码 umask(0); // 2. 获取最大文件描述符数 if (getrlimit(RLIMIT_NOFILE, rl) 0) { LOG_ERROR(Can‘t get file limit); exit(EXIT_FAILURE); } // 3. 第一次fork父进程退出 if ((pid fork()) 0) { LOG_ERROR(First fork failed); exit(EXIT_FAILURE); } else if (pid ! 0) { // 父进程 exit(EXIT_SUCCESS); } // 子进程继续 LOG_DEBUG(First fork succeeded, child PID: %d, getpid()); // 4. 创建新会话脱离控制终端 if (setsid() 0) { LOG_ERROR(setsid failed); exit(EXIT_FAILURE); } LOG_DEBUG(New session created. SID: %d, getsid(0)); // 5. 第二次fork确保不是会话首进程防止重新获取控制终端 if ((pid fork()) 0) { LOG_ERROR(Second fork failed); exit(EXIT_FAILURE); } else if (pid ! 0) { // 父进程第一次fork的子进程退出 exit(EXIT_SUCCESS); } // 孙子进程最终的守护进程继续 LOG_DEBUG(Second fork succeeded, daemon PID: %d, getpid()); // 6. 改变工作目录到根目录 if (chdir(/) 0) { LOG_ERROR(Can‘t change directory to /); exit(EXIT_FAILURE); } LOG_DEBUG(Changed working directory to /); // 7. 关闭所有从父进程继承的文件描述符 if (rl.rlim_max RLIM_INFINITY) { rl.rlim_max 1024; // 设定一个上限 } for (i 0; i rl.rlim_max; i) { close(i); } LOG_DEBUG(Closed all inherited file descriptors (0-%d), rl.rlim_max - 1); // 8. 重定向 stdin, stdout, stderr 到 /dev/null fd0 open(/dev/null, O_RDWR); fd1 dup(0); // 复制 stdin 的文件描述符 fd2 dup(0); // 再次复制 if (fd0 ! 0 || fd1 ! 1 || fd2 ! 2) { // 如果重定向失败记录错误但可能继续运行取决于严格程度 LOG_ERROR(Unexpected file descriptors after redirection: %d %d %d, fd0, fd1, fd2); } else { LOG_DEBUG(Standard I/O redirected to /dev/null); } LOG_INFO(Daemonize completed successfully. Daemon PID: %d, getpid()); }5.3 改造TCP服务器为守护进程现在我们修改之前的服务器主函数在初始化日志后立即调用daemonize函数。// tcp_echo_server_daemon.c (主函数部分修改) int main() { // 1. 初始化日志此时日志可能还在终端输出 log_init(server_daemon.log); LOG_INFO(TCP Echo Server (Daemon) starting...); // 2. 守护进程化 daemonize(tcp_echo_server_daemon); // 注意daemonize() 函数内部会关闭所有继承的文件描述符包括标准输入输出 // 但我们的 log_fp 是在 daemonize 之前用 fopen 打开的它会被关闭 // 因此必须在 daemonize 之后重新初始化日志让日志输出到文件。 log_close(); // 先关闭旧的可能已被关闭的FILE指针 log_init(server_daemon.log); // 重新初始化此时进程已脱离终端log_fp指向文件。 LOG_INFO(Daemon re-initialized logger. Ready to start network service.); // 3. 后续的socket创建、bind、listen、accept循环代码与之前完全相同 // ... (复制之前tcp_echo_server.c中socket()之后的代码) int server_fd socket(AF_INET, SOCK_STREAM, 0); // ... 其余代码完全一致 }关键点与避坑这里有一个非常重要的细节。我们在daemonize之前调用了log_init但daemonize函数会关闭所有从父进程继承的文件描述符包括log_init打开的文件描述符。虽然FILE*流log_fp是用户空间的指针但其底层的文件描述符已被关闭继续使用会导致程序崩溃或日志丢失。因此必须在daemonize之后重新初始化所有需要长期持有的资源比如日志、配置文件、监听套接字等。这也是为什么我们把socket()的创建放在daemonize之后。如果监听套接字在daemonize之前创建它也会被关闭导致服务失效。编译并运行守护进程版本的服务器gcc -o tcp_echo_server_daemon tcp_echo_server_daemon.c simple_logger.c daemonize.c ./tcp_echo_server_daemon运行后你会发现终端立即返回了提示符而进程已经在后台运行。你可以使用ps aux | grep tcp_echo_server_daemon查看进程使用kill命令结束它。所有的运行日志都记录在server_daemon.log文件中即使你关闭终端服务器依然在运行。6. 进阶议题连接处理与并发模型我们的示例服务器是单进程、阻塞式、一次处理一个连接的。这在学习阶段足够但在实际生产中无法应对多个并发连接。这里简要提一下后续的演进方向作为你深入学习的路标。多进程模型在accept到一个新连接后调用fork()创建一个子进程子进程专门处理这个连接父进程继续accept。这是最传统的并发模型实现简单但进程创建开销大连接数高时资源消耗严重。多线程模型与多进程类似但使用pthread_create创建线程来处理新连接。线程共享地址空间创建和切换开销比进程小但需要处理复杂的线程同步问题锁、条件变量等。I/O多路复用I/O Multiplexing这是现代高性能网络服务器的基石。使用select、poll或epollLinux特有等系统调用在一个线程内同时监控多个文件描述符的读写状态。当某个描述符就绪如有数据可读、可写时程序才对其进行操作避免了为每个连接创建一个线程/进程的巨大开销。epoll在处理大量并发连接时性能极高。反应堆Reactor模式与事件驱动基于I/O多路复用构建一个事件循环Event Loop。将所有的I/O操作读、写、接受连接都转化为事件由事件循环统一分发到对应的回调函数事件处理器中去处理。像Nginx、Redis等高性能服务器都采用了此类模型。异步I/OAsynchronous I/O由内核在I/O操作完成后主动通知应用程序应用程序在等待I/O期间完全不需要阻塞。Linux的AIO接口和Windows的IOCP属于此类。理论上性能最高但编程模型复杂。对于我们的Echo服务器下一步可以尝试用epoll将其改造成一个单线程即可处理成千上万个并发连接的高性能服务器这将是对你理解Linux网络编程的又一次巨大提升。