写网络程序这事儿很多学C语言的朋友卡了好几年。数组、指针、结构体都折腾明白了一到Socket就蒙圈——其实不怪你Socket这套东西本身不复杂但它藏在一堆看似枯燥的概念后面端口、字节序、三次握手、阻塞与非阻塞每样都够喝一壶。我把C语言网络编程基础里最关键的Socket通信原理和TCP/UDP实战写法完整梳理一遍从系统接口怎么调到粘包、超时、多路复用怎么处理全部用能跑的代码说话。这篇内容适合两类人一是刚入门C语言、想搞懂网络编程的学生二是做嵌入式或者后端、需要快速捡起Socket开发的工程师。读完你自己就能写出一套服务端加客户端并且知道为什么代码要这么写。1. 上手之前先想清楚这几个概念1.1 Socket在操作系统里的真实身份很多教程喜欢把Socket解释成“套接字”这个词太抽象了第一次听的人完全没概念。我的理解很简单Socket本质上是操作系统提供的一个网络编程接口。你调用socket()函数内核返回给你一个int类型的文件描述符之后你对这个描述符做read、write、close操作内核就会帮你完成数据的网络收发。可以把它想象成去邮局寄包裹。你不需要知道邮局内部的分拣系统怎么运作只需要把包裹从窗口递进去邮局保证它被送到目的地。Socket就是那个窗口。它屏蔽了下层复杂的IP路由、网卡驱动、协议栈处理让你像读写文件一样操作网络数据。这个设计是Unix“一切皆文件”哲学的经典体现。这里有个关键点值得注意服务端的监听套接字和实际通信的套接字是两回事。listen_fd只负责接受新连接accept()返回的client_fd才负责真正收发数据。这个区分想清楚了后面的代码读起来就顺了。1.2 TCP和UDP不是二选一而是两种完全不同的分工初学者最容易纠结的问题就是TCP和UDP到底选哪个其实它俩不是同一个维度的东西你可以这么理解TCP像快递员送货上门你下单后必须等到签字确认丢件了会重新补发UDP像你在广场上喊一嗓子喊出去就完事别人听没听清、听没听到你不负责。维度TCPUDP连接状态面向连接需要建立会话无连接直接发数据可靠性可靠传输丢包会重发尽力而为不保证送达数据顺序保证字节序不保证顺序传输效率较低有头和尾的额外开销高开销小使用场景HTTP、文件传输、消息队列视频通话、游戏状态同步、DNS查询实际开发里可靠性优先的业务选TCP实时性优先的业务选UDP。做视频通话、语音直播如果用TCP一旦网络抖动就会造成明显的卡顿延迟游戏里的角色坐标同步一般也用UDP因为丢一帧坐标问题不大但晚到一帧可能就被人打了。1.3 三次握手与四次挥手用生活场景复盘TCP的三次握手说白了就是建立通话前的确认过程。第一步客户端发SYN相当于“你在吗”第二步服务端回SYN-ACK相当于“我在呢你那边能听到吗”第三步客户端回ACK相当于“听到了咱们开始说话吧”。三次刚刚好为什么不能两次因为如果只有两次握手服务端发出确认后就认为连接建立了但万一这个确认包在网络中滞留客户端根本不知道服务端还要傻等数据浪费资源。四次挥手则是断开连接的过程。有一方先说“我这边说完了”FIN另一方回“收到我知道了”ACK然后另一方处理完手头的事情也说“我也说完了”FIN发起方再回“收到再见”ACK。这就是四次。比握手多一次的原因很简单TCP允许半关闭双方都要独立地关闭各自的数据发送通道所以需要各自确认一轮。这里还有个坑叫TIME_WAIT状态主动关闭方会停留在TIME_WAIT一段时间导致端口看似被占用后面讲端口占用问题时会专门展开。2. 环境准备与核心API速览2.1 你需要准备什么环境方面Linux系统或者Windows的WSL环境都可以我用的是Ubuntu加gcc编译器。如果你用的是纯Windows环境需要安装Winsock库代码上略有差异但核心逻辑完全一致。本文示例代码基于Linux平台用到的头文件有三个#include sys/socket.h、#include netinet/in.h、#include arpa/inet.h。第一个是Socket的API声明第二个定义了sockaddr_in等地址结构体第三个包含inet_pton、inet_ntoa这些地址转换函数。顺手把#include unistd.h也加上read、write、close都在这里头。编译命令很简单一条搞定gcc server.c -o server gcc client.c -o client2.2 从socket()到close()API全链路Socket编程的API不算多但每个都有明确的分工。我建议你按服务端和客户端两条线去记忆。服务端链路是socket()创建套接字bind()绑定IP和端口listen()进入监听状态accept()接受客户端连接然后对accept返回的fd做read/write最后close()关闭。客户端链路是socket()创建套接字connect()发起连接然后read/write收发数据最后close()关闭。函数作用服务端客户端socket()创建套接字必用必用bind()绑定地址端口必用通常不用listen()转为被动监听必用不用accept()接受连接必用不用connect()发起连接不用必用send()/recv()收发数据双向双向close()关闭套接字必用必用2.3 三个参数和一个结构体的细节socket()的三个参数是新手容易糊弄过去但后面一定会吃亏的地方。第一个参数是地址族常用的就是AF_INET代表IPv4。第二个参数是套接字类型SOCK_STREAM对应TCPSOCK_DGRAM对应UDP。第三个参数是协议传0就行让内核根据前两个参数自动推断。地址结构体sockaddr_in这里坑最多。它内部的端口和IP地址必须经过字节序转换才能赋值。因为网络传输是大端字节序而x86主机是小端字节序所以端口要用htons()转换IP地址用htonl()或inet_pton()转换。如果你不转换最典型的症状是bind()返回错误或者监听的端口和你想的不一样。结构体的最简用法是这样的struct sockaddr_in server_addr; memset(server_addr, 0, sizeof(server_addr)); server_addr.sin_family AF_INET; server_addr.sin_port htons(8888); server_addr.sin_addr.s_addr htonl(INADDR_ANY);memset清零这步千万别省不然后面的字节是随机垃圾值bind会失败或者行为诡异。INADDR_ANY代表监听本机所有网卡地址这样无论客户端连哪个IP服务端都能收到。3. TCP通信实战一次完整的往返3.1 服务端绑定、监听、接受连接下面这段代码是一个最小可用的TCP回显服务端客户端发来什么它就原样返回什么。我用它来讲清楚每个环节的用意。#include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/socket.h #include netinet/in.h #include arpa/inet.h int main() { int listen_fd socket(AF_INET, SOCK_STREAM, 0); if (listen_fd 0) { perror(socket); return -1; } struct sockaddr_in server_addr; memset(server_addr, 0, sizeof(server_addr)); server_addr.sin_family AF_INET; server_addr.sin_port htons(8888); server_addr.sin_addr.s_addr htonl(INADDR_ANY); int opt 1; setsockopt(listen_fd, SOL_SOCKET, SO_REUSEADDR, opt, sizeof(opt)); if (bind(listen_fd, (struct sockaddr *)server_addr, sizeof(server_addr)) 0) { perror(bind); close(listen_fd); return -1; } if (listen(listen_fd, 5) 0) { perror(listen); close(listen_fd); return -1; } printf(Server listening on port 8888...\n); while (1) { struct sockaddr_in client_addr; socklen_t len sizeof(client_addr); int client_fd accept(listen_fd, (struct sockaddr *)client_addr, len); if (client_fd 0) { perror(accept); continue; } printf(Client connected: %s:%d\n, inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port)); char buffer[1024]; memset(buffer, 0, sizeof(buffer)); ssize_t n read(client_fd, buffer, sizeof(buffer) - 1); if (n 0) { printf(Received: %s\n, buffer); write(client_fd, buffer, n); } close(client_fd); } close(listen_fd); return 0; }代码里有一个我在工程中一定会加的配置SO_REUSEADDR。它的作用是允许端口在TIME_WAIT状态下可以重新绑定。如果不加这个你写完代码调试时CtrlC结束进程后再重启大概率会遇到“Address already in use”非常烦人。这个选项的优先级比bind()本身还高必须在bind()之前设置好。accept()是阻塞的没有客户端连接时进程会一直卡在这一行。这种写法简单清晰适合理解原理但做不了高并发。想支持多客户端同时在线需要配合多线程或多进程后面第4小节会给出方案。3.2 客户端连接、发送、等待回显客户端的代码比服务端短得多核心就是socket()、connect()和read/write三个环节。#include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/socket.h #include netinet/in.h #include arpa/inet.h int main() { int sock_fd socket(AF_INET, SOCK_STREAM, 0); if (sock_fd 0) { perror(socket); return -1; } struct sockaddr_in server_addr; memset(server_addr, 0, sizeof(server_addr)); server_addr.sin_family AF_INET; server_addr.sin_port htons(8888); if (inet_pton(AF_INET, 127.0.0.1, server_addr.sin_addr) 0) { perror(inet_pton); close(sock_fd); return -1; } if (connect(sock_fd, (struct sockaddr *)server_addr, sizeof(server_addr)) 0) { perror(connect); close(sock_fd); return -1; } char *msg hello from client; write(sock_fd, msg, strlen(msg)); char buffer[1024]; memset(buffer, 0, sizeof(buffer)); ssize_t n read(sock_fd, buffer, sizeof(buffer) - 1); if (n 0) { buffer[n] \0; printf(Server replied: %s\n, buffer); } close(sock_fd); return 0; }这里用inet_pton()把字符串形式的IP地址转换成网络序的二进制地址比老的inet_addr()更安全因为它能区分合法地址和非法地址。connect()也是阻塞式的如果服务端没起来客户端会一直卡在连接阶段直到内核超时。一个小知识点receive端的read()返回0不代表收到空数据而是代表对端正常关闭了连接。这个细节很容易被忽略很多人把返回0当成读到了0字节去处理结果死循环刷屏。正确的做法是返回0就close()跳出循环。3.3 编译运行与自测方法编译和运行很简单两个终端窗口分别执行# 终端1 gcc server.c -o server ./server # 终端2 gcc client.c -o client ./client终端1会打印出客户端连接信息终端2会看到服务端的回显。如果你手头没有client程序可以用Linux自带的网络工具nc测试nc 127.0.0.1 8888输入一行字回车服务端打印收到的内容并原样返回。这个自测方法在调试阶段非常高效不用每次修改都重新编译客户端。接收缓冲区的大小我这个示例用了1024字节。实际项目中要根据协议设计过小会截断数据过大会浪费内存。还有一个常见的坑是read()只调用一次并不能保证完整读到你期望的数据。TCP是流式协议没有消息边界服务端发1000字节客户端第一次read可能只拿到300字节剩下700字节还在内核缓冲区里。这就引出了著名的粘包和拆包问题后面专门讲。3.4 从单连接到多连接用fork处理多客户端上面的回显服务端一次只能服务一个客户端accept()返回后整个进程就阻塞在read()里第二个客户端连进来会一直等着。要支持并发最朴素的做法是fork()。每次accept()拿到新的client_fd就fork一个子进程子进程里处理这个客户端的收发父进程继续accept新的连接。while (1) { int client_fd accept(listen_fd, (struct sockaddr *)client_addr, len); if (client_fd 0) { continue; } pid_t pid fork(); if (pid 0) { // 子进程处理客户端数据 close(listen_fd); // 子进程不需要监听fd char buffer[1024]; ssize_t n; while ((n read(client_fd, buffer, sizeof(buffer))) 0) { write(client_fd, buffer, n); } close(client_fd); exit(0); } // 父进程回收连接fd close(client_fd); }这里面有一个容易踩的坑父进程和子进程共享文件描述符表fork之后client_fd在父子进程里都指向同一个内核文件对象。父进程不close(client_fd)的话即使子进程处理完了连接也不会真正关闭。所以父进程accept完必须close一次子进程用完也必须close一次这个对称原则一定要记牢。用fork做多进程虽然简单但每个连接都独占一个进程内存开销比较大。C10K问题一万个并发连接指的是这就是多进程方案会遇到的瓶颈它催生了后面要讲的select、epoll等多路复用方案。4. UDP通信实战简单直接但别掉以轻心4.1 UDP服务端的一收一发UDP服务端比TCP简单一个量级不需要listen和accept因为UDP本身没有连接的概念。它只需要socket()、bind()然后在一个循环里recvfrom()和sendto()。#include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/socket.h #include netinet/in.h #include arpa/inet.h int main() { int sock_fd socket(AF_INET, SOCK_DGRAM, 0); if (sock_fd 0) { perror(socket); return -1; } struct sockaddr_in server_addr; memset(server_addr, 0, sizeof(server_addr)); server_addr.sin_family AF_INET; server_addr.sin_port htons(9999); server_addr.sin_addr.s_addr htonl(INADDR_ANY); if (bind(sock_fd, (struct sockaddr *)server_addr, sizeof(server_addr)) 0) { perror(bind); close(sock_fd); return -1; } char buffer[1024]; struct sockaddr_in client_addr; socklen_t len sizeof(client_addr); while (1) { memset(buffer, 0, sizeof(buffer)); ssize_t n recvfrom(sock_fd, buffer, sizeof(buffer) - 1, 0, (struct sockaddr *)client_addr, len); if (n 0) { perror(recvfrom); continue; } buffer[n] \0; printf(Received [%s:%d]: %s\n, inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port), buffer); sendto(sock_fd, buffer, n, 0, (struct sockaddr *)client_addr, len); } close(sock_fd); return 0; }recvfrom()的灵魂在于倒数两个参数它们既是“输出”又是“输出参数”。调用时你需要传入一个sockaddr_in结构体让内核填上发送方的地址和端口于是回包的时候你才知道该往哪儿发。如果这两个参数传NULL你只能收却不知道是谁发来的。这也是UDP和TCP编程体验上最大的差异TCP连接建立后就绑定了对方read/write不用关心对方是谁UDP每次收发都像一个陌生人敲门你需要现场问清对方身份。4.2 UDP客户端不连接也能通信UDP客户端更简单socket()之后连bind都不用直接sendto()发给指定地址然后recvfrom()等待回包。#include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/socket.h #include netinet/in.h #include arpa/inet.h int main() { int sock_fd socket(AF_INET, SOCK_DGRAM, 0); if (sock_fd 0) { perror(socket); return -1; } struct sockaddr_in server_addr; memset(server_addr, 0, sizeof(server_addr)); server_addr.sin_family AF_INET; server_addr.sin_port htons(9999); inet_pton(AF_INET, 127.0.0.1, server_addr.sin_addr); char *msg udp hello; sendto(sock_fd, msg, strlen(msg), 0, (struct sockaddr *)server_addr, sizeof(server_addr)); char buffer[1024]; struct sockaddr_in from_addr; socklen_t from_len sizeof(from_addr); ssize_t n recvfrom(sock_fd, buffer, sizeof(buffer) - 1, 0, (struct sockaddr *)from_addr, from_len); if (n 0) { buffer[n] \0; printf(Server replied: %s\n, buffer); } close(sock_fd); return 0; }很多人会问UDP客户端能不能用connect()可以但这个connect和TCP那个connect本质不同。UDP的connect只做一件事在本地绑定对方地址之后sendto()就可以简化成send()内核会自动把数据发给你绑定的那个地址。它不会进行任何握手也不会建立真正的连接。这样做的好处是性能更好坏处是失去了灵活性不能再往别的地址发数据。4.3 丢包、乱序与可靠性设计UDP最大的优势是快最大劣势是丢。实用项目里凡是需要UDP却又不能容忍丢包损失的都会在应用层自己做可靠性机制。我分享一套最基础的方案你在做自己的协议时可以参照每个数据包加上递增的序号接收方可以检测乱序和丢包。发送方维护一个超时定时器发送后如果隔了一段时间没收到ACK就重传。接收方收到乱序包先缓存等前面的序号补齐后再交给上层。这套机制其实就是TCP可靠传输的简化版自己实现要从零处理拥塞、重传时间计算等一堆问题。所以我通常建议不确定自己能力时优先选TCP选UDP的前提是你明确知道自己在做什么而且愿意为可靠性机制付出开发成本。比如游戏同步场景开发团队会自己写一套UDP可靠性层而普通的文件传输、消息推送老老实实TCP就完了。5. 实战中一定会踩的坑5.1 TCP粘包怎么破粘包问题的根源是TCP是流式协议。你在应用层调用两次write()内核协议栈可能把这两段数据合并成一个TCP段发出去接收端一次read()就把两段内容全读走了。反过来一个大报文也可能被拆成多个TCP段接收端需要调用多次read()才能读完整。最简单粗暴的解法是给每条消息定一个固定长度短了就高位补零。缺点是浪费带宽灵活性差。第二种解法是每条消息前面加2字节或4字节的长度头接收端先读长度再根据长度读正文。第三种是消息尾部加特殊分隔符比如换行符接收端持续的找分隔符。工程上除了文本协议最常用的是“长度头加正文”的方案兼顾了效率和通用性。关于“为什么socket接收到奇数字节后面会补一个随机数”这个问题事实是TCP本身不会给你补任何随机数。你看到这种诡异现象说明你的协议设计或者在解析数据时出了问题——比如按固定结构解析但结构体和网络字节序没对齐或者接收缓冲区里残留了旧数据你没有正确清空。不要把buff数组memset()当成强制保险读完一次后直接把长度记住靠长度而不是靠数组内容来切分数据才是正路。5.2 recv返回值和断开连接的正确处理recv()返回值的语义必须刻在脑子里返回值含义处理方式 0读到的字节数正常处理并继续0对端关闭连接close()并退出-1异常或中断检查errnoEINTR则重试其他则关闭我见过最多的bug就是把返回0当成“没有数据”继续循环结果CPU被干到100%。记住阻塞模式下recv()只要阻塞着就说明连接还活着一旦返回0连接已经凉了。另一个常见错误是一次recv()就以为收到了完整的应用层消息。TCP是流不是包。你必须在应用层维护一个接收缓冲区不断把recv()结果追加进去再从缓冲区里按协议解析出完整的消息。这就是解粘包的过程。5.3 超时、断开与优雅关闭阻塞模式下recv()会无限期等待下去。这在生产环境里是不可接受的一个客户端死掉了服务端线程就一直挂着。设置超时最常用的是这行代码struct timeval tv; tv.tv_sec 5; tv.tv_usec 0; setsockopt(client_fd, SOL_SOCKET, SO_RCVTIMEO, tv, sizeof(tv));过了5秒还没收到数据recv()返回-1errno是EAGAIN或EWOULDBLOCK。这时候你就可以主动关闭连接释放资源。优雅关闭也有讲究。close()会立即释放本地fd如果缓冲区里还有未发送的数据TCP会尽力发送但close()之后就不再接收新数据。要用shutdown()可以更精细控制shutdown(fd, SHUT_WR)表示我这边不再发了但还可以收shutdown(fd, SHUT_RD)表示我这边不再收了。在做长连接应用时先shutdown再close是稳妥的做法。5.4 端口被占用怎么办“Address already in use”是服务端开发者的老朋友。原因前面提过主动关闭连接的一方会进入TIME_WAIT状态默认持续2个MSL大约1-4分钟这段期间端口还被系统占着。解决办法就是SO_REUSEADDR。注意SO_REUSEADDR解决的是bind()时TIME_WAIT状态导致的失败不是让你绕过重复bind。如果端口真的被别的存活进程占着加上这个选项也没用得用lsof -i:8888或者netstat -tunlp | grep 8888找出占用进程先处理掉。5.5 最大句柄数与C10K问题每建立一个连接就会占用一个文件描述符。Linux默认的进程fd上限通常是1024也就是说你用多进程方案写服务端很快就撞到天花板。运行前可以用ulimit -n查看不够就执行ulimit -n 65535临时提高或者改/etc/security/limits.conf做持久化。但真正要解决的问题是怎么用有限的线程和fd管理上万个连接——这就是下一节select这类多路复用技术存在的意义。6. 多路复用用select管住所有连接6.1 select到底解决了什么问题回到上面的多进程方案每来一个连接就fork一个进程或线程连接多了系统资源很快就耗尽。多路复用的思路完全不同让一个线程同时监视几百上千个fd内核帮你看哪个fd上来了数据、哪个fd上有了新连接你再去处理“活跃”的那几个。相当于从“一对一服务”变成“一个前台同时盯着所有工位”谁叫号谁上前。select()就是最基础的多路复用接口。它的调用方式是把一堆fd放进fd_set集合然后交给内核去监视有事件发生时内核修改集合告诉你有哪些fd就绪。6.2 一套select骨架代码我写一个最简单但能跑的select骨架它同时监听监听fd和客户端fd有新连接就accept有数据就readfd_set read_fds; FD_ZERO(read_fds); FD_SET(listen_fd, read_fds); int max_fd listen_fd; while (1) { fd_set tmp_fds read_fds; // select会修改集合每次要重新复制 struct timeval timeout; timeout.tv_sec 3; timeout.tv_usec 0; int ret select(max_fd 1, tmp_fds, NULL, NULL, timeout); if (ret 0) { printf(select timeout\n); continue; } if (ret 0) { perror(select); break; } if (FD_ISSET(listen_fd, tmp_fds)) { struct sockaddr_in client_addr; socklen_t len sizeof(client_addr); int client_fd accept(listen_fd, (struct sockaddr *)client_addr, len); printf(Client connected: %s:%d\n, inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port)); FD_SET(client_fd, read_fds); if (client_fd max_fd) { max_fd client_fd; } } char buffer[1024]; for (int fd listen_fd 1; fd max_fd; fd) { if (FD_ISSET(fd, tmp_fds)) { ssize_t n read(fd, buffer, sizeof(buffer)); if (n 0) { write(fd, buffer, n); } else { close(fd); FD_CLR(fd, read_fds); } } } }6.3 几个容易出问题的细节select的坑集中在三处。第一select的max_fd参数要传“最大fd值加1”不是只传最大fd传错会导致它只检查部分fd行为很隐蔽。第二select会修改传入的fd_set集合把没就绪的fd清掉如果你保存了一份原始集合下次调用前必须重新复制所以我在循环里用了fd_set tmp_fds read_fds;。第三timeout参数在select返回后也可能被修改每次调用都必须重新赋值。select能管理的fd数量有上限由FD_SETSIZE决定默认通常1024。要支持更大规模的连接Linux上更好的选择是epollWindows上对应IOCP。select并不是性能最优方案但它逻辑清晰、跨平台性好是理解所有多路复用机制的基础。你把select彻底弄明白了后面学epoll就是水到渠成的事。我个人在实际开发中的一个经验是网络库的封装千千万但内核暴露的这套Socket接口几十年没变过。你把它彻底吃透了不管将来用C、Java还是Go底层网络模型的理解都会让你排查问题比别人快一截。最后再分享一个小技巧写网络程序时永远先跑通单连接再上多路复用先用nc做互测再写客户端这样能把“程序bug”和“网络bug”清晰区分开排查效率高得多。
C语言网络编程实战：Socket通信原理与TCP/UDP开发指南
写网络程序这事儿很多学C语言的朋友卡了好几年。数组、指针、结构体都折腾明白了一到Socket就蒙圈——其实不怪你Socket这套东西本身不复杂但它藏在一堆看似枯燥的概念后面端口、字节序、三次握手、阻塞与非阻塞每样都够喝一壶。我把C语言网络编程基础里最关键的Socket通信原理和TCP/UDP实战写法完整梳理一遍从系统接口怎么调到粘包、超时、多路复用怎么处理全部用能跑的代码说话。这篇内容适合两类人一是刚入门C语言、想搞懂网络编程的学生二是做嵌入式或者后端、需要快速捡起Socket开发的工程师。读完你自己就能写出一套服务端加客户端并且知道为什么代码要这么写。1. 上手之前先想清楚这几个概念1.1 Socket在操作系统里的真实身份很多教程喜欢把Socket解释成“套接字”这个词太抽象了第一次听的人完全没概念。我的理解很简单Socket本质上是操作系统提供的一个网络编程接口。你调用socket()函数内核返回给你一个int类型的文件描述符之后你对这个描述符做read、write、close操作内核就会帮你完成数据的网络收发。可以把它想象成去邮局寄包裹。你不需要知道邮局内部的分拣系统怎么运作只需要把包裹从窗口递进去邮局保证它被送到目的地。Socket就是那个窗口。它屏蔽了下层复杂的IP路由、网卡驱动、协议栈处理让你像读写文件一样操作网络数据。这个设计是Unix“一切皆文件”哲学的经典体现。这里有个关键点值得注意服务端的监听套接字和实际通信的套接字是两回事。listen_fd只负责接受新连接accept()返回的client_fd才负责真正收发数据。这个区分想清楚了后面的代码读起来就顺了。1.2 TCP和UDP不是二选一而是两种完全不同的分工初学者最容易纠结的问题就是TCP和UDP到底选哪个其实它俩不是同一个维度的东西你可以这么理解TCP像快递员送货上门你下单后必须等到签字确认丢件了会重新补发UDP像你在广场上喊一嗓子喊出去就完事别人听没听清、听没听到你不负责。维度TCPUDP连接状态面向连接需要建立会话无连接直接发数据可靠性可靠传输丢包会重发尽力而为不保证送达数据顺序保证字节序不保证顺序传输效率较低有头和尾的额外开销高开销小使用场景HTTP、文件传输、消息队列视频通话、游戏状态同步、DNS查询实际开发里可靠性优先的业务选TCP实时性优先的业务选UDP。做视频通话、语音直播如果用TCP一旦网络抖动就会造成明显的卡顿延迟游戏里的角色坐标同步一般也用UDP因为丢一帧坐标问题不大但晚到一帧可能就被人打了。1.3 三次握手与四次挥手用生活场景复盘TCP的三次握手说白了就是建立通话前的确认过程。第一步客户端发SYN相当于“你在吗”第二步服务端回SYN-ACK相当于“我在呢你那边能听到吗”第三步客户端回ACK相当于“听到了咱们开始说话吧”。三次刚刚好为什么不能两次因为如果只有两次握手服务端发出确认后就认为连接建立了但万一这个确认包在网络中滞留客户端根本不知道服务端还要傻等数据浪费资源。四次挥手则是断开连接的过程。有一方先说“我这边说完了”FIN另一方回“收到我知道了”ACK然后另一方处理完手头的事情也说“我也说完了”FIN发起方再回“收到再见”ACK。这就是四次。比握手多一次的原因很简单TCP允许半关闭双方都要独立地关闭各自的数据发送通道所以需要各自确认一轮。这里还有个坑叫TIME_WAIT状态主动关闭方会停留在TIME_WAIT一段时间导致端口看似被占用后面讲端口占用问题时会专门展开。2. 环境准备与核心API速览2.1 你需要准备什么环境方面Linux系统或者Windows的WSL环境都可以我用的是Ubuntu加gcc编译器。如果你用的是纯Windows环境需要安装Winsock库代码上略有差异但核心逻辑完全一致。本文示例代码基于Linux平台用到的头文件有三个#include sys/socket.h、#include netinet/in.h、#include arpa/inet.h。第一个是Socket的API声明第二个定义了sockaddr_in等地址结构体第三个包含inet_pton、inet_ntoa这些地址转换函数。顺手把#include unistd.h也加上read、write、close都在这里头。编译命令很简单一条搞定gcc server.c -o server gcc client.c -o client2.2 从socket()到close()API全链路Socket编程的API不算多但每个都有明确的分工。我建议你按服务端和客户端两条线去记忆。服务端链路是socket()创建套接字bind()绑定IP和端口listen()进入监听状态accept()接受客户端连接然后对accept返回的fd做read/write最后close()关闭。客户端链路是socket()创建套接字connect()发起连接然后read/write收发数据最后close()关闭。函数作用服务端客户端socket()创建套接字必用必用bind()绑定地址端口必用通常不用listen()转为被动监听必用不用accept()接受连接必用不用connect()发起连接不用必用send()/recv()收发数据双向双向close()关闭套接字必用必用2.3 三个参数和一个结构体的细节socket()的三个参数是新手容易糊弄过去但后面一定会吃亏的地方。第一个参数是地址族常用的就是AF_INET代表IPv4。第二个参数是套接字类型SOCK_STREAM对应TCPSOCK_DGRAM对应UDP。第三个参数是协议传0就行让内核根据前两个参数自动推断。地址结构体sockaddr_in这里坑最多。它内部的端口和IP地址必须经过字节序转换才能赋值。因为网络传输是大端字节序而x86主机是小端字节序所以端口要用htons()转换IP地址用htonl()或inet_pton()转换。如果你不转换最典型的症状是bind()返回错误或者监听的端口和你想的不一样。结构体的最简用法是这样的struct sockaddr_in server_addr; memset(server_addr, 0, sizeof(server_addr)); server_addr.sin_family AF_INET; server_addr.sin_port htons(8888); server_addr.sin_addr.s_addr htonl(INADDR_ANY);memset清零这步千万别省不然后面的字节是随机垃圾值bind会失败或者行为诡异。INADDR_ANY代表监听本机所有网卡地址这样无论客户端连哪个IP服务端都能收到。3. TCP通信实战一次完整的往返3.1 服务端绑定、监听、接受连接下面这段代码是一个最小可用的TCP回显服务端客户端发来什么它就原样返回什么。我用它来讲清楚每个环节的用意。#include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/socket.h #include netinet/in.h #include arpa/inet.h int main() { int listen_fd socket(AF_INET, SOCK_STREAM, 0); if (listen_fd 0) { perror(socket); return -1; } struct sockaddr_in server_addr; memset(server_addr, 0, sizeof(server_addr)); server_addr.sin_family AF_INET; server_addr.sin_port htons(8888); server_addr.sin_addr.s_addr htonl(INADDR_ANY); int opt 1; setsockopt(listen_fd, SOL_SOCKET, SO_REUSEADDR, opt, sizeof(opt)); if (bind(listen_fd, (struct sockaddr *)server_addr, sizeof(server_addr)) 0) { perror(bind); close(listen_fd); return -1; } if (listen(listen_fd, 5) 0) { perror(listen); close(listen_fd); return -1; } printf(Server listening on port 8888...\n); while (1) { struct sockaddr_in client_addr; socklen_t len sizeof(client_addr); int client_fd accept(listen_fd, (struct sockaddr *)client_addr, len); if (client_fd 0) { perror(accept); continue; } printf(Client connected: %s:%d\n, inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port)); char buffer[1024]; memset(buffer, 0, sizeof(buffer)); ssize_t n read(client_fd, buffer, sizeof(buffer) - 1); if (n 0) { printf(Received: %s\n, buffer); write(client_fd, buffer, n); } close(client_fd); } close(listen_fd); return 0; }代码里有一个我在工程中一定会加的配置SO_REUSEADDR。它的作用是允许端口在TIME_WAIT状态下可以重新绑定。如果不加这个你写完代码调试时CtrlC结束进程后再重启大概率会遇到“Address already in use”非常烦人。这个选项的优先级比bind()本身还高必须在bind()之前设置好。accept()是阻塞的没有客户端连接时进程会一直卡在这一行。这种写法简单清晰适合理解原理但做不了高并发。想支持多客户端同时在线需要配合多线程或多进程后面第4小节会给出方案。3.2 客户端连接、发送、等待回显客户端的代码比服务端短得多核心就是socket()、connect()和read/write三个环节。#include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/socket.h #include netinet/in.h #include arpa/inet.h int main() { int sock_fd socket(AF_INET, SOCK_STREAM, 0); if (sock_fd 0) { perror(socket); return -1; } struct sockaddr_in server_addr; memset(server_addr, 0, sizeof(server_addr)); server_addr.sin_family AF_INET; server_addr.sin_port htons(8888); if (inet_pton(AF_INET, 127.0.0.1, server_addr.sin_addr) 0) { perror(inet_pton); close(sock_fd); return -1; } if (connect(sock_fd, (struct sockaddr *)server_addr, sizeof(server_addr)) 0) { perror(connect); close(sock_fd); return -1; } char *msg hello from client; write(sock_fd, msg, strlen(msg)); char buffer[1024]; memset(buffer, 0, sizeof(buffer)); ssize_t n read(sock_fd, buffer, sizeof(buffer) - 1); if (n 0) { buffer[n] \0; printf(Server replied: %s\n, buffer); } close(sock_fd); return 0; }这里用inet_pton()把字符串形式的IP地址转换成网络序的二进制地址比老的inet_addr()更安全因为它能区分合法地址和非法地址。connect()也是阻塞式的如果服务端没起来客户端会一直卡在连接阶段直到内核超时。一个小知识点receive端的read()返回0不代表收到空数据而是代表对端正常关闭了连接。这个细节很容易被忽略很多人把返回0当成读到了0字节去处理结果死循环刷屏。正确的做法是返回0就close()跳出循环。3.3 编译运行与自测方法编译和运行很简单两个终端窗口分别执行# 终端1 gcc server.c -o server ./server # 终端2 gcc client.c -o client ./client终端1会打印出客户端连接信息终端2会看到服务端的回显。如果你手头没有client程序可以用Linux自带的网络工具nc测试nc 127.0.0.1 8888输入一行字回车服务端打印收到的内容并原样返回。这个自测方法在调试阶段非常高效不用每次修改都重新编译客户端。接收缓冲区的大小我这个示例用了1024字节。实际项目中要根据协议设计过小会截断数据过大会浪费内存。还有一个常见的坑是read()只调用一次并不能保证完整读到你期望的数据。TCP是流式协议没有消息边界服务端发1000字节客户端第一次read可能只拿到300字节剩下700字节还在内核缓冲区里。这就引出了著名的粘包和拆包问题后面专门讲。3.4 从单连接到多连接用fork处理多客户端上面的回显服务端一次只能服务一个客户端accept()返回后整个进程就阻塞在read()里第二个客户端连进来会一直等着。要支持并发最朴素的做法是fork()。每次accept()拿到新的client_fd就fork一个子进程子进程里处理这个客户端的收发父进程继续accept新的连接。while (1) { int client_fd accept(listen_fd, (struct sockaddr *)client_addr, len); if (client_fd 0) { continue; } pid_t pid fork(); if (pid 0) { // 子进程处理客户端数据 close(listen_fd); // 子进程不需要监听fd char buffer[1024]; ssize_t n; while ((n read(client_fd, buffer, sizeof(buffer))) 0) { write(client_fd, buffer, n); } close(client_fd); exit(0); } // 父进程回收连接fd close(client_fd); }这里面有一个容易踩的坑父进程和子进程共享文件描述符表fork之后client_fd在父子进程里都指向同一个内核文件对象。父进程不close(client_fd)的话即使子进程处理完了连接也不会真正关闭。所以父进程accept完必须close一次子进程用完也必须close一次这个对称原则一定要记牢。用fork做多进程虽然简单但每个连接都独占一个进程内存开销比较大。C10K问题一万个并发连接指的是这就是多进程方案会遇到的瓶颈它催生了后面要讲的select、epoll等多路复用方案。4. UDP通信实战简单直接但别掉以轻心4.1 UDP服务端的一收一发UDP服务端比TCP简单一个量级不需要listen和accept因为UDP本身没有连接的概念。它只需要socket()、bind()然后在一个循环里recvfrom()和sendto()。#include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/socket.h #include netinet/in.h #include arpa/inet.h int main() { int sock_fd socket(AF_INET, SOCK_DGRAM, 0); if (sock_fd 0) { perror(socket); return -1; } struct sockaddr_in server_addr; memset(server_addr, 0, sizeof(server_addr)); server_addr.sin_family AF_INET; server_addr.sin_port htons(9999); server_addr.sin_addr.s_addr htonl(INADDR_ANY); if (bind(sock_fd, (struct sockaddr *)server_addr, sizeof(server_addr)) 0) { perror(bind); close(sock_fd); return -1; } char buffer[1024]; struct sockaddr_in client_addr; socklen_t len sizeof(client_addr); while (1) { memset(buffer, 0, sizeof(buffer)); ssize_t n recvfrom(sock_fd, buffer, sizeof(buffer) - 1, 0, (struct sockaddr *)client_addr, len); if (n 0) { perror(recvfrom); continue; } buffer[n] \0; printf(Received [%s:%d]: %s\n, inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port), buffer); sendto(sock_fd, buffer, n, 0, (struct sockaddr *)client_addr, len); } close(sock_fd); return 0; }recvfrom()的灵魂在于倒数两个参数它们既是“输出”又是“输出参数”。调用时你需要传入一个sockaddr_in结构体让内核填上发送方的地址和端口于是回包的时候你才知道该往哪儿发。如果这两个参数传NULL你只能收却不知道是谁发来的。这也是UDP和TCP编程体验上最大的差异TCP连接建立后就绑定了对方read/write不用关心对方是谁UDP每次收发都像一个陌生人敲门你需要现场问清对方身份。4.2 UDP客户端不连接也能通信UDP客户端更简单socket()之后连bind都不用直接sendto()发给指定地址然后recvfrom()等待回包。#include stdio.h #include stdlib.h #include string.h #include unistd.h #include sys/socket.h #include netinet/in.h #include arpa/inet.h int main() { int sock_fd socket(AF_INET, SOCK_DGRAM, 0); if (sock_fd 0) { perror(socket); return -1; } struct sockaddr_in server_addr; memset(server_addr, 0, sizeof(server_addr)); server_addr.sin_family AF_INET; server_addr.sin_port htons(9999); inet_pton(AF_INET, 127.0.0.1, server_addr.sin_addr); char *msg udp hello; sendto(sock_fd, msg, strlen(msg), 0, (struct sockaddr *)server_addr, sizeof(server_addr)); char buffer[1024]; struct sockaddr_in from_addr; socklen_t from_len sizeof(from_addr); ssize_t n recvfrom(sock_fd, buffer, sizeof(buffer) - 1, 0, (struct sockaddr *)from_addr, from_len); if (n 0) { buffer[n] \0; printf(Server replied: %s\n, buffer); } close(sock_fd); return 0; }很多人会问UDP客户端能不能用connect()可以但这个connect和TCP那个connect本质不同。UDP的connect只做一件事在本地绑定对方地址之后sendto()就可以简化成send()内核会自动把数据发给你绑定的那个地址。它不会进行任何握手也不会建立真正的连接。这样做的好处是性能更好坏处是失去了灵活性不能再往别的地址发数据。4.3 丢包、乱序与可靠性设计UDP最大的优势是快最大劣势是丢。实用项目里凡是需要UDP却又不能容忍丢包损失的都会在应用层自己做可靠性机制。我分享一套最基础的方案你在做自己的协议时可以参照每个数据包加上递增的序号接收方可以检测乱序和丢包。发送方维护一个超时定时器发送后如果隔了一段时间没收到ACK就重传。接收方收到乱序包先缓存等前面的序号补齐后再交给上层。这套机制其实就是TCP可靠传输的简化版自己实现要从零处理拥塞、重传时间计算等一堆问题。所以我通常建议不确定自己能力时优先选TCP选UDP的前提是你明确知道自己在做什么而且愿意为可靠性机制付出开发成本。比如游戏同步场景开发团队会自己写一套UDP可靠性层而普通的文件传输、消息推送老老实实TCP就完了。5. 实战中一定会踩的坑5.1 TCP粘包怎么破粘包问题的根源是TCP是流式协议。你在应用层调用两次write()内核协议栈可能把这两段数据合并成一个TCP段发出去接收端一次read()就把两段内容全读走了。反过来一个大报文也可能被拆成多个TCP段接收端需要调用多次read()才能读完整。最简单粗暴的解法是给每条消息定一个固定长度短了就高位补零。缺点是浪费带宽灵活性差。第二种解法是每条消息前面加2字节或4字节的长度头接收端先读长度再根据长度读正文。第三种是消息尾部加特殊分隔符比如换行符接收端持续的找分隔符。工程上除了文本协议最常用的是“长度头加正文”的方案兼顾了效率和通用性。关于“为什么socket接收到奇数字节后面会补一个随机数”这个问题事实是TCP本身不会给你补任何随机数。你看到这种诡异现象说明你的协议设计或者在解析数据时出了问题——比如按固定结构解析但结构体和网络字节序没对齐或者接收缓冲区里残留了旧数据你没有正确清空。不要把buff数组memset()当成强制保险读完一次后直接把长度记住靠长度而不是靠数组内容来切分数据才是正路。5.2 recv返回值和断开连接的正确处理recv()返回值的语义必须刻在脑子里返回值含义处理方式 0读到的字节数正常处理并继续0对端关闭连接close()并退出-1异常或中断检查errnoEINTR则重试其他则关闭我见过最多的bug就是把返回0当成“没有数据”继续循环结果CPU被干到100%。记住阻塞模式下recv()只要阻塞着就说明连接还活着一旦返回0连接已经凉了。另一个常见错误是一次recv()就以为收到了完整的应用层消息。TCP是流不是包。你必须在应用层维护一个接收缓冲区不断把recv()结果追加进去再从缓冲区里按协议解析出完整的消息。这就是解粘包的过程。5.3 超时、断开与优雅关闭阻塞模式下recv()会无限期等待下去。这在生产环境里是不可接受的一个客户端死掉了服务端线程就一直挂着。设置超时最常用的是这行代码struct timeval tv; tv.tv_sec 5; tv.tv_usec 0; setsockopt(client_fd, SOL_SOCKET, SO_RCVTIMEO, tv, sizeof(tv));过了5秒还没收到数据recv()返回-1errno是EAGAIN或EWOULDBLOCK。这时候你就可以主动关闭连接释放资源。优雅关闭也有讲究。close()会立即释放本地fd如果缓冲区里还有未发送的数据TCP会尽力发送但close()之后就不再接收新数据。要用shutdown()可以更精细控制shutdown(fd, SHUT_WR)表示我这边不再发了但还可以收shutdown(fd, SHUT_RD)表示我这边不再收了。在做长连接应用时先shutdown再close是稳妥的做法。5.4 端口被占用怎么办“Address already in use”是服务端开发者的老朋友。原因前面提过主动关闭连接的一方会进入TIME_WAIT状态默认持续2个MSL大约1-4分钟这段期间端口还被系统占着。解决办法就是SO_REUSEADDR。注意SO_REUSEADDR解决的是bind()时TIME_WAIT状态导致的失败不是让你绕过重复bind。如果端口真的被别的存活进程占着加上这个选项也没用得用lsof -i:8888或者netstat -tunlp | grep 8888找出占用进程先处理掉。5.5 最大句柄数与C10K问题每建立一个连接就会占用一个文件描述符。Linux默认的进程fd上限通常是1024也就是说你用多进程方案写服务端很快就撞到天花板。运行前可以用ulimit -n查看不够就执行ulimit -n 65535临时提高或者改/etc/security/limits.conf做持久化。但真正要解决的问题是怎么用有限的线程和fd管理上万个连接——这就是下一节select这类多路复用技术存在的意义。6. 多路复用用select管住所有连接6.1 select到底解决了什么问题回到上面的多进程方案每来一个连接就fork一个进程或线程连接多了系统资源很快就耗尽。多路复用的思路完全不同让一个线程同时监视几百上千个fd内核帮你看哪个fd上来了数据、哪个fd上有了新连接你再去处理“活跃”的那几个。相当于从“一对一服务”变成“一个前台同时盯着所有工位”谁叫号谁上前。select()就是最基础的多路复用接口。它的调用方式是把一堆fd放进fd_set集合然后交给内核去监视有事件发生时内核修改集合告诉你有哪些fd就绪。6.2 一套select骨架代码我写一个最简单但能跑的select骨架它同时监听监听fd和客户端fd有新连接就accept有数据就readfd_set read_fds; FD_ZERO(read_fds); FD_SET(listen_fd, read_fds); int max_fd listen_fd; while (1) { fd_set tmp_fds read_fds; // select会修改集合每次要重新复制 struct timeval timeout; timeout.tv_sec 3; timeout.tv_usec 0; int ret select(max_fd 1, tmp_fds, NULL, NULL, timeout); if (ret 0) { printf(select timeout\n); continue; } if (ret 0) { perror(select); break; } if (FD_ISSET(listen_fd, tmp_fds)) { struct sockaddr_in client_addr; socklen_t len sizeof(client_addr); int client_fd accept(listen_fd, (struct sockaddr *)client_addr, len); printf(Client connected: %s:%d\n, inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port)); FD_SET(client_fd, read_fds); if (client_fd max_fd) { max_fd client_fd; } } char buffer[1024]; for (int fd listen_fd 1; fd max_fd; fd) { if (FD_ISSET(fd, tmp_fds)) { ssize_t n read(fd, buffer, sizeof(buffer)); if (n 0) { write(fd, buffer, n); } else { close(fd); FD_CLR(fd, read_fds); } } } }6.3 几个容易出问题的细节select的坑集中在三处。第一select的max_fd参数要传“最大fd值加1”不是只传最大fd传错会导致它只检查部分fd行为很隐蔽。第二select会修改传入的fd_set集合把没就绪的fd清掉如果你保存了一份原始集合下次调用前必须重新复制所以我在循环里用了fd_set tmp_fds read_fds;。第三timeout参数在select返回后也可能被修改每次调用都必须重新赋值。select能管理的fd数量有上限由FD_SETSIZE决定默认通常1024。要支持更大规模的连接Linux上更好的选择是epollWindows上对应IOCP。select并不是性能最优方案但它逻辑清晰、跨平台性好是理解所有多路复用机制的基础。你把select彻底弄明白了后面学epoll就是水到渠成的事。我个人在实际开发中的一个经验是网络库的封装千千万但内核暴露的这套Socket接口几十年没变过。你把它彻底吃透了不管将来用C、Java还是Go底层网络模型的理解都会让你排查问题比别人快一截。最后再分享一个小技巧写网络程序时永远先跑通单连接再上多路复用先用nc做互测再写客户端这样能把“程序bug”和“网络bug”清晰区分开排查效率高得多。
