【发布时间】:2014-09-03 05:21:16
【问题描述】:
我正在开发一个使用 cppZmq 绑定的本机应用程序。我的消息代理从 ZMQ_ROUTER 读取消息,并在应用一些负载平衡逻辑后将它们转发到另一个 ZMQ_ROUTER。我使用一个 message_t 类来接收数据(它在内部只是用 zmq_msg_t 结构调用 zmq_recv)。
在我的轮询循环中,我可以使用 message_t 变量(在循环外分配的堆栈)接收消息,转发到套接字,然后在循环的下一次迭代中使用相同的 message_t 变量接收另一条消息吗?或者,我应该在轮询循环内部堆栈分配 message_t 变量吗?换句话说,在使用相同的 zmq_msg_t 变量执行 zmq_recv 之前,必须再次 zmq_close 一条消息、zmq_msg_init 吗?这可能没有可衡量的性能考虑,但目标是在开发周期的后期做正确的事情以避免错误。
另外,我可以从一个套接字获取一个 zmq_msg_t 结构并将其转发到另一个套接字而不创建新的消息结构,并对它执行 zmq_msg_copy 吗?
【问题讨论】: