Zeromq: Jak uzyskać dostęp do wiadomości tcp w języku C++

Question

Jestem nowicjuszem w ZeroMQ i robię sobie drogę przez przykład hello-world C++ dla wzorca klienta-serwera echa (Request-Reply). Serwer wygląda następująco:

// 
// Hello World server in C++ 
// Binds REP socket to tcp://*:5555 
// Expects "Hello" from client, replies with "World" 
// 
#include <zmq.hpp> 
#include <string> 
#include <iostream> 
#include <unistd.h> 

int main() { 
    // Prepare our context and socket 
    zmq::context_t context (1); 
    zmq::socket_t socket (context, ZMQ_REP); 
    socket.bind ("tcp://*:5555"); 

    while (true) { 
     zmq::message_t request; 

     // Wait for next request from client 
     socket.recv (&request); 
     std::cout << "Received Hello" << std::endl; 

     // Do some 'work' 
     sleep (1); 

     // Send reply back to client 
     zmq::message_t reply (5); 
     memcpy ((void *) reply.data(), "World", 5); 
     socket.send (reply); 
    } 
    return 0; 
} 

Teraz moje pytanie: W jaki sposób można uzyskać dostęp do/czytać prawdziwe dane, które socket.recv()? Próbując:

std::cout << request << std::endl; 

powodowało wyświetlenie komunikatu o błędzie:

error: no match for ‘operator<<’ in ‘std::operator<< [with _Traits = 
std::char_traits<char>](((std::basic_ostream<char, std::char_traits<char> >&) 
(& std::cout)), ((const char*)"Received Hello")) << request’ 

To samo po stronie klienta, który wysyła wiadomość. Nie znaleźć sposób, aby wyświetlić wiadomość prawdziwe ...

Answer 1

Przykład hello world idzie tylko pół drogi i wyprowadza na stałe wartości:

std::cout << "Received Hello" << std::endl; 

Drukowanie rzeczywistą odpowiedź może być wykonane jako to:

zmq::message_t reply; 
socket.recv (&reply); 

std::string rpl = std::string(static_cast<char*>(reply.data()), reply.size()); 

std::cout << rpl << std::endl; 

Istnieje kilka innych przydatnych przykładów w zhelpers.hpp.

Answer 2

okazało się, że po robi to, co chcę:

zmq::message_t request (msglen); 
memcpy ((void *) request.data(), myMessage, msglen); 
char * requestmsg = new char [msglen]; 
memcpy (requestmsg, request.data(), request.size()); 
requestsocket.send (request); 
std::cout << "Sending " << requestmsg << std::endl; 

gdzie msglen jest typu int i myMessage jest const char * tyoe. W ten sposób serwer otrzymuje wiadomość czytelną dla człowieka. Mam nadzieję, że nie jest to sprzeczne z żadnymi regułami zerowymi ...

Answer 3

Chociaż myślę, że musimy przejść przez przewodnik, zanim będziemy mogli pisać eleganckie kody ZeroMQ. Znalazłem linii prostych kodów z Hello World przykład do ekstrakcji danych otrzymanych od gniazda i odesłaniem odpowiedzi:

zmq::message_t request; 
    socket.recv (&request); 
    std::cout << "Received request: [" << (char*) request.data() << "]" << std::endl; 
    // Do some 'work' 
    Sleep (1); 
    // Send reply back to client 
    zmq::message_t reply (6); 
    memcpy ((void *) reply.data(), "World", 6); 
    socket.send (reply); 

Jednak to rozwiązanie nie określa długość odebranych danych, po Nikolai Koudelia powyżej, tworzę ciąg znaków dla otrzymanych danych:

std::cout << "Received request: [" << std::string(static_cast<char*>(request.data()), request.size()) << "]" << std::endl;