我正在尝试使用ZMQ在客户端和服务器之间建立基本的通信系统。我正在使用protobuf作为消息格式。
我的问题是,当我从客户端发送消息时,消息大小为34,但在服务器上收到的消息大小为0。
以下是我的代码;
Client.cpp
tutorial::Person person;
person.set_id(1234);
person.set_name("john");
person.set_email("[email protected]");
person.set_phonenumber("12345678");
zmq::context_t context (1); // Prepare our context and socket
zmq::socket_t socket (context, ZMQ_PAIR);
std::cout << "Connecting to server…" << std::endl;
int linger = 0;// ms
socket.setsockopt(ZMQ_LINGER, &linger, sizeof(linger));
socket.connect ("tcp://127.0.0.1:20000");
std::string msg_str;
person.SerializeToString(&msg_str);
std::cout << "Size of message string is "<< msg_str.size()<<std::endl;
zmq::message_t request (msg_str.size());
memcpy ((void *) request.data (), msg_str.c_str(), msg_str.size());
std::cout << "Sending Person data ..." << std::endl;
socket.send (request);
socket.close();
google::protobuf::ShutdownProtobufLibrary();
return 0;
Server.cpp:
zmq::context_t context(1); // Prepare our context and socket
zmq::socket_t socket(context, ZMQ_PAIR);
int linger = 0; // ms
socket.setsockopt(ZMQ_LINGER, &linger, sizeof(linger));
socket.bind("tcp://127.0.0.1:20000");
while (true)
{
zmq::message_t request;
int recieved = socket.recv(&request);
std::string msg(static_cast<char*>(request.data()),request.size());
std::cout<<"Size of message recieved is "<< msg.size()<<std::endl;
tutorial::Person person;
person.ParseFromString(msg);
std::string text_str1;
google::protobuf::TextFormat::PrintToString(person, &text_str1);
}
socket.close();
客户的输出是:
Size of message string is 34
服务器的输出是:
Size of message received is 0
我也尝试过切换到ParseToArray,但没有帮助。
任何帮助都将受到赞赏。
最佳答案
我用另一种方法解决了。实际上,我之前安装了libzmq lib,但是后来我切换到libzmq3-dev时,它对我有用。
关于c++ - 使用ZMQ和protobuf时接收大小为0的邮件,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/38420559/