Ricezione di messaggi di dimensione 0 durante l’utilizzo di ZMQ e protobuf

Sto cercando di configurare un sistema di comunicazione di base tra client e server usando ZMQ. Sto usando protobuf per il formato del messaggio. Il mio problema è quando invio il messaggio dal client la dimensione del messaggio è 34 ma la dimensione del messaggio ricevuta sul server è 0.

Di seguito è riportato il mio codice;

• ZMQ DEALER - ROUTER Communication
• Errore di epgm ZeroMQ su Linux: protocollo non supportato
• Usando ZeroMQ insieme a Boost :: ASIO
• Come implementare la rete Pub-Sub con un proxy utilizzando XPUB e XSUB in ZeroMQ (C ++)?
• Utilizzo di ZeroMQ in VS2012 C ++

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(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(); 

L’output del client è:

• zeromq con errore di segmentazione protobuf durante l'analisi in c ++
• boost asio deadline_timer async_wait (N secondi) due volte in N secondi causa l'annullamento dell'operazione
• ZMQ C ++ Invia e ricevi da un lavoratore specifico
• Qual è il modo elegante per inviare dati binari serizizzati con i buffer di protocollo di Google in un messaggio ZMQ
• PUB / SUB + PUSH / PULL Messaging Broker - Come migliorare la latenza e le prestazioni?

 Size of message string is 34 

L’output del server è:

 Size of message received is 0 

Ho provato a provare a passare a ParseToArray anche se non ha aiutato. Ogni tipo di aiuto è apprezzato.