简介这份资源面向在 Windows 平台使用 VS2008 进行 ZeroMQ 开发的初学者围绕订阅与发布模式给出可运行的入门实例。内容包含 ZeroMQ 库的获取与编译说明、服务端与客户端两个测试工程的完整源码以及头文件、库文件与工程配置的对应关系帮助读者快速理解 ZeroMQ 在 Windows 下的集成方式与基本通信流程。压缩包共 31 个文件以 h 头文件、cpp 源文件、dll 动态库、lib 静态库和 vcproj 工程文件为主另附说明文档与工程说明文本整体约 4.25MB结构紧凑便于直接打开编译。目前已有 488 人学习下载适合需要快速跑通 ZeroMQ 发布订阅示例、对照源码理解工程配置细节的开发者参考。1. 在 VS2008 里把 ZeroMQ 订阅发布跑起来版本选错一步都白搭前阵子帮一个做工业数据采集的朋友收拾一台老工控机系统是 Windows 7开发环境锁死在 VS2008需求很简单把产线上几个采集点的数据用发布订阅模式分发出去。听起来十分钟的事结果光是把 ZeroMQ 在 VS2008 里编过就折腾了大半天。ZeroMQ 这个库本身不复杂但它的版本分水岭特别明显——3.x 和 4.x 的 API 头文件、库名、依赖方式都不一样而 VS2008 又是 2008 年的编译器对 C11 之后的东西一概不认。你要是随手下了个最新版编译报错能刷满整个输出窗口。这篇笔记就是记录我在这套老环境里从选版本、配路径、写订阅发布实例到跑通验证的完整过程适合还在维护 VS2008 老项目、又需要引入消息队列的开发者照着走一遍。2. 环境准备VS2008 配 ZeroMQ 的版本选择与目录规划2.1 为什么 ZeroMQ 版本必须卡在 3.2.xZeroMQ 从 4.0 开始源码里大量使用了 C11 的特性比如std::atomic、std::mutex而 VS2008 自带的编译器是 MSVC 9.0根本不支持 C11。你拿 4.x 的源码去编第一步#include atomic就直接报找不到文件。所以在这套环境里唯一稳妥的选择是 ZeroMQ 3.2.x 系列我一般用 3.2.5这个版本对 MSVC 9.0 的兼容性最好官方源码包里还带着 VS2008 的解决方案文件省得自己从头搭工程。另一个坑是 libzmq 和 czmq 的区别。czmq 是 ZeroMQ 的高级封装用起来更顺手但它依赖 libzmq 的版本更严格而且在 VS2008 下编 czmq 经常卡在stdint.h缺失上。如果你的项目只是做简单的发布订阅直接用 libzmq 的 C API 就够了别给自己加戏。2.2 目录结构规划与依赖确认在动手之前先把目录理清楚。我习惯在 D 盘建一个统一的第三方库目录避免路径里带空格和中文VS2008 对这两样东西的容忍度很低。D:\thirdparty\ zeromq-3.2.5\ include\ # 存放 zmq.h 和 zmq_utils.h lib\ # 存放 libzmq.lib bin\ # 存放 libzmq.dll projects\ zmq_pub\ # 发布端工程 zmq_sub\ # 订阅端工程这个结构的好处是头文件、静态库、动态库分开存放VS2008 工程里配置包含目录和库目录时一目了然。注意bin目录要单独放因为运行时 DLL 必须和 exe 在同一目录或者放进系统 PATH否则程序启动就弹「找不到 libzmq.dll」。依赖方面ZeroMQ 3.2.5 在 Windows 下只需要系统自带的ws2_32.lib不需要额外的第三方库。这一点比很多消息队列中间件省心也是它在工控场景里受欢迎的原因之一。2.3 编译 libzmq 生成 VS2008 可用的库文件如果你下载的是源码包里面builds\msvc目录下会有 VS2008 的解决方案文件。用 VS2008 打开libzmq.sln注意配置管理器里要选Release和Win32别选成 x64除非你的工控机是 64 位系统且 VS2008 装了 64 位编译组件。编译之前先检查项目属性里的运行库设置。libzmq 默认用的是多线程 DLL 运行库/MD如果你的主工程用的是 /MT链接时会报LNK2005重复定义错误。我一般把 libzmq 和主工程统一成 /MD省得后面扯皮。编译完成后在lib目录下会生成libzmq.lib在bin目录下会生成libzmq.dll。把这两个文件分别拷到前面规划的lib和bin目录里头文件从include目录拷zmq.h和zmq_utils.h过去。提示如果你不想自己编译也可以找现成的 3.2.5 编译好的包但要注意对方用的运行库版本是否和你一致否则一样会链接报错。3. 工程配置VS2008 里把 ZeroMQ 链接进项目3.1 新建控制台工程与包含目录设置打开 VS2008新建一个 Win32 控制台应用程序命名为zmq_pub应用程序类型选「控制台应用程序」附加选项里勾上「空项目」免得生成一堆用不上的模板代码。工程建好后右键项目 → 属性在「配置属性 → C/C → 常规 → 附加包含目录」里填入D:\thirdparty\zeromq-3.2.5\include。这一步是告诉编译器去哪里找zmq.h。注意路径末尾不要加反斜杠VS2008 有时候会因为末尾反斜杠导致路径拼接异常。3.2 链接器配置与运行库一致性检查接着在「配置属性 → 链接器 → 常规 → 附加库目录」里填入D:\thirdparty\zeromq-3.2.5\lib然后在「链接器 → 输入 → 附加依赖项」里加上libzmq.lib ws2_32.lib。ws2_32.lib是 Windows Socket 库ZeroMQ 底层网络通信要用到不加的话会报一堆unresolved external symbol错误。运行库的设置在前面提过这里再确认一遍「配置属性 → C/C → 代码生成 → 运行时库」选「多线程 DLL (/MD)」。如果你用的是 Debug 配置就选「多线程调试 DLL (/MDd)」但要注意 Debug 版的 libzmq 和 Release 版不能混用否则会出现堆损坏的玄学问题。3.3 发布端代码绑定端口与循环发送配置好之后先写发布端。发布端的逻辑很简单创建一个ZMQ_PUB类型的 socket绑定一个端口然后循环发送消息。#include zmq.h #include stdio.h #include string.h #include windows.h int main() { // 创建 ZeroMQ 上下文1 表示内部 IO 线程数 void* context zmq_init(1); if (!context) { printf(zmq_init failed\n); return -1; } // 创建发布者 socket void* publisher zmq_socket(context, ZMQ_PUB); if (!publisher) { printf(zmq_socket failed\n); zmq_term(context); return -1; } // 绑定到 5555 端口所有订阅者连接这个端口 int rc zmq_bind(publisher, tcp://127.0.0.1:5555); if (rc ! 0) { printf(zmq_bind failed\n); zmq_close(publisher); zmq_term(context); return -1; } printf(Publisher started, binding on tcp://127.0.0.1:5555\n); int count 0; while (1) { char buffer[64]; // 消息格式主题 空格 内容订阅端按主题过滤 sprintf(buffer, sensor %d, count); zmq_msg_t msg; zmq_msg_init_size(msg, strlen(buffer) 1); memcpy(zmq_msg_data(msg), buffer, strlen(buffer) 1); // 发送消息ZMQ_PUB 类型 socket 发送失败不阻塞 rc zmq_send(publisher, msg, 0); zmq_msg_close(msg); if (rc ! 0) { printf(zmq_send failed\n); break; } printf(Sent: %s\n, buffer); Sleep(1000); // 每秒发一条方便观察 } zmq_close(publisher); zmq_term(context); return 0; }这段代码里几个关键点zmq_init(1)的参数是 IO 线程数对于简单的发布订阅1 个线程足够zmq_bind用的是tcp://127.0.0.1:5555实际部署时改成工控机的内网 IP消息内容以sensor开头后面跟序号订阅端会根据这个前缀做过滤。Sleep(1000)是 Windows API需要包含windows.h用Sleep而不是sleep后者在 MSVC 里不存在。3.4 订阅端代码连接、订阅与接收循环订阅端稍微多一步创建ZMQ_SUB类型的 socket 后必须调用zmq_setsockopt设置订阅过滤条件否则收不到任何消息。这是 ZeroMQ 发布订阅模式最容易踩的坑之一。#include zmq.h #include stdio.h #include string.h int main() { void* context zmq_init(1); if (!context) { printf(zmq_init failed\n); return -1; } void* subscriber zmq_socket(context, ZMQ_SUB); if (!subscriber) { printf(zmq_socket failed\n); zmq_term(context); return -1; } // 连接到发布端 int rc zmq_connect(subscriber, tcp://127.0.0.1:5555); if (rc ! 0) { printf(zmq_connect failed\n); zmq_close(subscriber); zmq_term(context); return -1; } // 设置订阅过滤空字符串表示订阅所有主题 // 如果只想收 sensor 开头的消息改成 sensor 即可 rc zmq_setsockopt(subscriber, ZMQ_SUBSCRIBE, , 0); if (rc ! 0) { printf(zmq_setsockopt failed\n); zmq_close(subscriber); zmq_term(context); return -1; } printf(Subscriber started, connected to tcp://127.0.0.1:5555\n); while (1) { zmq_msg_t msg; zmq_msg_init(msg); // 阻塞接收消息 rc zmq_recv(subscriber, msg, 0); if (rc ! 0) { printf(zmq_recv failed\n); zmq_msg_close(msg); break; } // 消息末尾补 \0方便当字符串打印 int size zmq_msg_size(msg); char* data (char*)malloc(size 1); memcpy(data, zmq_msg_data(msg), size); data[size] \0; printf(Received: %s\n, data); free(data); zmq_msg_close(msg); } zmq_close(subscriber); zmq_term(context); return 0; }订阅端的zmq_setsockopt那行是重点ZMQ_SUBSCRIBE的第四个参数是过滤前缀长度传 0 表示订阅所有消息。如果你只关心sensor开头的消息把空字符串改成sensor长度传 6。注意这个过滤是在发布端做的不是订阅端本地过滤所以订阅条件设置得越精确网络传输的数据量越小。4. 避坑排查VS2008 下 ZeroMQ 订阅发布的五个血泪坑4.1 编译报错「无法打开包括文件: zmq.h」现象是编译时提示找不到zmq.h但你明明在附加包含目录里配了路径。原因通常是路径写错了或者你把头文件放在了带空格的目录里。VS2008 对路径中的空格处理有问题比如D:\my projects\zeromq\include这种路径它可能只识别到D:\my就断了。解决办法是把第三方库放在无空格、无中文的路径下比如D:\thirdparty\。4.2 链接报错「unresolved external symbol _zmq_init」这个错误说明编译器找到了头文件但链接器没找到libzmq.lib。检查两个地方一是附加库目录是否指向了libzmq.lib所在的目录二是附加依赖项里是否写了libzmq.lib。还有一个隐蔽情况是你编译 libzmq 时用的是 x64 配置但主工程是 Win32架构不匹配链接器直接忽略了这个库。解决办法是确保两边架构一致。4.3 程序启动弹窗「找不到 libzmq.dll」编译链接都过了双击 exe 却弹窗说找不到 DLL。原因是libzmq.dll不在 exe 的搜索路径里。Windows 搜索 DLL 的顺序是exe 所在目录 → 系统目录 → PATH 环境变量。最简单的做法是把libzmq.dll拷到 exe 同目录下。如果不想拷来拷去就把bin目录加到系统 PATH 里但注意改完 PATH 要重启 VS2008 才生效。4.4 订阅端收不到消息发布端在发订阅端也在收但就是一条消息都收不到。最常见的原因是订阅端忘了调zmq_setsockopt设置ZMQ_SUBSCRIBEZeroMQ 的订阅 socket 默认不接收任何消息必须显式订阅。另一个原因是发布端和订阅端的连接顺序如果发布端还没绑定端口订阅端就zmq_connectZeroMQ 会自动重连但如果你在连接后立刻发消息可能因为连接还没建立而丢失。我一般让发布端先启动等一秒再启动订阅端。4.5 程序退出时卡死或崩溃调用zmq_term之后程序卡住不动或者直接崩溃。这通常是因为还有 socket 没关闭就调了zmq_term。正确的顺序是先zmq_close所有 socket再zmq_term销毁上下文。另外如果zmq_send或zmq_recv正在阻塞另一个线程调了zmq_term也会导致崩溃。在 VS2008 这种老环境里尽量用单线程模型别在回调里做复杂操作。5. 验证跑通发布订阅联调与消息吞吐观察5.1 双工程联调步骤把发布端和订阅端分别编译成zmq_pub.exe和zmq_sub.exe两个 exe 和libzmq.dll放在同一目录下。先双击zmq_pub.exe看到Publisher started和不断输出的Sent: sensor 0、Sent: sensor 1就说明发布端正常。再双击zmq_sub.exe如果看到Received: sensor 0跟着发布端的节奏一条条出来说明整条链路通了。这里有个细节如果你先启动订阅端再启动发布端订阅端可能前几条收不到因为 ZeroMQ 的发布订阅是「慢加入者丢消息」模型连接建立之前发的消息不会补发。这不是 bug是设计如此。工控场景里如果要求不丢消息得改用ZMQ_PUSH/ZMQ_PULL或者加一层确认机制。5.2 用命令行快速验证端口监听如果订阅端连不上先在命令行里确认发布端有没有真的在监听 5555 端口netstat -ano | findstr 5555正常的话会看到一行TCP 127.0.0.1:5555 0.0.0.0:0 LISTENING后面的 PID 就是zmq_pub.exe的进程号。如果没有这行说明zmq_bind失败了检查端口是不是被其他程序占用或者防火墙有没有拦截。工控机上经常装着各种组态软件它们可能已经占用了 5555 端口换个端口比如 5566 就行。5.3 消息吞吐与延迟的简单观察在发布端把Sleep(1000)改成Sleep(10)每秒发 100 条观察订阅端的输出是否跟得上。如果订阅端输出明显滞后或者开始丢消息说明接收循环处理太慢。在 VS2008 里printf本身是瓶颈可以改成累加计数每 1000 条打印一次。另外ZeroMQ 的默认高水位标记是 1000 条消息超过这个数发布端会丢弃消息可以通过zmq_setsockopt设置ZMQ_SNDHWM调大但工控场景里更重要的是消费速度跟得上而不是无限缓冲。5.4 验证清单与版本对照跑通之后我习惯对照下面这张表再确认一遍避免换台机器又翻车检查项正确状态常见错误状态ZeroMQ 版本3.2.54.x 编译报 C11 错误运行库配置/MD 或 /MDd 一致/MT 与 /MD 混用导致 LNK2005包含目录指向 include 文件夹路径带空格或中文库目录指向 libzmq.lib 所在目录指向了 bin 目录DLL 位置与 exe 同目录放在系统目录但版本不对订阅过滤调用了 zmq_setsockopt忘记设置导致收不到消息启动顺序先发布端后订阅端先订阅端导致前几条丢失从那以后我每次在这类老环境里配 ZeroMQ都强制先跑一遍这张表尤其是运行库一致性和订阅过滤这两项翻车次数最多。希望帮到你。本文还有配套的精品资源点击获取