简介这份资源面向希望理解 Windows 下 Socket 网络编程原理的 C 学习者与 MFC 开发者提供一套基于 MFC 实现的双向网络通信完整示例采用非指针机制组织代码帮助读者绕开指针封装带来的理解障碍直观掌握局域网内消息收发与连接管理的实现思路。包内包含客户端与服务端两套源码及可直接运行的 exe 文件共 67 个文件以 h 头文件、cpp 源文件、obj 编译中间文件、pdb 调试符号、dsp 与 dsw 工程文件、rc 资源脚本、ico 图标及 exe 可执行文件为主压缩包约 4.59MB工程结构清晰便于对照阅读与二次编译。目前已有 158 人学习下载。读者可从中获得完整的 MFC 网络通信工程骨架、监听与收发套接字的类划分方式、客户端与服务端交互流程以及非指针机制下的消息处理与调试排错思路适合作为网络编程入门练手与课程设计的参考素材。1. 双向网络通信为什么值得用 MFC 重做一遍很多做桌面软件的朋友一提到 MFC 就皱眉觉得它是上个时代的产物网络层更是能绕就绕。但现实是大量工业上位机、医疗设备客户端、电力监控后台仍然跑在 MFC 框架上而且它们对网络通信的要求一点都不低既要能主动发指令又要能被动收推送也就是双向网络通信。问题在于MFC 自带的 CAsyncSocket 和 CSocket 用起来总让人提心吊胆指针传来传去稍不留神就是内存泄漏或者野指针崩溃。这个标题里的“非指针机制”恰恰是冲着这个痛点来的——它想表达的是在 MFC 环境下实现双向通信时尽量不依赖裸指针传递对象而是用值语义、引用或者消息机制来管理连接和缓冲区。如果你正在维护一套 MFC 老代码或者准备用 MFC 写一个需要长连接、能收服务端推送的桌面端那这套思路值得你花时间复现一遍。它不追求高并发极限但求稳定、可调试、不给自己埋雷。2. 非指针机制到底指什么从 CAsyncSocket 的指针陷阱说起2.1 为什么 MFC 网络编程容易写成指针灾难MFC 的 CAsyncSocket 设计初衷是好的它把 Winsock 的异步事件封装成虚函数回调比如 OnReceive、OnConnect。但问题出在对象生命周期上CAsyncSocket 对象通常用 new 创建然后把 this 指针挂到窗口消息里或者在 OnAccept 里 new 一个新对象传给通信线程。一旦网络线程和 UI 线程同时操作这个指针或者窗口先销毁而 socket 还在收数据崩溃就来了。更常见的是为了在 OnReceive 里访问对话框控件很多人把对话框的指针存成成员变量结果对话框关了socket 还在回调直接访问野指针。这种“指针满天飞”的写法调试时就是黑匣子出了问题只能靠重启。非指针机制的核心思路很简单把网络连接抽象成一个值对象或者句柄所有回调通过消息队列或者 std::function 传递而不是直接传对象指针。在 MFC 里最稳妥的做法是让 CAsyncSocket 的派生类只负责底层收发把收到的数据打包成结构体通过 PostMessage 发给窗口窗口用消息映射处理。这样socket 对象本身不持有 UI 指针UI 也不直接调用 socket 的成员函数双方靠消息解耦。2.2 用值语义封装连接一个可复用的 CNetChannel 设计我一般会写一个 CNetChannel 类它不继承 CAsyncSocket而是持有一个 CAsyncSocket 的派生类实例并且用 std::shared_ptr 管理但对外只暴露值语义的接口。听起来有点绕看代码就清楚了。先定义数据包结构// NetPacket.h #pragma once #include vector #include cstdint struct NetPacket { uint32_t cmd; // 命令字区分业务类型 std::vectoruint8_t payload; // 实际数据值语义拷贝安全 };然后写一个 Socket 派生类只做收发不碰 UI// RawSocket.h #pragma once #include afxwin.h #include functional #include NetPacket.h class CRawSocket : public CAsyncSocket { public: // 用 std::function 代替指针回调生命周期由调用方管理 std::functionvoid(const NetPacket) onPacket; std::functionvoid() onDisconnected; virtual void OnReceive(int nErrorCode) override { if (nErrorCode ! 0) { if (onDisconnected) onDisconnected(); return; } char buf[4096]; int n Receive(buf, sizeof(buf)); while (n 0) { NetPacket pkt; // 简单协议前4字节cmd后面是payload if (n 4) { memcpy(pkt.cmd, buf, 4); pkt.payload.assign(buf 4, buf n); if (onPacket) onPacket(pkt); // 值传递不传this } n Receive(buf, sizeof(buf)); } } virtual void OnClose(int nErrorCode) override { if (onDisconnected) onDisconnected(); CAsyncSocket::OnClose(nErrorCode); } };这段代码的关键在于onPacket 和 onDisconnected 是 std::function不是裸指针。CRawSocket 对象本身不保存窗口指针它只负责把收到的字节流解析成 NetPacket 值对象然后回调出去。谁注册了这个回调谁就负责处理而且处理的是拷贝后的数据不存在跨线程访问同一块内存的问题。参数说明buf 大小 4096 是经验值太小会拆包太大浪费栈空间cmd 用 4 字节是为了对齐实际项目可以改成变长协议。2.3 消息映射代替直接调用让 UI 线程安全收包有了上面的 RawSocket接下来要在对话框里用它。注意CAsyncSocket 的回调是在网络线程里执行的直接在里面更新控件会出问题。所以 onPacket 里不能直接操作 UI而是用 PostMessage 把数据扔给窗口消息队列。先在对话框类里定义自定义消息// MyDlg.h #define WM_NET_PACKET (WM_USER 100) #define WM_NET_DISCONNECT (WM_USER 101) class CMyDlg : public CDialogEx { // ... CRawSocket m_socket; // 值成员不是指针 public: afx_msg LRESULT OnNetPacket(WPARAM wParam, LPARAM lParam); afx_msg LRESULT OnNetDisconnect(WPARAM, LPARAM); };然后在 OnInitDialog 里初始化 socket 并注册回调// MyDlg.cpp BOOL CMyDlg::OnInitDialog() { CDialogEx::OnInitDialog(); m_socket.Create(); // 先创建再连接 m_socket.onPacket [this](const NetPacket pkt) { // 注意这里还在网络线程不能直接更新UI NetPacket* pCopy new NetPacket(pkt); // 拷贝一份给消息队列 PostMessage(WM_NET_PACKET, 0, (LPARAM)pCopy); }; m_socket.onDisconnected [this]() { PostMessage(WM_NET_DISCONNECT, 0, 0); }; m_socket.Connect(_T(127.0.0.1), 8888); return TRUE; } LRESULT CMyDlg::OnNetPacket(WPARAM, LPARAM lParam) { std::unique_ptrNetPacket pkt(reinterpret_castNetPacket*(lParam)); // 现在在UI线程可以安全更新控件 CString str; str.Format(_T(收到命令%u长度%zu), pkt-cmd, pkt-payload.size()); SetDlgItemText(IDC_LOG, str); return 0; }这里用 new 分配 NetPacket 并通过 PostMessage 传递接收端用 unique_ptr 接管确保释放。虽然用了一次指针但它是值拷贝后的临时对象生命周期完全由消息队列控制不会出现野指针。这就是“非指针机制”的落地方式对外接口是值语义内部跨线程传递用所有权明确的智能指针。参数说明WM_USER100 要确保不和 MFC 内部消息冲突PostMessage 的 wParam 可以传命令字lParam 传数据指针这里为了简单都放 lParam 了。3. 双向通信的完整实现从连接建立到心跳保活3.1 客户端主动连接与服务端被动接受的非对称处理双向通信意味着双方都能主动发数据但连接建立阶段仍然是不对称的客户端调 Connect服务端调 Accept。在 MFC 里服务端通常用 CAsyncSocket 的 OnAccept 回调这里也要避免指针陷阱。常见做法是监听 socket 是对话框成员OnAccept 里 new 一个 CRawSocket然后把它存到一个容器里但容器里存 shared_ptr不存裸指针。看代码// ServerDlg.h #include map #include memory class CServerDlg : public CDialogEx { CAsyncSocket m_listen; std::mapSOCKET, std::shared_ptrCRawSocket m_clients; afx_msg void OnAccept(int nErrorCode); };// ServerDlg.cpp void CServerDlg::OnAccept(int nErrorCode) { if (nErrorCode ! 0) return; auto pNew std::make_sharedCRawSocket(); if (m_listen.Accept(*pNew)) { SOCKET s pNew-GetSocket(); m_clients[s] pNew; pNew-onPacket [this, s](const NetPacket pkt) { // 收到某个客户端的数据可以转发给其他客户端实现双向 for (auto kv : m_clients) { if (kv.first ! s) { kv.second-Send(pkt.cmd, 4); if (!pkt.payload.empty()) kv.second-Send(pkt.payload.data(), pkt.payload.size()); } } }; pNew-onDisconnected [this, s]() { m_clients.erase(s); // shared_ptr 自动释放 }; } CAsyncSocket::OnAccept(nErrorCode); }这里 m_clients 用 map 存 shared_ptr当连接断开时 erase 掉引用计数归零socket 对象自动析构。整个过程没有手动 delete也没有把 this 指针传给 socket 长期持有。参数说明Accept 的参数是 CAsyncSocket 引用所以 CRawSocket 必须公有继承 CAsyncSocketGetSocket 返回原生 SOCKET用作 map 的 key方便查找。3.2 心跳包与断线重连让双向通道保持在线长连接最怕中间网络设备悄悄断开所以心跳包是必须的。在非指针机制下心跳可以用定时器实现定时器回调里直接调用 socket 的 Send因为 socket 是值成员生命周期和对话框一致。但要注意如果连接已经断了Send 会失败所以要判断状态。我一般会加一个 m_bConnected 标志在 OnConnect 和 OnClose 里更新。// 在对话框里设置定时器 SetTimer(1, 5000, nullptr); // 5秒心跳 void CMyDlg::OnTimer(UINT_PTR nIDEvent) { if (nIDEvent 1 m_bConnected) { NetPacket heartbeat; heartbeat.cmd 0xFFFF; // 心跳命令字 m_socket.Send(heartbeat.cmd, 4); } CDialogEx::OnTimer(nIDEvent); }断线重连则是在 OnNetDisconnect 消息里启动一个重连定时器隔几秒尝试 Connect 一次。注意重连前要关闭旧 socket重新 Create否则会报错。这里有个血泪经验CAsyncSocket 的 Connect 如果失败必须调用 Close 再重新 Create不能直接再次 Connect否则状态机就乱了。3.3 用环形缓冲区解决粘包与半包TCP 是流式协议OnReceive 收到的数据不保证是一个完整的包。上面的示例代码简单假设了一次 Receive 就是一个包实际项目必须处理粘包和半包。非指针机制下我推荐在 CRawSocket 里内置一个环形缓冲区用 std::vector 管理收到数据先追加然后按协议头里的长度字段切分。这样对外回调的永远是完整包。// 在 CRawSocket 里增加 std::vectoruint8_t m_buffer; virtual void OnReceive(int nErrorCode) override { char buf[4096]; int n Receive(buf, sizeof(buf)); if (n 0) return; m_buffer.insert(m_buffer.end(), buf, buf n); // 假设协议4字节cmd 4字节长度 payload while (m_buffer.size() 8) { uint32_t cmd, len; memcpy(cmd, m_buffer.data(), 4); memcpy(len, m_buffer.data() 4, 4); if (m_buffer.size() 8 len) break; // 半包继续等 NetPacket pkt; pkt.cmd cmd; pkt.payload.assign(m_buffer.begin() 8, m_buffer.begin() 8 len); if (onPacket) onPacket(pkt); m_buffer.erase(m_buffer.begin(), m_buffer.begin() 8 len); } }参数说明len 字段最大不要超过 1MB否则可能是协议解析错误导致内存暴涨m_buffer 在连接断开时要清空避免下次连接收到脏数据。4. 避坑与排查MFC 双向通信里最容易翻车的 5 个点4.1 现象程序退出时崩溃在 OnReceive原因socket 对象已经析构但网络线程还在回调。解决在对话框 OnDestroy 里先 Close socket再等待网络线程退出或者用 shared_ptr 保证回调期间对象存活。我一般会在 CRawSocket 析构函数里调用 Close并且把 onPacket 置空。4.2 现象PostMessage 发送的数据偶尔乱码原因lParam 传的是栈上对象的地址PostMessage 是异步的等消息处理时栈已经销毁。解决必须用 new 在堆上分配接收端 delete。上面的示例已经用 unique_ptr 处理了。4.3 现象服务端 Accept 后收不到数据原因CAsyncSocket 的 Accept 需要传入一个已经 Create 的 socket 对象但很多人直接传一个未初始化的对象。解决先 pNew-Create() 再 Accept或者用 Detach 方式。注意 Create 的参数要和监听 socket 一致。4.4 现象心跳包导致 CPU 占用高原因定时器间隔太短或者 OnReceive 里用了阻塞的 Receive。解决心跳间隔不低于 3 秒OnReceive 里只调用一次 Receive不要循环阻塞。CAsyncSocket 本身就是异步的循环 Receive 会破坏事件驱动。4.5 现象多客户端时 map 迭代器失效原因在 onPacket 回调里遍历 m_clients 并发送数据如果此时有客户端断开erase 会导致迭代器失效。解决遍历时先拷贝一份 key 列表或者用 std::vector 存 shared_ptr 并加锁。简单做法是用 PostMessage 把转发任务交给 UI 线程串行处理。5. 进阶技巧用自定义消息队列彻底消除跨线程指针如果你想把非指针机制做到极致可以完全不用 new 传递数据而是定义一个线程安全的环形队列网络线程只负责往队列里 push 值对象UI 线程用定时器或者 OnIdle 去 pop。这样连 PostMessage 的指针都不需要了。具体做法写一个模板类 CThreadSafeQueue内部用 std::deque 和 CRITICAL_SECTION 保护push 和 pop 都操作值。然后在对话框里 SetTimer 每 50ms 检查一次队列有数据就更新 UI。这种方式的优点是调试极其方便所有数据流动都是值拷贝没有生命周期纠缠缺点是多了拷贝开销但对于大多数工业场景数据量不大完全可接受。验证方法也很简单在 push 和 pop 处打日志观察队列长度是否稳定。如果持续增长说明 UI 处理不过来需要优化。我自己的习惯是任何 MFC 网络项目先把这个队列搭好再写业务后面基本不会遇到玄学崩溃。希望帮到你。本文还有配套的精品资源点击获取