本文深入探討基於 Windows Sockets API 的面向連接流式套接字編程模型，重點闡述客戶端/服務器架構下的異步網絡通訊實現方案。通過詳細的流程分析、關鍵 API 解析與 MFC 實戰代碼，展示如何構建高效、響應及時的網絡通訊程序。
Socket 接口源自 1980 年代初加州大學伯克利分校為 TCP/IP 開發的 API，成為互聯網應用開發的通用標準。微軟聯合多家廠商制定的 Windows Sockets 規範，在繼承 BSD Sockets 基礎上引入異步函數與網絡事件異步選擇機制，完美契合 Windows 消息驅動特性，極大提升了網絡開發效率與程序性能。
採用非對稱編程模式：服務器提供固定服務並響應請求，客戶端發起請求獲取服務。基於 TCP/IP 的流式套接字（SOCK_STREAM）提供可靠、有序、全雙工的字節流通道。
socket() → bind() 綁定本地端口 → listen() 進入監聽狀態socket() → connect() 發起連接請求accept() 接受連接，生成新通信套接字，原監聽套接字繼續監聽send()/recv() 進行可靠數據傳輸closesocket() 釋放資源
流式套接字編程流程示意圖
// 服務器端
socket() → bind() → listen() → accept() → recv()/send() → closesocket()
// 客戶端
socket() → connect() → send()/recv() → closesocket()SOCKET sock = socket(AF_INET, SOCK_STREAM, 0);
// AF_INET: IPv4 地址族
// SOCK_STREAM: 流式套接字（TCP）
// 0: 默認協議（TCP）
// 服務器綁定本地地址
SOCKADDR_IN serverAddr;
serverAddr.sin_family = AF_INET;
serverAddr.sin_addr.s_addr = INADDR_ANY; // 綁定所有本地接口
serverAddr.sin_port = htons(USER_PORT); // 主機序轉網絡序
bind(sock, (LPSOCKADDR)&serverAddr, sizeof(serverAddr));注意：端口號 1024 以下為保留端口，自定義服務建議使用 1024-65535 範圍。
listen(sock, SOMAXCONN); // 最大連接隊列長度
// 在獨立線程中調用 accept，避免主線程阻塞
UINT ServerThread(LPVOID pParam) {
CMyView* pView = (CMyView*)pParam;
int nLen = sizeof(SOCKADDR);
pView->newSock = accept(pView->sock, (LPSOCKADDR)&pView->clientAddr, &nLen);
// 關鍵：為新連接套接字註冊異步事件
WSAAsyncSelect(pView->newSock, pView->m_hWnd, WM_SOCKET_MSG, FD_READ | FD_CLOSE);
return 1;
}
// 啟動線程
AfxBeginThread(ServerThread, this);設計考量：accept 默認阻塞，若在主線程調用會凍結界面。雖可設置非阻塞模式輪詢，但會浪費 CPU。採用專用線程阻塞於 accept，將阻塞範圍限制在子線程，是經典折中方案。
// 註冊關注的網絡事件
WSAAsyncSelect(socket, hWnd, WM_SOCKET_MSG, FD_READ | FD_CLOSE);當註冊事件發生時，Windows 向 hWnd 發送 WM_SOCKET_MSG 消息：
wParam：觸發事件的套接字句柄lParam 低字節：網絡事件類型（FD_READ、FD_CLOSE 等）lParam 高字節：錯誤碼（0 表示成功）void CNetServerView::OnSocket(WPARAM wParam, LPARAM lParam) {
SOCKET s = (SOCKET)wParam;
int event = lParam & 0xFFFF;
int error = (lParam >> 16) & 0xFFFF;
if (error) { /* 錯誤處理 */ return; }
switch (event) {
case FD_READ: {
char buffer[MTU * 10];
int nRead = recv(s, buffer, sizeof(buffer), 0);
if (nRead > 0) {
// 保存到文件示例
CFile file;
if (!file.Open(_T("ServerFile.txt"), CFile::modeReadWrite))
file.Open(_T("ServerFile.txt"), CFile::modeCreate | CFile::modeReadWrite);
file.SeekToEnd();
file.Write(buffer, nRead);
file.Close();
}
break;
}
case FD_CLOSE: {
// 客戶端斷開，清理資源
closesocket(s);
break;
}
}
}頭文件：
class CNetServerView : public CView {
// ...
afx_msg void OnSocket(WPARAM wParam, LPARAM lParam);
DECLARE_MESSAGE_MAP()
};實現文件：
BEGIN_MESSAGE_MAP(CNetServerView, CView)
ON_MESSAGE(WM_SOCKET_MSG, OnSocket)
END_MESSAGE_MAP()WSAAsyncSelect(s, hWnd, msg1, FD_READ);
WSAAsyncSelect(s, hWnd, msg2, FD_CLOSE); // 僅 FD_CLOSE 生效，FD_READ 被清除FD_READ | FD_WRITE | FD_CLOSE 一次性註冊lParam 高字節錯誤碼FD_READ 觸發時應循環 recv 直到返回 WSAEWOULDBLOCK，確保讀乾淨，否則下次不再觸發// 客戶端連接
SOCKET sock = socket(AF_INET, SOCK_STREAM, 0);
SOCKADDR_IN serverAddr = {0};
serverAddr.sin_family = AF_INET;
serverAddr.sin_addr.s_addr = inet_addr("192.168.1.100");
serverAddr.sin_port = htons(8080);
// 註冊連接完成、讀寫、關閉事件
WSAAsyncSelect(sock, hWnd, WM_SOCKET_MSG, FD_CONNECT | FD_READ | FD_WRITE | FD_CLOSE);
// 發起非阻塞連接
connect(sock, (SOCKADDR*)&serverAddr, sizeof(serverAddr));
// 連接完成後將收到 FD_CONNECT 消息，此時可發送數據基於 WSAAsyncSelect 的異步選擇模型，憑藉其簡單直觀、完美融合 Windows 消息循環的特點，成為中小型網絡應用、GUI 客戶端的首選方案。對於高並發服務器場景，建議遷移至 IOCP（I/O 完成端口） 模型，利用 WSASocket(..., WSA_FLAG_OVERLAPPED) + CreateIoCompletionPort 實現真正的高性能異步 I/O，單線程可支撐數萬並發連接。
核心要點回顧：
accept + 新套接字註冊異步事件WSAAsyncSelect 事件掩碼一次性設置，避免覆蓋WSAEWOULDBLOCKON_MESSAGE 映射自定義套接字消息
