简介这份资源面向在 Windows 平台使用 Visual Studio 2008 进行 ZeroMQ 开发的初学者围绕订阅与发布模式提供一套可快速上手的入门实例。内容包含 ZeroMQ 的下载与编译说明、服务端与客户端两个独立测试工程的完整源码以及头文件、库文件的引用配置方法帮助读者理解消息队列在进程间通信中的基本用法。压缩包共 31 个文件以 h 头文件、cpp 源文件、dll 动态库、lib 静态库和 txt 说明文档为主另含 vcproj 工程文件、sln 解决方案与 doc 教程文档整体约 4.25MB结构清晰便于对照学习。目前已有 487 人学习下载。读者可借助其中的工程说明与示例代码快速完成 ZeroMQ 环境搭建掌握发布订阅模型的编码流程与常见配置要点适合作为消息中间件入门的第一份实践材料。1. 老编译器遇上消息队列为什么还有人要在 VS2008 里跑 ZeroMQ如果你手上维护的是一套十几年前定型的工控上位机、测试台架或者产线数据采集软件大概率会遇到这个组合Windows XP/7 时代的开发机、Visual Studio 2008、C03 语法以及一个绕不开的需求——把多台设备的数据实时汇总到一台机器上。这时候 ZeroMQ 的发布订阅模式几乎是性价比最高的选择不用装服务端、不用配中间件、一个 DLL 加几个头文件就能跑起来。但问题在于ZeroMQ 官方早就把 VS2008 的支持从主线里拿掉了网上能搜到的教程要么是 Linux 下的要么是 VS2015 以后的直接照抄必然翻车。这篇笔记就是把我自己在一套模拟产线采集系统里踩过的路重新走一遍从库的编译到订阅发布跑通把参数、坑点和排查方法都摊开讲。适合两类人一类是被老项目绑住、必须用 VS2008 交付的工程师另一类是想理解 ZeroMQ 发布订阅底层行为、不想只停留在调 API 层面的开发者。2. 在 VS2008 里把 ZeroMQ 编译成能用的库从源码到 lib 与 dll2.1 为什么不能直接下现成的二进制包ZeroMQ 官方发布的 Windows 二进制包从 4.x 某个版本之后基本都转向了 VS2015 及以上的工具集运行库是 v140/v142。VS2008 用的是 v90 工具集链接阶段会因为 MSVCR90.dll 和 MSVCR140.dll 的混用直接报 LNK2001 或者运行时崩溃。更隐蔽的问题是 C 运行库的堆管理如果 DLL 在一个堆上分配内存、EXE 在另一个堆上释放程序跑一段时间就会莫名其妙地访问违例。所以最稳妥的做法是自己拿源码编译保证整个工程和库用的是同一套 v90 运行库。常见做法是去 ZeroMQ 的发布页找 4.0.x 或 4.1.x 的源码包这两个大版本对 C03 和旧编译器的兼容性最好。再新的版本会用到一些 C99 特性和新的 Windows APIVS2008 的头文件里根本没有声明。我一般会选 4.1.7 这个版本它在旧工具集下的编译成功率最高而且发布订阅的核心行为已经稳定。2.2 用 VS2008 命令行工具链编译静态库ZeroMQ 源码包里自带builds\msvc目录里面有各版本 VS 的解决方案文件。但 VS2008 对应的.sln往往缺文件或者路径不对直接打开会提示项目加载失败。我的做法是绕开解决方案直接用vcbuild或者nmake走命令行这样每一步都能看到实际调用了什么。先把源码解压到一个没有空格和中文的路径比如D:\zmq\zeromq-4.1.7。然后打开 VS2008 的命令行环境开始菜单里找「Visual Studio 2008 Command Prompt」或者手动执行vcvarsall.bat x86。接下来进入源码的builds\msvc目录手动生成 Makefile# 进入源码的 msvc 构建目录 cd /d D:\zmq\zeromq-4.1.7\builds\msvc # 用 VS2008 自带的 nmake 生成项目文件 # 注意这里指定了静态库模式避免 DLL 堆问题 nmake -f Makefile.vc clean nmake -f Makefile.vc libzmq.lib如果Makefile.vc不存在说明这个源码包没有带 VS2008 的构建脚本需要自己写一个简单的。更通用的办法是用 CMake 生成 VS2008 工程但前提是机器上装了 CMake 2.8.x 这个老版本新版本 CMake 已经不支持 VS2008 生成器了。用 CMake 的话命令是这样# 在源码根目录建一个 build 目录 mkdir build cd build # 指定 VS2008 生成器关闭测试和示例减少编译量 cmake -G Visual Studio 9 2008 ^ -DCMAKE_BUILD_TYPERelease ^ -DBUILD_TESTSOFF ^ -DBUILD_SHAREDOFF ^ -DWITH_PERF_TOOLOFF ^ .. # 用 msbuild 或 vcbuild 编译 vcbuild libzmq.vcproj Release|Win32这里几个参数值得说明。BUILD_SHAREDOFF是关键它让 ZeroMQ 编译成静态库libzmq.lib直接链进你的 EXE彻底避开 DLL 堆和运行库版本的问题。代价是最终 EXE 体积会大几百 KB但对工控软件来说这点体积无所谓。BUILD_TESTSOFF和WITH_PERF_TOOLOFF是为了减少编译时间测试代码里有些 C99 写法在 VS2008 下会报错关掉省心。编译完成后在build\lib\Release或者build\Release目录下能找到libzmq.lib。头文件在源码的include目录主要用到zmq.h和zmq_utils.h两个。2.3 在 VS2008 工程里配置头文件和库路径新建一个 Win32 控制台工程注意在向导里选「空项目」避免 VS 自动生成一堆用不上的文件。然后右键工程属性做三处配置第一处是 C/C 的「附加包含目录」填D:\zmq\zeromq-4.1.7\include。第二处是链接器的「附加库目录」填D:\zmq\zeromq-4.1.7\build\lib\Release。第三处是链接器的「附加依赖项」填libzmq.lib;ws2_32.lib;Iphlpapi.lib。后面两个是 Windows 网络编程必须的系统库ZeroMQ 内部会调用 Winsock 的接口不显式链接会在链接阶段报找不到符号。还有一个容易漏掉的配置C/C 的「代码生成」里运行库要选「多线程 (/MT)」或者「多线程调试 (/MTd)」必须和编译 libzmq 时用的选项一致。如果 libzmq 用的是 /MT而你的工程用 /MD链接时会报LNK2005重复定义或者运行时堆校验失败。这个坑我在第一次集成时卡了整整一个下午血泪经验就是编译库和用库的工程运行库选项必须一模一样。3. 发布订阅模式的最小可运行实例从单进程到跨进程3.1 发布端和订阅端的代码骨架ZeroMQ 的发布订阅模型里发布端用ZMQ_PUB类型的套接字订阅端用ZMQ_SUB。发布端绑定一个端口订阅端连接过去然后订阅端通过ZMQ_SUBSCRIBE设置过滤前缀。消息从发布端发出后只有前缀匹配的订阅端能收到。下面是最小的发布端代码// publisher.cpp - 发布端绑定 5555 端口每秒发一条消息 #include zmq.h #include stdio.h #include windows.h int main() { // 创建 ZeroMQ 上下文1 表示内部 IO 线程数 void* ctx zmq_ctx_new(); // 创建 PUB 类型套接字 void* pub zmq_socket(ctx, ZMQ_PUB); // 绑定到本机所有网卡的 5555 端口 int rc zmq_bind(pub, tcp://*:5555); if (rc ! 0) { printf(bind failed: %s\n, zmq_strerror(zmq_errno())); return -1; } int count 0; while (1) { char buf[64]; // 消息格式topic 空格 序号 sprintf(buf, sensor %d, count); // 发送时指定长度不依赖字符串结尾 zmq_send(pub, buf, strlen(buf), 0); printf(sent: %s\n, buf); Sleep(1000); } zmq_close(pub); zmq_ctx_destroy(ctx); return 0; }订阅端代码// subscriber.cpp - 订阅端连接发布端只收 sensor 开头的消息 #include zmq.h #include stdio.h int main() { void* ctx zmq_ctx_new(); // 创建 SUB 类型套接字 void* sub zmq_socket(ctx, ZMQ_SUB); // 连接到发布端注意这里用 connect 而不是 bind int rc zmq_connect(sub, tcp://127.0.0.1:5555); if (rc ! 0) { printf(connect failed: %s\n, zmq_strerror(zmq_errno())); return -1; } // 设置订阅前缀空字符串表示订阅所有消息 // 这里只订阅 sensor 开头的 zmq_setsockopt(sub, ZMQ_SUBSCRIBE, sensor, 6); while (1) { char buf[128]; // 接收消息返回实际字节数 int n zmq_recv(sub, buf, sizeof(buf) - 1, 0); if (n 0) { printf(recv failed: %s\n, zmq_strerror(zmq_errno())); break; } buf[n] \0; printf(received: %s\n, buf); } zmq_close(sub); zmq_ctx_destroy(ctx); return 0; }这两段代码的逻辑很直白发布端创建上下文、创建 PUB 套接字、绑定端口然后循环发送订阅端创建上下文、创建 SUB 套接字、连接端口、设置订阅前缀然后循环接收。关键点在于zmq_setsockopt的第三个参数是前缀字符串第四个参数是前缀长度。如果写成zmq_setsockopt(sub, ZMQ_SUBSCRIBE, sensor, 6)那么只有以sensor开头的消息会被投递。如果前缀长度写错比如写成 5就变成匹配senso行为会不符合预期。3.2 编译运行与第一个必踩的坑慢连接问题把两个文件分别编译成 EXE先启动发布端再启动订阅端理论上订阅端应该每秒打印一条消息。但实际跑起来你很可能会发现订阅端一条都收不到或者前几条丢失。这不是代码写错了而是 ZeroMQ 发布订阅模式的一个固有行为叫「慢连接」问题。具体原因是发布端绑定端口后立刻开始发送而订阅端此时可能还没完成 TCP 连接和订阅前缀的注册。ZeroMQ 的 PUB 套接字在发送消息时如果还没有任何订阅者连接上来这条消息会直接被丢弃不会缓存。所以如果发布端先启动、订阅端后启动订阅端启动之前发布端发的消息全部丢失这是正常的。更隐蔽的情况是订阅端虽然启动了但 TCP 三次握手和订阅信息传递需要几十毫秒这期间发布端发的消息也会丢。解决办法有两个。第一个是在发布端启动后先Sleep(1000)再进入发送循环给订阅端留出连接时间。第二个是在订阅端连接成功后先发一条「握手」消息给发布端但 PUB/SUB 模式不支持反向通信所以这个办法需要额外加一个 REQ/REP 通道复杂度上来了。对于工控场景我一般直接用第一个办法在发布端绑定之后加一个一秒的延时简单可靠。提示慢连接问题不是 bug是 PUB/SUB 模式的设计取舍。它保证了发布端不会被慢订阅者阻塞代价就是连接建立期间的消息会丢。如果你的场景不允许丢消息应该改用 PUSH/PULL 或者加一层确认机制。3.3 跨进程和跨机器通信的配置差异上面的例子是在同一台机器上跑发布端绑定tcp://*:5555订阅端连接tcp://127.0.0.1:5555。如果要跨机器订阅端的连接地址要改成发布端的实际 IP比如tcp://192.168.1.100:5555。这里有个细节发布端绑定*表示监听所有网卡如果只想监听内网网卡可以写成tcp://192.168.1.100:5555。跨机器时还要注意 Windows 防火墙。VS2008 编译出来的 EXE 第一次运行绑定时防火墙会弹窗询问是否允许如果点了取消后续连接会一直超时。排查方法是在发布端机器上执行netstat -ano | findstr 5555看端口有没有处于 LISTENING 状态。如果没有就是绑定失败或者被防火墙拦了。另外跨机器通信时订阅端的zmq_connect如果填了主机名而不是 IP在 VS2008 环境下可能会因为 DNS 解析超时而阻塞。我一般直接用 IP 地址避免引入不必要的变量。4. 发布订阅的参数调优与常见避坑记录4.1 高频发送下的丢包排查从 HWM 到 TCP 缓冲区当发布频率从每秒一条提高到每秒几千条时订阅端开始出现丢包。这时候第一个要查的参数是ZMQ_SNDHWM也就是发送端的高水位标记。ZeroMQ 在发布端为每个订阅者维护一个发送队列队列长度默认是 1000 条消息。如果订阅端消费速度跟不上队列满了之后新消息会被丢弃。可以通过zmq_setsockopt调整// 把发送端高水位调到 100000 条 int hwm 100000; zmq_setsockopt(pub, ZMQ_SNDHWM, hwm, sizeof(hwm)); // 订阅端也可以设置接收高水位 zmq_setsockopt(sub, ZMQ_RCVHWM, hwm, sizeof(hwm));但调大 HWM 只是把问题延后如果订阅端持续消费不过来内存会一直涨。根本办法还是提高订阅端的处理速度或者用多线程把接收和处理分开。另一个容易被忽略的参数是 TCP 的发送缓冲区ZeroMQ 底层用的是操作系统的 socketWindows 默认的发送缓冲区可能只有 8KB高频发送时会成为瓶颈。可以在绑定之前设置// 设置 TCP 发送缓冲区为 1MB int sndbuf 1024 * 1024; zmq_setsockopt(pub, ZMQ_SNDBUF, sndbuf, sizeof(sndbuf));4.2 订阅前缀的匹配规则与三个易错点订阅前缀的匹配是从消息的第一个字节开始逐字节比较不涉及正则或者通配符。三个易错点分别是第一前缀长度参数必须和字符串实际长度一致用strlen计算时要注意字符串里有没有嵌入的\0第二订阅端可以多次调用zmq_setsockopt添加多个前缀消息匹配任意一个就会被投递第三如果前缀设置为空字符串且长度为 0表示订阅所有消息但有些版本的 ZeroMQ 对长度为 0 的处理不一致建议显式传一个长度为 1 的前缀或者用ZMQ_SUBSCRIBE配合空指针。还有一个坑是消息分隔符。ZeroMQ 的消息可以有多帧发布端用zmq_send时如果带了ZMQ_SNDMORE标志表示后面还有帧。订阅端接收时需要用zmq_recv配合ZMQ_RCVMORE判断是否还有后续帧。如果发布端发了多帧而订阅端只收了一帧剩下的帧会残留在缓冲区里导致后续消息错位。我一般建议在发布订阅模式里只用单帧消息把复杂结构序列化成一段连续内存再发。4.3 避坑记录五个让程序崩溃或静默失败的场景现象一程序启动时报「无法定位程序输入点」或者直接闪退。原因是 EXE 和 DLL 的运行库版本不一致或者链接了错误的 libzmq。解决方法是确认工程属性里的运行库选项和编译 libzmq 时一致并且附加依赖项里只链接自己编译出来的那个libzmq.lib不要混入系统路径下的其他版本。现象二订阅端能连接但收不到任何消息。先检查订阅前缀是否匹配再检查发布端是否在订阅端连接之前就开始发送。如果发布端发送频率很低比如每分钟一条慢连接问题会导致前几条丢失但后续应该能收到。如果一直收不到用zmq_getsockopt查一下ZMQ_EVENTS看套接字上有没有可读事件。现象三程序运行一段时间后内存持续增长。大概率是 HWM 设置过大加上订阅端消费慢消息在发送队列里堆积。用任务管理器看发布端进程的内存如果和发送速率成正比增长就是这个问题。解决办法是调小 HWM 或者提高订阅端处理速度。现象四跨机器通信时连接超时。先在发布端机器上用telnet 目标IP 5555测试端口通不通不通就是防火墙或者绑定地址的问题。如果发布端绑定的是127.0.0.1而不是*或者实际 IP外部机器根本连不上。这个错误很隐蔽因为本机测试完全正常。现象五VS2008 调试模式下运行正常Release 模式下崩溃。通常是变量未初始化或者数组越界Debug 模式下编译器会填充一些特殊值让问题暴露Release 模式下这些填充没了问题就变成随机崩溃。重点检查zmq_recv的缓冲区大小和返回值的处理确保n小于缓冲区长度时才写buf[n] \0。5. 用多线程订阅和消息序列化把方案推到可用单线程的订阅端在消息量上来之后必然成为瓶颈因为zmq_recv是阻塞的接收和处理串在一起。一个实用的改进是把接收和处理拆到两个线程中间用一个无锁队列或者简单的环形缓冲区传递。ZeroMQ 的套接字不是线程安全的所以接收线程负责zmq_recv处理线程从队列里取数据两边通过条件变量同步。另一个提升可用性的点是消息序列化。发布端发送的往往不是简单字符串而是包含多个字段的结构体。直接memcpy结构体发送在 VS2008 下有个隐患结构体对齐方式可能因为编译选项不同而变化导致订阅端解析错位。稳妥的做法是手动序列化成字节流每个字段按固定长度写入。比如一个包含设备 ID、时间戳、数值的结构// 序列化设备ID(4字节) 时间戳(8字节) 数值(4字节) char buf[16]; int devId 1001; long long ts GetTickCount(); float value 23.5f; memcpy(buf, devId, 4); memcpy(buf 4, ts, 8); memcpy(buf 12, value, 4); // 发送时指定总长度 16 zmq_send(pub, buf, 16, 0);订阅端按同样的偏移量解析。这里要注意字节序问题如果发布端和订阅端都是 x86 架构字节序一致不用额外处理。如果涉及跨架构通信需要在序列化时统一转成网络字节序。最后一个技巧是关于zmq_ctx_new的参数。这个参数指定 ZeroMQ 内部 IO 线程的数量默认是 1。如果发布端要同时服务几百个订阅者1 个 IO 线程可能不够可以调到 2 或者 4。但也不是越大越好IO 线程太多会增加上下文切换开销。我一般从 1 开始用性能监视器看 CPU 占用如果某个核跑满了再往上加。这套方案在一套模拟产线采集系统里连续跑了三个月每天处理几十万条消息没有出现过崩溃或者消息错乱。我的习惯是每次改完参数都先用zmq_send和zmq_recv的返回值做断言把错误在发生的第一时间暴露出来而不是等程序跑飞了再回头查。希望帮到你。本文还有配套的精品资源点击获取