16

私は ZeroMQ の初心者であり、エコー クライアント サーバー パターン (Request-Reply) の C++ の hello-world の例に取り組んでいます。サーバーは次のようになります。

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

ここで私の質問: socket.recv() という実際のデータにアクセス/読み取るにはどうすればよいですか? しようとしている：

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

エラーメッセージが表示されました：

 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’

メッセージを送信しているクライアント側にも同じことが言えます。本当のメッセージを表示する方法が見つかりません...

4

3 に答える 3

45

hello worldの例は途中までしか進んでおらず、ハードコードされた値を出力します。

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

実際の応答の印刷は、次のように実行できます。

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

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

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

zhelpers.hppには他にもいくつかの便利な例があります。

于 2012-06-10T07:35:35.587 に答える
1

エレガントなZeroMQコードを書く前にガイドを読む必要があると思います. ソケットから受信したデータを抽出して応答を返すためのHELLO WORLDの例から、単純なコードの行を見つけました。

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

ただし、このソリューションは受信データの長さを指定していません。上記のNikolai Koudeliaの方法に従って、受信データの文字列を作成します。

 std::cout << "Received request: [" << std::string(static_cast<char*>(request.data()), request.size())  << "]" << std::endl;
于 2016-03-28T06:48:16.207 に答える