Я начинаю работать с ZeroMQ и прокладываю себе путь по приветствующему образцу С++ hello-world шаблона echo client-server (Request-Reply). Сервер выглядит так:
//
// 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’
То же самое относится к стороне клиента, которая отправляет сообщение. Я не нашел способ отобразить реальное сообщение...
Пример 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 есть и другие полезные примеры.
Я обнаружил, что следующее делает то, что я хочу:
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;
где msglen имеет тип int, а myMessage - const char * tyoe. Таким образом, сервер получает человекообразное сообщение. Надеюсь, это не против каких-либо правил zeromq...
В то время как я думаю, нам нужно пройти руководство, прежде чем мы сможем написать элегантные коды 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);
Однако это решение не определяет длину полученных данных, следуя примеру Николая Коуделии выше, я делаю строку для полученных данных:
std::cout << "Received request: [" << std::string(static_cast<char*>(request.data()), request.size()) << "]" << std::endl;