如何高效将cppzmq message_t移至后台线程队列？

你遇到的错误根源是**zmq::message_t的拷贝构造函数被显式删除**（代码中的ZMQ_DELETED_FUNCTION标记）——这是ZeroMQ的设计决定，目的是避免无意义的消息数据拷贝。如果你的ZeroMQ版本较旧，可能还未实现移动构造/赋值运算符，导致即使使用std::move，编译器仍会尝试调用被禁用的拷贝构造函数，最终触发报错。另外你的代码存在笔误：qu.push(std::move(message));中的message应为msg。

高效无复制的实现方案 #

1. 升级ZeroMQ版本（推荐）

从libzmq 4.3.x版本开始，zmq::message_t已完整支持C++11移动语义。升级后修正代码笔误，即可直接用std::move转移消息所有权，完全不涉及数据复制：

std::queue<zmq::message_t> qu;
zmq::message_t msg;
zmq::recv_result_t res = sock.recv(msg, zmq::recv_flags::none);
qu.push(std::move(msg)); // 修正变量名，通过std::move转移消息所有权

2. 用智能指针包裹消息（兼容旧版本）

若无法升级ZeroMQ，可使用std::unique_ptr包裹zmq::message_t，队列存储智能指针，通过转移指针所有权实现无复制传递：

#include <memory>
#include <queue>
#include <zmq.hpp>

std::queue<std::unique_ptr<zmq::message_t>> qu;

// 接收线程逻辑
auto msg = std::make_unique<zmq::message_t>();
zmq::recv_result_t res = sock.recv(*msg, zmq::recv_flags::none);
qu.push(std::move(msg)); // 转移unique_ptr所有权，无数据复制

// 后台处理线程逻辑
auto msg_to_process = std::move(qu.front());
qu.pop();
// 通过*msg_to_process访问并处理消息

3. 用ZeroMQ原生inproc套接字传递（最符合ZeroMQ设计）

ZeroMQ本身提供了线程间消息传递的原生方案——inproc套接字，它线程安全且无数据复制（ZeroMQ内部直接转移消息缓冲区所有权），无需手动维护队列：

#include <zmq.hpp>

// 线程间共享的context
zmq::context_t context(1);

// 接收线程：绑定inproc套接字
zmq::socket_t receiver(context, zmq::socket_type::pull);
receiver.bind("inproc://thread_msg_queue");

// 后台处理线程：连接到inproc套接字
zmq::socket_t worker(context, zmq::socket_type::pull);
worker.connect("inproc://thread_msg_queue");

// 接收线程逻辑
while (true) {
    zmq::message_t msg;
    receiver.recv(msg, zmq::recv_flags::none);
    // 直接转发给处理线程，无数据复制
    worker.send(std::move(msg), zmq::send_flags::none);
}

// 后台处理线程逻辑
while (true) {
    zmq::message_t msg;
    worker.recv(msg, zmq::recv_flags::none);
    // 处理消息
}

关于你的疑问 #

zmq::message_t确实持有堆上分配的消息数据，析构时会自动释放，但早期版本的ZeroMQ未实现移动语义，无法通过std::move转移数据所有权；而拷贝构造被删除，是为了强制开发者避免低效的数据拷贝操作，引导使用更高效的所有权转移方式。

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