Zeromq: Wie der Zugriff auf tcp-Nachricht in c++

Ich bin ein neues zu ZeroMQ und meinen Weg durch die C++ - hello-world-Beispiel des echo-client-server-Muster (Request-Reply). Der server sieht wie folgt aus:

//
//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;
}

Nun meine Frage: Wie kann ich den Zugriff /Lesen Sie die realen Daten, die Buchse.recv() ? Versuch:

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

führte zu einer Fehlermeldung:

 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’

Das gleiche gilt für die client-Seite, die die Nachricht sendet. Ich nicht finden, eine Weg, um die wahre Botschaft...

  • Ich glaube, der ZeroMQ Dokumentation-Beispiele in C++. Haben Sie schaute auf die?
  • Du hast Recht, es ist ein Eintrag für zmq_msg_data, der sagt: "Die zmq_msg_data () - Funktion wird wieder ein Zeiger auf den Inhalt der Nachricht des message-Objekts verwiesen wird, die von msg." Aber wie mache ich das explizit?
  • Nein, ich meine die Guide ist voll von C++ code-Beispiele.
  • Ich lese die Anleitung, aber leider ist es nicht das, was ich Suche...
  • hast du den guide gelesen ? Wenn Sie haben, dann würden Sie erkennen an den oben genannten code als aus dem Reiseführer. Dort sagt man einfach "empfangen Hallo", anstatt wirklich nach dem Lesen der Nachricht, die gesendet wurde. Ich habe tatsächlich kommen hier für die sehr gleiche Frage wie der OP.
InformationsquelleAutor dhpizza | 2012-06-05
  1. 37

    Dem hello world Beispiel geht nur den halben Weg und Ausgänge der hart codierte Werte:

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

    Drucken der aktuellen Reaktion kann wie folgt erledigt werden:

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

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

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

    Es gibt einige andere Beispiele in zhelpers.hpp.

    • Schöne erste Antwort @NikolaiKoudelia.
    • verwenden Sie c-Bindung der zmq (cppzmq) oder die zmq ohne Bindung?
    • Ja, die Bindung (zmq.hpp) benötigt wird.
    • Sehr nette Antwort!
    InformationsquelleAutor Nikolai Koudelia
  2. 1

    Fand ich, dass das folgende tut was ich will:

    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;

    wo Sie für msglen ist vom Typ int und myMessage ist const char * tyoe.
    Auf diese Weise erhält der server eine lesbare Nachricht.
    Hoffe das ist nicht gegen irgendwelche zeromq Regeln...

    • Da du in C++, warum keine strings ? Ich meine, char* sind nur Schmerzen, es sei denn, Sie wirklich brauchen, Sie aus unerfindlichen Gründen (andere Bibliotheken, zum Beispiel).
    InformationsquelleAutor dhpizza
  3. 1

    Während ich denke, wir müssen gehen durch die Führung, bevor wir schreiben können elegante ZeroMQ-codes. Ich fand Zeilen einfach die codes aus den HALLO WELT Beispiel für das extrahieren von empfangenen Daten aus dem socket und sendet Antwort zurück:

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

    Diese Lösung allerdings nicht angeben, die Länge der empfangenen Daten, folgende Nikolai Koudelia's Weg oben habe ich einen string für empfangene Daten:

     std::cout << "Received request: [" << std::string(static_cast<char*>(request.data()), request.size())  << "]" << std::endl;
    InformationsquelleAutor Wenbo Li
Schreibe einen Kommentar