C++ ZeroMQ 教程（从零开始掌握 C++ 消息队列通信）

安装 ZeroMQ（C++ 环境）

在开始编码前，你需要先安装 ZeroMQ 库及其 C++ 绑定（通常使用 cppzmq）。以下是常见平台的安装方法：

Ubuntu / Debian

sudo apt updatesudo apt install libzmq3-dev libczmq-dev# 安装 C++ 头文件（cppzmq）git clone https://github.com/zeromq/cppzmq.gitsudo cp cppzmq/zmq.hpp /usr/local/include/sudo cp cppzmq/zmq_addon.hpp /usr/local/include/

Windows（使用 vcpkg）

# 安装 vcpkg（如果尚未安装）git clone https://github.com/Microsoft/vcpkg.gitcd vcpkg./bootstrap-vcpkg.bat# 安装 ZeroMQ 和 cppzmqvcpkg install zeromq cppzmq# 在 Visual Studio 中集成vcpkg integrate install

第一个 ZeroMQ 程序：请求-应答模式

我们以最基础的“请求-应答”（Request-Reply）模式为例。这种模式常用于客户端向服务端发送请求并等待响应。

服务端代码（server.cpp）

#include <iostream>#include <zmq.hpp>#include <string>int main() {    // 创建 ZeroMQ 上下文    zmq::context_t context(1);        // 创建 REP（应答）套接字    zmq::socket_t socket(context, ZMQ_REP);    socket.bind("tcp://*:5555");  // 监听所有接口的 5555 端口    std::cout << "服务端已启动，等待客户端连接...\n";    while (true) {        // 接收客户端消息        zmq::message_t request;        socket.recv(request, zmq::recv_flags::none);        std::string msg_str(static_cast(request.data()), request.size());        std::cout << "收到请求: " << msg_str << std::endl;        // 发送回复        std::string reply = "Hello from server!";        socket.send(zmq::buffer(reply), zmq::send_flags::none);    }    return 0;}

客户端代码（client.cpp）

#include <iostream>#include <zmq.hpp>#include <string>int main() {    zmq::context_t context(1);    zmq::socket_t socket(context, ZMQ_REQ);    socket.connect("tcp://localhost:5555");  // 连接本地服务端    // 发送请求    std::string request = "Hello from client!";    socket.send(zmq::buffer(request), zmq::send_flags::none);    // 接收回复    zmq::message_t reply;    socket.recv(reply, zmq::recv_flags::none);    std::string reply_str(static_cast(reply.data()), reply.size());    std::cout << "收到回复: " << reply_str << std::endl;    return 0;}

编译与运行

在 Linux 或 macOS 下，使用以下命令编译：

g++ -std=c++17 server.cpp -lzmq -o serverg++ -std=c++17 client.cpp -lzmq -o client

然后先运行服务端：./server，再在另一个终端运行客户端：./client。你将看到通信成功！

其他常用通信模式简介

• PUB/SUB（发布-订阅）：适用于广播消息，如日志收集、实时通知。
• PUSH/PULL（推-拉）：用于任务分发与负载均衡，如并行计算。
• ROUTER/DEALER：更高级的异步通信模式，适合构建代理或网关。

总结

通过本篇ZeroMQ入门指南，你已经掌握了如何在 C++ 中使用 ZeroMQ 构建基本的网络通信程序。无论是构建微服务、分布式系统，还是高性能后端，C++ 消息队列工具 ZeroMQ 都能为你提供强大支持。

记住，ZeroMQ 的核心优势在于其灵活性和轻量级设计。随着你深入学习，你会发现它几乎可以满足任何通信场景的需求。

现在就动手试试吧！更多高级用法可参考官方文档：https://zeromq.org/