c++ - 零 MQ 发布者订阅者(发布/订阅)

Question

我已经实现了一个简单的发布/订阅示例。我正在发送一个简单的问候消息并尝试在订阅者处接收它。我的发布者代码是 -

std::string msg = "hello,";
zmq::message_t message(static_cast<const void*> (msg.data()), msg.size());
publisher.send(message);

我的订阅者代码 -

zmq::message_t msgReceive;
subscriber.recv(&msgReceive);   
const char* buffer_body = static_cast<const char*>(msgReceive.data());
printf("Message: %s\n",buffer_body);

我得到的输出是 - “你好，套接字类型”而不是“你好”，

我无法弄清楚错误在哪里。任何帮助，将不胜感激。

Answer 1

尝试改变这一行

const char* buffer_body = static_cast<const char*>(msgReceive.data());

到

const char* buffer_body = static_cast<const char*>(msgReceive.data(), msgReceive.size());

这样您就可以根据消息的长度告诉 C_String 在何处终止，而不是让它在找到第一个空字符时自行终止。

有关详细信息，请参阅 the guide .