当前位置：首页 > news >正文

详细的注释和多客户端支持的C++ SOCKET同步阻塞与异步非阻塞通信代码示例

news 2026/6/2 13:54:30

1、C++SOCKET同步阻塞、异步非阻塞通信服务端、客户端代码，支持多个客户端连接。 2、断线重连（服务端或客户端没有启动顺序要求，先开启的等待另一端连接）； 3、服务端支持同时连接多个客户端； 4、阅读代码就明白通信道理，注释详细； 5、VS2015编译通过。

概述

本文介绍了一个基于MFC框架的异步TCP通信程序，包含服务端和客户端两个独立应用程序。该程序采用Windows Socket API的异步非阻塞模式，能够处理多个客户端同时连接，实现了基本的聊天室功能。服务端可以接受多个客户端连接，并将任一客户端发送的消息广播给所有已连接的客户端。

系统架构

技术特点

异步非阻塞通信：使用WSAAsyncSelect实现基于Windows消息机制的异步Socket通信
多客户端支持：服务端使用链表结构管理所有客户端连接信息
Unicode/ANSI编码转换：完整处理不同字符编码的转换
MFC对话框界面：提供友好的用户交互界面

客户端功能详解

核心功能

客户端程序主要实现以下功能：

网络初始化：初始化Winsock库，创建TCP套接字
服务器连接：支持指定服务器IP地址和端口号进行连接
异步消息处理：通过Windows消息机制处理网络事件
消息收发：支持向服务器发送消息并接收来自服务器的消息
编码转换：在Unicode和ANSI编码之间进行转换

关键实现

客户端使用WSAAsyncSelect函数将Socket事件与窗口消息绑定：

WSAAsyncSelect(m_Socket, m_hWnd, NETWORK_RECEIVE, FD_CLOSE | FD_READ | FD_WRITE)

当有网络事件发生时，系统会发送NETWORK_RECEIVE消息到窗口过程，然后在OnNetworkReceive方法中处理具体事件。

消息接收处理流程：

BOOL CAsyncSocketClientDlg::onreceive() { char * buff = new char[1024]; // 接收服务器数据 recv(m_Socket, buff, 1024, 0); // 转换为Unicode并显示在界面上 this->edit_values += AnsiToUnicode(buff); SetDlgItemText(IDC_EDIT1, this->edit_values); }

服务端功能详解

核心功能

服务端程序具备更复杂的功能：

服务监听：在指定端口启动TCP监听服务
客户端管理：使用链表结构维护所有连接的客户端信息
连接接受：异步接受新的客户端连接请求
消息广播：将任一客户端发送的消息转发给所有其他客户端
连接状态监控：实时监测客户端连接和断开状态

关键数据结构

服务端定义了一个结构体来管理客户端信息：

typedef struct clientIP { SOCKET ac_socket; // 客户端套接字 USHORT port; // 客户端端口号 char ip[30]; // 客户端IP地址 }*LclientIP;

所有连接的客户端信息存储在std::list Socket_IP链表中。

消息处理机制

服务端采用两级消息处理机制：

连接级消息（NETWORKCONTROL）：处理新的连接请求（FDACCEPT）
数据级消息（ACTURE_CONTROL）：处理已连接客户端的读写和关闭事件

当有新客户端连接时：

BOOL CAsyncSocketTCPDlg::OnAccept() { // 接受客户端连接 clientIP temp_object; temp_object.ac_socket = accept(m_Socket, (SOCKADDR *)&sender, &len); // 保存客户端信息 strcpy_s(temp_object.ip, inet_ntoa(sender.sin_addr)); Socket_IP.push_back(temp_object); // 为新连接注册异步事件 WSAAsyncSelect(temp_object.ac_socket, m_hWnd, ACTURE_CONTROL, FD_CLOSE | FD_READ | FD_WRITE); }

消息广播实现：

BOOL CAsyncSocketTCPDlg::OnReceive(clientIP &sock) { // 接收来自某一客户端的消息 recv(sock.ac_socket, buff, 1024, 0); // 向所有客户端广播消息 for (itr=Socket_IP.begin(); itr!=Socket_IP.end(); itr++) { send(itr->ac_socket, temp, num, 0); } }