：從裸 socket 到跨平臺可復用網(wǎng)絡通信類)
簡介這是一份面向C網(wǎng)絡編程初學者與進階開發(fā)者的輕量級socket通信封裝資源針對原生socket接口調(diào)用繁瑣、錯誤處理分散的問題提供了一套可直接復用的類實現(xiàn)幫助讀者快速在項目中搭建TCP/UDP通信能力。壓縮包共2個文件包含1個h頭文件與1個cpp源文件分別承擔類接口聲明與具體實現(xiàn)整體僅2KB結構精簡、依賴極少便于嵌入現(xiàn)有工程或作為教學示例逐行研讀。資源圍繞socket套接字編程展開涵蓋地址綁定、連接建立、數(shù)據(jù)收發(fā)等核心環(huán)節(jié)適合用于課程設計、小型服務端客戶端實驗以及網(wǎng)絡通信原理的動手驗證。目前已有340人學習下載說明其在同類入門素材中具備一定參考價值。讀者可借此理解C中面向對象方式封裝系統(tǒng)調(diào)用的思路掌握將底層API抽象為易用類的實踐方法并在此基礎上擴展多線程、異常處理或跨平臺適配為后續(xù)深入網(wǎng)絡編程打下基礎。1. 從一段裸 socket 代碼說起C 網(wǎng)絡通信到底難在哪很多人第一次寫 C socket都是從一段幾十行的 TCP echo 服務端開始的socket()建套接字、bind()綁端口、listen()監(jiān)聽、accept()拿連接、recv()/send()收發(fā)。跑通那一刻很爽但把它塞進真實項目問題立刻冒出來——連接一多就卡死、客戶端斷開后服務端 CPU 飆滿、發(fā)一半的數(shù)據(jù)對端只收到半截、Windows 上編譯報windows socket error: 通常每個套接字地址(協(xié)議/網(wǎng)絡地址/端口)只允許使用一次。這些不是玄學是裸 socket 編程繞不開的邊界。這篇筆記要講的就是把「c socket 類」這件事做扎實用 C 封裝一個能復用的 socket 類屏蔽掉sockaddr_in、字節(jié)序、WSAStartup、close/closesocket這些平臺差異讓上層只關心「連、發(fā)、收、斷」。適合兩類人剛學完 C 基礎、想動手寫網(wǎng)絡通信的新手以及寫過 socket 但代碼散落各處、想整理成類的中級開發(fā)者。下面從設計、實現(xiàn)、參數(shù)、踩坑一路講到進階代碼可直接抄。2. 封裝前先想清楚C socket 類該切哪幾刀2.1 為什么裸 socket 不適合直接進業(yè)務代碼裸 socket 的問題不在功能而在「散」。一個int fd到處傳誰負責關、關了之后別人還用不用、錯誤碼怎么統(tǒng)一、Windows 和 Linux 頭文件不一樣這些全壓在業(yè)務邏輯里。常見做法是抽三層最底層是平臺適配socket/closesocket、WSAStartup/WSACleanup中間層是Socket類管生命周期和收發(fā)上層才是協(xié)議解析和業(yè)務。這樣切的好處是換平臺只動底層業(yè)務代碼一行不改。另一個必須提前定的是「阻塞還是非阻塞」。新手項目用阻塞 socket 最省心recv沒數(shù)據(jù)就停在那但一旦要同時處理多個連接阻塞模型就得配多線程線程一多上下文切換開銷上來。非阻塞配select/epoll/IOCP才是高并發(fā)正路但復雜度陡增。我的建議是先把阻塞版封裝穩(wěn)接口留好非阻塞的擴展位別一上來就上 epoll容易翻車。2.2 類的接口設計連接、收發(fā)、關閉四件事一個夠用的Socket類公開接口控制在四類connect客戶端連服務端、bindlistenaccept服務端、send/recv收發(fā)、close關閉。構造函數(shù)只做初始化不建連接析構函數(shù)負責兜底關閉防止忘記close導致句柄泄漏。這里有個關鍵決策拷貝構造和賦值要不要禁掉必須禁。socket 句柄是獨占資源拷貝一份就會出現(xiàn)兩個對象關同一個 fd第二個close直接踩空。用 delete顯式禁用拷貝需要轉移就實現(xiàn)移動構造。class Socket { public: Socket(); // 只初始化不建連接 ~Socket(); // 析構兜底關閉 Socket(const Socket) delete; // 禁止拷貝句柄獨占 Socket operator(const Socket) delete; Socket(Socket other) noexcept; // 允許移動轉移所有權 bool connectTo(const std::string ip, uint16_t port); bool bindAndListen(const std::string ip, uint16_t port, int backlog 128); Socket acceptClient(); int sendAll(const void* data, size_t len); int recvSome(void* buf, size_t len); void close(); private: int fd_ -1; // Linux 是 fdWindows 是 SOCKET };邏輯說明fd_初始化為 -1代表「未持有有效句柄」析構和close都先判斷再操作避免重復關閉。移動構造把other.fd_拿過來后置 -1保證同一時刻只有一個對象持有句柄。參數(shù)上backlog給 128 是常見經(jīng)驗值表示內(nèi)核已完成三次握手但還沒被accept取走的連接隊列長度太小會在高并發(fā)下丟連接。2.3 跨平臺適配Windows 和 Linux 的差異清單跨平臺是 C socket 最容易埋雷的地方。差異集中在四處頭文件Windows 用winsock2.hLinux 用sys/socket.h等、初始化Windows 必須WSAStartupLinux 不用、關閉函數(shù)closesocketvsclose、錯誤碼WSAGetLastErrorvserrno。用宏把這些包起來業(yè)務層就干凈了。項目WindowsLinux頭文件winsock2.h、ws2tcpip.hsys/socket.h、netinet/in.h、arpa/inet.h初始化WSAStartup(MAKEWORD(2,2),...)無需關閉closesocket(fd)close(fd)錯誤碼WSAGetLastError()errno鏈接庫ws2_32.lib無#ifdef _WIN32 #include winsock2.h #include ws2tcpip.h #pragma comment(lib, ws2_32.lib) using socklen_t int; #define CLOSE_SOCKET(fd) closesocket(fd) #else #include sys/socket.h #include netinet/in.h #include arpa/inet.h #include unistd.h #include cerrno #define CLOSE_SOCKET(fd) ::close(fd) #endif邏輯說明#pragma comment(lib, ws2_32.lib)是 MSVC 特有的自動鏈接用 GCC/MinGW 就得在編譯命令里加-lws2_32。socklen_t在 Windows 上默認沒定義用using補一個否則accept的第三個參數(shù)編譯不過。這套宏是后面所有實現(xiàn)的基礎先落地再往下寫。3. 把 Socket 類寫出來連接、收發(fā)、關閉的完整實現(xiàn)3.1 初始化與析構WSAStartup 和資源釋放Windows 上不調(diào)WSAStartup后面所有 socket 調(diào)用都會失敗返回WSANOTINITIALISED。這個初始化進程級只需一次放在類里做要注意別重復調(diào)用。簡單做法是用一個靜態(tài)標志或std::once_flag保證只跑一次。析構里對應WSACleanup但同樣只能調(diào)一次所以更穩(wěn)的方式是交給一個全局的 RAII 對象管而不是每個 Socket 對象都調(diào)。Socket::Socket() { #ifdef _WIN32 static std::once_flag wsaFlag; std::call_once(wsaFlag, []{ WSADATA wsa; if (WSAStartup(MAKEWORD(2,2), wsa) ! 0) { throw std::runtime_error(WSAStartup failed); } }); #endif } Socket::~Socket() { close(); } void Socket::close() { if (fd_ ! -1) { CLOSE_SOCKET(fd_); fd_ -1; // 置無效防止二次關閉 } }邏輯說明std::call_once保證WSAStartup在多線程下也只執(zhí)行一次比手寫if判斷更安全。close()里先判斷fd_ ! -1再關關完立刻置 -1這樣析構、顯式 close、移動后的源對象都不會重復關同一個句柄。參數(shù)上MAKEWORD(2,2)請求 Winsock 2.2 版本這是目前通用版本別用 1.1。3.2 connect 與 bind/listen/accept 的實現(xiàn)細節(jié)客戶端connectTo要做三件事建 socket、填sockaddr_in、調(diào)connect。服務端bindAndListen多一步bind和listen。這里最容易錯的是地址填充sin_family必須是AF_INETsin_port必須用htons轉網(wǎng)絡字節(jié)序sin_addr用inet_pton而不是老掉牙的inet_addr后者不支持錯誤區(qū)分。bool Socket::connectTo(const std::string ip, uint16_t port) { fd_ ::socket(AF_INET, SOCK_STREAM, 0); if (fd_ -1) return false; sockaddr_in addr{}; addr.sin_family AF_INET; addr.sin_port htons(port); // 主機序轉網(wǎng)絡序 if (inet_pton(AF_INET, ip.c_str(), addr.sin_addr) 0) { close(); return false; } if (::connect(fd_, (sockaddr*)addr, sizeof(addr)) -1) { close(); return false; } return true; } bool Socket::bindAndListen(const std::string ip, uint16_t port, int backlog) { fd_ ::socket(AF_INET, SOCK_STREAM, 0); if (fd_ -1) return false; int opt 1; setsockopt(fd_, SOL_SOCKET, SO_REUSEADDR, (char*)opt, sizeof(opt)); sockaddr_in addr{}; addr.sin_family AF_INET; addr.sin_port htons(port); addr.sin_addr.s_addr (ip 0.0.0.0) ? INADDR_ANY : inet_addr(ip.c_str()); if (::bind(fd_, (sockaddr*)addr, sizeof(addr)) -1) { close(); return false; } if (::listen(fd_, backlog) -1) { close(); return false; } return true; }邏輯說明SO_REUSEADDR是必須設的否則服務端重啟時端口處于TIME_WAIT狀態(tài)bind會直接失敗報的就是熱詞里那個「通常每個套接字地址只允許使用一次」。htons把端口從主機字節(jié)序轉成網(wǎng)絡字節(jié)序忘了這步端口號會變成另一個值。INADDR_ANY表示監(jiān)聽本機所有網(wǎng)卡寫0.0.0.0是常見約定。inet_addr這里用于服務端綁定簡單夠用客戶端解析域名場景建議換getaddrinfo。3.3 send/recv 的返回值處理半包和粘包從哪來send和recv的返回值是新手最大的坑。send返回實際發(fā)出的字節(jié)數(shù)可能小于你請求的長度內(nèi)核發(fā)送緩沖區(qū)滿了recv返回實際讀到的字節(jié)數(shù)可能小于你期望的TCP 是字節(jié)流沒有消息邊界。這就是「半包」和「粘包」的根源——不是 bug是 TCP 的設計。所以sendAll必須循環(huán)發(fā)到發(fā)完recvSome只保證讀到「一些」數(shù)據(jù)邊界要靠應用層協(xié)議自己劃。int Socket::sendAll(const void* data, size_t len) { const char* p static_castconst char*(data); size_t sent 0; while (sent len) { int n ::send(fd_, p sent, len - sent, 0); if (n 0) return -1; // 出錯或對端關閉 sent n; } return (int)sent; } int Socket::recvSome(void* buf, size_t len) { int n ::recv(fd_, buf, len, 0); if (n 0) return 0; // 對端正常關閉 if (n 0) return -1; // 出錯 return n; // 可能小于 len正常 }邏輯說明sendAll用while循環(huán)每次從p sent繼續(xù)發(fā)剩余部分直到sent len這樣才保證「全部發(fā)出」。recvSome故意不循環(huán)因為阻塞模式下循環(huán)讀會一直等到緩沖區(qū)滿或對端關閉反而卡住正確做法是讀一次拿到多少算多少交給上層按協(xié)議長度字段判斷。參數(shù)上len建議不超過 64KB太大單次系統(tǒng)調(diào)用效率反而下降。3.4 一個能跑的最小客戶端和服務端把上面的類拼起來寫一個 echo 服務端和客戶端驗證。服務端accept后循環(huán)recvSome收到就sendAll回去客戶端連上后發(fā)一句讀回顯。// 服務端 int main() { Socket srv; if (!srv.bindAndListen(0.0.0.0, 9000)) return 1; while (true) { Socket cli srv.acceptClient(); char buf[1024]; int n cli.recvSome(buf, sizeof(buf)); if (n 0) cli.sendAll(buf, n); } } // 客戶端 int main() { Socket cli; if (!cli.connectTo(127.0.0.1, 9000)) return 1; const char* msg hello socket; cli.sendAll(msg, strlen(msg)); char buf[1024]; int n cli.recvSome(buf, sizeof(buf)); if (n 0) printf(echo: %.*s\n, n, buf); }邏輯說明acceptClient內(nèi)部調(diào)accept返回一個新的Socket對象代表這條連接和監(jiān)聽 socket 分開。服務端這個版本一次只處理一個連接是教學最小版要并發(fā)就得把cli丟給線程或改成非阻塞。編譯命令 Linux 下g main.cpp -o srvWindows MSVC 下cl main.cpp ws2_32.libMinGW 下g main.cpp -lws2_32。4. 避坑與排查socket 類最容易翻車的五個地方4.1 端口被占用bind 直接失敗現(xiàn)象服務端啟動報bind failedWindows 上錯誤信息是「通常每個套接字地址(協(xié)議/網(wǎng)絡地址/端口)只允許使用一次」。原因上一次進程退出后端口處于TIME_WAIT或者另一個進程還占著這個端口。解決setsockopt設SO_REUSEADDR見 3.2這是標準解法如果還不行用netstat -ano | findstr 9000Windows或lsof -i:9000Linux查是誰占著換端口或殺掉進程。4.2 客戶端斷開后服務端 CPU 跑滿現(xiàn)象客戶端一關服務端recv返回 0但代碼沒處理繼續(xù)循環(huán)調(diào)用CPU 直接 100%。原因recv返回 0 表示對端正常關閉返回 -1 表示出錯這兩種情況都必須跳出循環(huán)并關閉連接。解決recvSome返回 0時立即close并結束該連接的循環(huán)別把 0 當成「暫時沒數(shù)據(jù)」。4.3 只發(fā)出去一半對端收到截斷數(shù)據(jù)現(xiàn)象發(fā) 1000 字節(jié)對端只收到 600 字節(jié)。原因用了裸send沒檢查返回值或者用了sendAll但中途send返回 -1 沒處理。解決統(tǒng)一走sendAll循環(huán)發(fā)送如果send返回 -1先看錯誤碼是不是EINTR被信號打斷是就重試其他錯誤才斷開。別假設一次send能發(fā)完。4.4 忘記 WSAStartup 或鏈接 ws2_32現(xiàn)象Windows 上所有 socket 調(diào)用返回失敗錯誤碼WSANOTINITIALISED或者編譯報一堆undefined reference to socket。原因沒調(diào)WSAStartup或者沒鏈接ws2_32.lib。解決初始化放構造函數(shù)用call_once保證執(zhí)行鏈接在 MSVC 用#pragma commentMinGW/GCC 在編譯命令加-lws2_32CMake 里寫target_link_libraries(xxx ws2_32)。4.5 拷貝 Socket 對象導致雙重關閉現(xiàn)象程序隨機崩潰或者報「無效的句柄」。原因Socket 對象被拷貝兩個對象持有同一個 fd析構時都去close第二次關的是已經(jīng)被關的句柄行為未定義。解決拷貝構造和賦值 delete見 2.2需要傳遞就用移動語義或傳引用/指針。這條是血淚經(jīng)驗早期我圖省事沒禁拷貝線上偶發(fā)崩潰查了兩天才定位到。5. 進階把阻塞 socket 改成能扛并發(fā)的版本阻塞版跑通后下一步就是并發(fā)。最省事的做法是「一連接一線程」accept拿到cli后std::thread丟出去處理主線程繼續(xù)accept。這個模型代碼改動小幾十上百連接夠用但連接上千時線程開銷就壓不住了。再往上就是select/poll/epollLinux或IOCPWindows把「等哪個 fd 可讀」交給內(nèi)核單線程管上萬連接。我一般會先給Socket類加一個setNonBlocking()內(nèi)部用fcntl(fd_, F_SETFL, O_NONBLOCK)Linux或ioctlsocket(fd_, FIONBIO, mode)Windows切換。然后配epoll寫一個事件循環(huán)注冊監(jiān)聽 fd 的EPOLLIN有事件就accept把新連接也注冊進去已連接 fd 可讀就recvSome返回 0 或 -1 就注銷并關閉。這套結構比多線程復雜但擴展性好得多。驗證并發(fā)是否真的生效別只看「能連上」。用ab或自己寫腳本開 500 個連接持續(xù)發(fā)小包觀察 CPU 和內(nèi)存曲線一連接一線程的版本線程數(shù)會飆到幾百epoll版本線程數(shù)穩(wěn)定在個位數(shù)。另外記得給recv加超時SO_RCVTIMEO否則慢連接會一直占著不放。我踩過的坑是非阻塞模式下recv返回 -1 且errno是EAGAIN/EWOULDBLOCK這不是錯誤是「暫時沒數(shù)據(jù)」必須和真正的錯誤區(qū)分開否則會把正常連接誤殺。這個判斷寫錯高并發(fā)下連接會莫名其妙斷排查起來很折磨。從裸 socket 到封裝成類再到并發(fā)模型每一步都有它的邊界。我的習慣是先把阻塞版寫穩(wěn)、把錯誤處理寫全再談性能。希望幫到你。本文還有配套的精品資源點擊獲取 C++ Socket 類封裝實戰(zhàn)：從裸 socket 到跨平臺可復用網(wǎng)絡通信類
簡介這是一份面向C網(wǎng)絡編程初學者與進階開發(fā)者的輕量級socket通信封裝資源針對原生socket接口調(diào)用繁瑣、錯誤處理分散的問題提供了一套可直接復用的類實現(xiàn)幫助讀者快速在項目中搭建TCP/UDP通信能力。壓縮包共2個文件包含1個h頭文件與1個cpp源文件分別承擔類接口聲明與具體實現(xiàn)整體僅2KB結構精簡、依賴極少便于嵌入現(xiàn)有工程或作為教學示例逐行研讀。資源圍繞socket套接字編程展開涵蓋地址綁定、連接建立、數(shù)據(jù)收發(fā)等核心環(huán)節(jié)適合用于課程設計、小型服務端客戶端實驗以及網(wǎng)絡通信原理的動手驗證。目前已有340人學習下載說明其在同類入門素材中具備一定參考價值。讀者可借此理解C中面向對象方式封裝系統(tǒng)調(diào)用的思路掌握將底層API抽象為易用類的實踐方法并在此基礎上擴展多線程、異常處理或跨平臺適配為后續(xù)深入網(wǎng)絡編程打下基礎。1. 從一段裸 socket 代碼說起C 網(wǎng)絡通信到底難在哪很多人第一次寫 C socket都是從一段幾十行的 TCP echo 服務端開始的socket()建套接字、bind()綁端口、listen()監(jiān)聽、accept()拿連接、recv()/send()收發(fā)。跑通那一刻很爽但把它塞進真實項目問題立刻冒出來——連接一多就卡死、客戶端斷開后服務端 CPU 飆滿、發(fā)一半的數(shù)據(jù)對端只收到半截、Windows 上編譯報windows socket error: 通常每個套接字地址(協(xié)議/網(wǎng)絡地址/端口)只允許使用一次。這些不是玄學是裸 socket 編程繞不開的邊界。這篇筆記要講的就是把「c socket 類」這件事做扎實用 C 封裝一個能復用的 socket 類屏蔽掉sockaddr_in、字節(jié)序、WSAStartup、close/closesocket這些平臺差異讓上層只關心「連、發(fā)、收、斷」。適合兩類人剛學完 C 基礎、想動手寫網(wǎng)絡通信的新手以及寫過 socket 但代碼散落各處、想整理成類的中級開發(fā)者。下面從設計、實現(xiàn)、參數(shù)、踩坑一路講到進階代碼可直接抄。2. 封裝前先想清楚C socket 類該切哪幾刀2.1 為什么裸 socket 不適合直接進業(yè)務代碼裸 socket 的問題不在功能而在「散」。一個int fd到處傳誰負責關、關了之后別人還用不用、錯誤碼怎么統(tǒng)一、Windows 和 Linux 頭文件不一樣這些全壓在業(yè)務邏輯里。常見做法是抽三層最底層是平臺適配socket/closesocket、WSAStartup/WSACleanup中間層是Socket類管生命周期和收發(fā)上層才是協(xié)議解析和業(yè)務。這樣切的好處是換平臺只動底層業(yè)務代碼一行不改。另一個必須提前定的是「阻塞還是非阻塞」。新手項目用阻塞 socket 最省心recv沒數(shù)據(jù)就停在那但一旦要同時處理多個連接阻塞模型就得配多線程線程一多上下文切換開銷上來。非阻塞配select/epoll/IOCP才是高并發(fā)正路但復雜度陡增。我的建議是先把阻塞版封裝穩(wěn)接口留好非阻塞的擴展位別一上來就上 epoll容易翻車。2.2 類的接口設計連接、收發(fā)、關閉四件事一個夠用的Socket類公開接口控制在四類connect客戶端連服務端、bindlistenaccept服務端、send/recv收發(fā)、close關閉。構造函數(shù)只做初始化不建連接析構函數(shù)負責兜底關閉防止忘記close導致句柄泄漏。這里有個關鍵決策拷貝構造和賦值要不要禁掉必須禁。socket 句柄是獨占資源拷貝一份就會出現(xiàn)兩個對象關同一個 fd第二個close直接踩空。用 delete顯式禁用拷貝需要轉移就實現(xiàn)移動構造。class Socket { public: Socket(); // 只初始化不建連接 ~Socket(); // 析構兜底關閉 Socket(const Socket) delete; // 禁止拷貝句柄獨占 Socket operator(const Socket) delete; Socket(Socket other) noexcept; // 允許移動轉移所有權 bool connectTo(const std::string ip, uint16_t port); bool bindAndListen(const std::string ip, uint16_t port, int backlog 128); Socket acceptClient(); int sendAll(const void* data, size_t len); int recvSome(void* buf, size_t len); void close(); private: int fd_ -1; // Linux 是 fdWindows 是 SOCKET };邏輯說明fd_初始化為 -1代表「未持有有效句柄」析構和close都先判斷再操作避免重復關閉。移動構造把other.fd_拿過來后置 -1保證同一時刻只有一個對象持有句柄。參數(shù)上backlog給 128 是常見經(jīng)驗值表示內(nèi)核已完成三次握手但還沒被accept取走的連接隊列長度太小會在高并發(fā)下丟連接。2.3 跨平臺適配Windows 和 Linux 的差異清單跨平臺是 C socket 最容易埋雷的地方。差異集中在四處頭文件Windows 用winsock2.hLinux 用sys/socket.h等、初始化Windows 必須WSAStartupLinux 不用、關閉函數(shù)closesocketvsclose、錯誤碼WSAGetLastErrorvserrno。用宏把這些包起來業(yè)務層就干凈了。項目WindowsLinux頭文件winsock2.h、ws2tcpip.hsys/socket.h、netinet/in.h、arpa/inet.h初始化WSAStartup(MAKEWORD(2,2),...)無需關閉closesocket(fd)close(fd)錯誤碼WSAGetLastError()errno鏈接庫ws2_32.lib無#ifdef _WIN32 #include winsock2.h #include ws2tcpip.h #pragma comment(lib, ws2_32.lib) using socklen_t int; #define CLOSE_SOCKET(fd) closesocket(fd) #else #include sys/socket.h #include netinet/in.h #include arpa/inet.h #include unistd.h #include cerrno #define CLOSE_SOCKET(fd) ::close(fd) #endif邏輯說明#pragma comment(lib, ws2_32.lib)是 MSVC 特有的自動鏈接用 GCC/MinGW 就得在編譯命令里加-lws2_32。socklen_t在 Windows 上默認沒定義用using補一個否則accept的第三個參數(shù)編譯不過。這套宏是后面所有實現(xiàn)的基礎先落地再往下寫。3. 把 Socket 類寫出來連接、收發(fā)、關閉的完整實現(xiàn)3.1 初始化與析構WSAStartup 和資源釋放Windows 上不調(diào)WSAStartup后面所有 socket 調(diào)用都會失敗返回WSANOTINITIALISED。這個初始化進程級只需一次放在類里做要注意別重復調(diào)用。簡單做法是用一個靜態(tài)標志或std::once_flag保證只跑一次。析構里對應WSACleanup但同樣只能調(diào)一次所以更穩(wěn)的方式是交給一個全局的 RAII 對象管而不是每個 Socket 對象都調(diào)。Socket::Socket() { #ifdef _WIN32 static std::once_flag wsaFlag; std::call_once(wsaFlag, []{ WSADATA wsa; if (WSAStartup(MAKEWORD(2,2), wsa) ! 0) { throw std::runtime_error(WSAStartup failed); } }); #endif } Socket::~Socket() { close(); } void Socket::close() { if (fd_ ! -1) { CLOSE_SOCKET(fd_); fd_ -1; // 置無效防止二次關閉 } }邏輯說明std::call_once保證WSAStartup在多線程下也只執(zhí)行一次比手寫if判斷更安全。close()里先判斷fd_ ! -1再關關完立刻置 -1這樣析構、顯式 close、移動后的源對象都不會重復關同一個句柄。參數(shù)上MAKEWORD(2,2)請求 Winsock 2.2 版本這是目前通用版本別用 1.1。3.2 connect 與 bind/listen/accept 的實現(xiàn)細節(jié)客戶端connectTo要做三件事建 socket、填sockaddr_in、調(diào)connect。服務端bindAndListen多一步bind和listen。這里最容易錯的是地址填充sin_family必須是AF_INETsin_port必須用htons轉網(wǎng)絡字節(jié)序sin_addr用inet_pton而不是老掉牙的inet_addr后者不支持錯誤區(qū)分。bool Socket::connectTo(const std::string ip, uint16_t port) { fd_ ::socket(AF_INET, SOCK_STREAM, 0); if (fd_ -1) return false; sockaddr_in addr{}; addr.sin_family AF_INET; addr.sin_port htons(port); // 主機序轉網(wǎng)絡序 if (inet_pton(AF_INET, ip.c_str(), addr.sin_addr) 0) { close(); return false; } if (::connect(fd_, (sockaddr*)addr, sizeof(addr)) -1) { close(); return false; } return true; } bool Socket::bindAndListen(const std::string ip, uint16_t port, int backlog) { fd_ ::socket(AF_INET, SOCK_STREAM, 0); if (fd_ -1) return false; int opt 1; setsockopt(fd_, SOL_SOCKET, SO_REUSEADDR, (char*)opt, sizeof(opt)); sockaddr_in addr{}; addr.sin_family AF_INET; addr.sin_port htons(port); addr.sin_addr.s_addr (ip 0.0.0.0) ? INADDR_ANY : inet_addr(ip.c_str()); if (::bind(fd_, (sockaddr*)addr, sizeof(addr)) -1) { close(); return false; } if (::listen(fd_, backlog) -1) { close(); return false; } return true; }邏輯說明SO_REUSEADDR是必須設的否則服務端重啟時端口處于TIME_WAIT狀態(tài)bind會直接失敗報的就是熱詞里那個「通常每個套接字地址只允許使用一次」。htons把端口從主機字節(jié)序轉成網(wǎng)絡字節(jié)序忘了這步端口號會變成另一個值。INADDR_ANY表示監(jiān)聽本機所有網(wǎng)卡寫0.0.0.0是常見約定。inet_addr這里用于服務端綁定簡單夠用客戶端解析域名場景建議換getaddrinfo。3.3 send/recv 的返回值處理半包和粘包從哪來send和recv的返回值是新手最大的坑。send返回實際發(fā)出的字節(jié)數(shù)可能小于你請求的長度內(nèi)核發(fā)送緩沖區(qū)滿了recv返回實際讀到的字節(jié)數(shù)可能小于你期望的TCP 是字節(jié)流沒有消息邊界。這就是「半包」和「粘包」的根源——不是 bug是 TCP 的設計。所以sendAll必須循環(huán)發(fā)到發(fā)完recvSome只保證讀到「一些」數(shù)據(jù)邊界要靠應用層協(xié)議自己劃。int Socket::sendAll(const void* data, size_t len) { const char* p static_castconst char*(data); size_t sent 0; while (sent len) { int n ::send(fd_, p sent, len - sent, 0); if (n 0) return -1; // 出錯或對端關閉 sent n; } return (int)sent; } int Socket::recvSome(void* buf, size_t len) { int n ::recv(fd_, buf, len, 0); if (n 0) return 0; // 對端正常關閉 if (n 0) return -1; // 出錯 return n; // 可能小于 len正常 }邏輯說明sendAll用while循環(huán)每次從p sent繼續(xù)發(fā)剩余部分直到sent len這樣才保證「全部發(fā)出」。recvSome故意不循環(huán)因為阻塞模式下循環(huán)讀會一直等到緩沖區(qū)滿或對端關閉反而卡住正確做法是讀一次拿到多少算多少交給上層按協(xié)議長度字段判斷。參數(shù)上len建議不超過 64KB太大單次系統(tǒng)調(diào)用效率反而下降。3.4 一個能跑的最小客戶端和服務端把上面的類拼起來寫一個 echo 服務端和客戶端驗證。服務端accept后循環(huán)recvSome收到就sendAll回去客戶端連上后發(fā)一句讀回顯。// 服務端 int main() { Socket srv; if (!srv.bindAndListen(0.0.0.0, 9000)) return 1; while (true) { Socket cli srv.acceptClient(); char buf[1024]; int n cli.recvSome(buf, sizeof(buf)); if (n 0) cli.sendAll(buf, n); } } // 客戶端 int main() { Socket cli; if (!cli.connectTo(127.0.0.1, 9000)) return 1; const char* msg hello socket; cli.sendAll(msg, strlen(msg)); char buf[1024]; int n cli.recvSome(buf, sizeof(buf)); if (n 0) printf(echo: %.*s\n, n, buf); }邏輯說明acceptClient內(nèi)部調(diào)accept返回一個新的Socket對象代表這條連接和監(jiān)聽 socket 分開。服務端這個版本一次只處理一個連接是教學最小版要并發(fā)就得把cli丟給線程或改成非阻塞。編譯命令 Linux 下g main.cpp -o srvWindows MSVC 下cl main.cpp ws2_32.libMinGW 下g main.cpp -lws2_32。4. 避坑與排查socket 類最容易翻車的五個地方4.1 端口被占用bind 直接失敗現(xiàn)象服務端啟動報bind failedWindows 上錯誤信息是「通常每個套接字地址(協(xié)議/網(wǎng)絡地址/端口)只允許使用一次」。原因上一次進程退出后端口處于TIME_WAIT或者另一個進程還占著這個端口。解決setsockopt設SO_REUSEADDR見 3.2這是標準解法如果還不行用netstat -ano | findstr 9000Windows或lsof -i:9000Linux查是誰占著換端口或殺掉進程。4.2 客戶端斷開后服務端 CPU 跑滿現(xiàn)象客戶端一關服務端recv返回 0但代碼沒處理繼續(xù)循環(huán)調(diào)用CPU 直接 100%。原因recv返回 0 表示對端正常關閉返回 -1 表示出錯這兩種情況都必須跳出循環(huán)并關閉連接。解決recvSome返回 0時立即close并結束該連接的循環(huán)別把 0 當成「暫時沒數(shù)據(jù)」。4.3 只發(fā)出去一半對端收到截斷數(shù)據(jù)現(xiàn)象發(fā) 1000 字節(jié)對端只收到 600 字節(jié)。原因用了裸send沒檢查返回值或者用了sendAll但中途send返回 -1 沒處理。解決統(tǒng)一走sendAll循環(huán)發(fā)送如果send返回 -1先看錯誤碼是不是EINTR被信號打斷是就重試其他錯誤才斷開。別假設一次send能發(fā)完。4.4 忘記 WSAStartup 或鏈接 ws2_32現(xiàn)象Windows 上所有 socket 調(diào)用返回失敗錯誤碼WSANOTINITIALISED或者編譯報一堆undefined reference to socket。原因沒調(diào)WSAStartup或者沒鏈接ws2_32.lib。解決初始化放構造函數(shù)用call_once保證執(zhí)行鏈接在 MSVC 用#pragma commentMinGW/GCC 在編譯命令加-lws2_32CMake 里寫target_link_libraries(xxx ws2_32)。4.5 拷貝 Socket 對象導致雙重關閉現(xiàn)象程序隨機崩潰或者報「無效的句柄」。原因Socket 對象被拷貝兩個對象持有同一個 fd析構時都去close第二次關的是已經(jīng)被關的句柄行為未定義。解決拷貝構造和賦值 delete見 2.2需要傳遞就用移動語義或傳引用/指針。這條是血淚經(jīng)驗早期我圖省事沒禁拷貝線上偶發(fā)崩潰查了兩天才定位到。5. 進階把阻塞 socket 改成能扛并發(fā)的版本阻塞版跑通后下一步就是并發(fā)。最省事的做法是「一連接一線程」accept拿到cli后std::thread丟出去處理主線程繼續(xù)accept。這個模型代碼改動小幾十上百連接夠用但連接上千時線程開銷就壓不住了。再往上就是select/poll/epollLinux或IOCPWindows把「等哪個 fd 可讀」交給內(nèi)核單線程管上萬連接。我一般會先給Socket類加一個setNonBlocking()內(nèi)部用fcntl(fd_, F_SETFL, O_NONBLOCK)Linux或ioctlsocket(fd_, FIONBIO, mode)Windows切換。然后配epoll寫一個事件循環(huán)注冊監(jiān)聽 fd 的EPOLLIN有事件就accept把新連接也注冊進去已連接 fd 可讀就recvSome返回 0 或 -1 就注銷并關閉。這套結構比多線程復雜但擴展性好得多。驗證并發(fā)是否真的生效別只看「能連上」。用ab或自己寫腳本開 500 個連接持續(xù)發(fā)小包觀察 CPU 和內(nèi)存曲線一連接一線程的版本線程數(shù)會飆到幾百epoll版本線程數(shù)穩(wěn)定在個位數(shù)。另外記得給recv加超時SO_RCVTIMEO否則慢連接會一直占著不放。我踩過的坑是非阻塞模式下recv返回 -1 且errno是EAGAIN/EWOULDBLOCK這不是錯誤是「暫時沒數(shù)據(jù)」必須和真正的錯誤區(qū)分開否則會把正常連接誤殺。這個判斷寫錯高并發(fā)下連接會莫名其妙斷排查起來很折磨。從裸 socket 到封裝成類再到并發(fā)模型每一步都有它的邊界。我的習慣是先把阻塞版寫穩(wěn)、把錯誤處理寫全再談性能。希望幫到你。本文還有配套的精品資源點擊獲取