使用ZMQ接收消息时，退出循环后第8个消息大小随机异常飙升

问题现象 #

使用ZMQ实现消息接收功能时，退出do-while循环后遍历存储消息的vector，发现第8个消息的大小会变成随机超大值；循环内检查消息大小一切正常，发送端消息也验证无误，关闭未使用消息后仍无法解决问题。

核心原因 #

• zmq_msg_t结构体内部包含指向消息数据缓冲区的指针，默认拷贝构造是浅拷贝：仅复制结构体本身，不会复制底层的消息数据缓冲区。
• 循环中执行messages.push_back(part)后立刻调用zmq_msg_close(&part)，会释放part指向的消息缓冲区，此时vector中存储的副本的指针就变成了野指针。
• 第8个消息才暴露问题是因为vector的扩容机制：默认情况下vector初始容量通常为8左右，前7个元素可能存放在初始分配的内存块中，第8个元素触发扩容时，原内存块的操作导致野指针的访问错误表现得更明显——本质上所有存入vector的zmq_msg_t副本都是无效的。

解决方案 #

思路1：存储消息内容而非zmq_msg_t实例 #

将每个消息段的数据复制到独立容器（如std::string或std::vector<char>）中，脱离ZMQ的消息生命周期管理，彻底避免野指针问题。

修正后的代码示例：

int more;
size_t more_size = sizeof(more);
std::vector<std::string> messages; // 改为存储string类型
int counter = 0;
do {
  zmq_msg_t part;
  rc = zmq_msg_init(&part);
  rc = zmq_msg_init_size(&part, CHUNK_SIZE);
  rc = zmq_msg_recv(&part, clientSocket_, 0);
  assert(rc != -1);

  // 将消息内容复制到string中
  char* data = static_cast<char*>(zmq_msg_data(&part));
  messages.emplace_back(data, zmq_msg_size(&part));

  rc = zmq_getsockopt(clientSocket_, ZMQ_RCVMORE, &more, &more_size);
  assert(rc == 0);
  zmq_msg_close(&part); // 关闭原消息不影响存储的string
} while (more);

for (const auto& msg : messages) {
  std::cout << "message size: " << msg.size() << std::endl;
}

思路2：使用zmq_msg_copy创建独立消息副本 #

如果必须存储zmq_msg_t，需要用zmq_msg_copy创建独立的消息实例存入vector，之后在vector销毁时逐个关闭这些副本。

修正后的代码示例：

int more;
size_t more_size = sizeof(more);
std::vector<zmq_msg_t> messages;
int counter = 0;
do {
  zmq_msg_t part;
  rc = zmq_msg_init(&part);
  rc = zmq_msg_init_size(&part, CHUNK_SIZE);
  rc = zmq_msg_recv(&part, clientSocket_, 0);
  assert(rc != -1);

  // 创建新的zmq_msg_t并复制原消息内容
  zmq_msg_t copied_part;
  rc = zmq_msg_init(&copied_part);
  rc = zmq_msg_copy(&copied_part, &part);
  assert(rc != -1);
  messages.push_back(copied_part);

  rc = zmq_getsockopt(clientSocket_, ZMQ_RCVMORE, &more, &more_size);
  assert(rc == 0);
  zmq_msg_close(&part); // 关闭原消息，副本不受影响
} while (more);

for (zmq_msg_t& msg : messages) {
  std::cout << "message size: " << zmq_msg_size(&msg) << std::endl;
  zmq_msg_close(&msg); // 遍历后关闭每个副本
}

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