ZMQ PUB-SUB套接字连接异常：发布端发消息订阅端无接收

我正在开发一个通过ZMQ套接字连接两个终端的项目，采用PUB-SUB模式，但发布端能发送消息，订阅端始终无法接收。尝试过更换IP地址、强制发送消息均无效。

简化后的代码如下：

Server.cpp #

#include <zmq.h>

const char* C_TO_S = "tcp://127.0.0.1:5557";
const char* S_TO_C = "tcp://127.0.0.1:5558";

int main() {
  zmq::context_t context(1);
  zmq::socket_t pub(context, ZMQ_PUB);
  zmq::socket_t sub(context, ZMQ_SUB);

  int sndhwm = 0;

  sub.connect(C_TO_S);
  pub.bind(S_TO_C);
  sub.setsockopt(ZMQ_SUBSCRIBE, &sndhwm, sizeof(sndhwm));

  while(true) {
    zmq::message_t rx_msg;
    sub.recv(&rx_msg);
    cout << "b\n";
    // 其他代码
  }
}

Client.cpp #

#include <zmq.h>

const char* C_TO_S = "tcp://127.0.0.1:5557";
const char* S_TO_C = "tcp://127.0.0.1:5558";

void network_thread() {
  zmq::context_t context(1);
  zmq::socket_t pub(context, ZMQ_PUB);
  zmq::socket_t sub(context, ZMQ_SUB);

  int sndhwm = 0;

  sub.connect(S_TO_C);
  pub.connect(C_TO_S);
  sub.setsockopt(ZMQ_SUBSCRIBE, &sndhwm, sizeof(sndhwm));

  while (true) {
    cout << pub.send("a", strlen("a"), 0);
    cout << "AA\n";
  }
  
  // 无关代码省略
}  

客户端主函数会在单独线程中调用network_thread，持续向服务器发送消息"a"，但服务器从未收到（收到会打印"b"）。确认发布端能发送消息（执行时输出"1"）。客户端订阅端和服务器发布端同样无法工作，解决一组问题即可类推解决另一组。试过更换端口、频繁发送消息等方法，均未解决，求帮助。

1. 订阅过滤器完全不匹配 #

你的代码中错误地将整数sndhwm的内存作为订阅过滤器传递给ZMQ_SUBSCRIBE，但PUB-SUB的订阅逻辑是匹配消息的前缀：

• 你发送的消息是字符串"a"（二进制为0x61）
• 订阅的过滤器是4字节的整数0（二进制为0x00 0x00 0x00 0x00）

两者没有任何匹配关系，所以订阅端会直接丢弃所有收到的消息。

修正方式： #

如果要接收所有消息，设置空过滤器：

sub.setsockopt(ZMQ_SUBSCRIBE, "", 0);

如果只接收前缀为"a"的消息，设置对应字符串作为过滤器：

const char* filter = "a";
sub.setsockopt(ZMQ_SUBSCRIBE, filter, strlen(filter));

2. PUB端连接未建立就发送消息 #

ZMQ的PUB套接字在刚完成connect后，需要短暂时间建立TCP连接和ZMQ内部的订阅关系，此时发送的消息会被直接丢弃。

修正方式： #

在客户端连接PUB套接字后添加短暂延迟：

pub.connect(C_TO_S);
zmq_sleep(1); // 等待1秒确保连接建立，需包含<zmq.h>

3. 额外优化建议 #

• 一个进程内最好复用同一个zmq::context_t，不要每个线程创建新的context，这是ZMQ的推荐做法。
• 检查防火墙是否拦截了5557、5558端口的TCP流量。
• 确保两端使用的ZMQ版本一致，避免兼容性问题。

内容的提问来源于stack exchange，提问作者lapassey