Zeromq:如何在 c++ 中访问 tcp 消息
Zeromq: How to access tcp message in c++
我是 ZeroMQ 的新手,并介绍了 echo 客户端-服务器模式(请求-回复)的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’
发送消息的客户端也是如此。我找不到显示真实消息的方法...
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。通过这种方式,服务器接收人类可读的消息。希望这不违反任何零mq规则...
虽然我认为我们需要先阅读指南,然后才能编写优雅的 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;
相关文章:
- 通过方法访问结构
- 使用不带参数的函数访问结构元素
- 如果我只是不访问queue_front节点的子节点,而是将它们推到队列中呢?还是BFS吗
- 用于访问容器<T>数据成员的正确 API
- 访问者访问变体并返回不同类型时出错
- 尝试通过多个向量访问变量时,向量下标超出范围
- 无法访问嵌套类.类的使用无效
- 写入位置0x0000000C时发生访问冲突
- 我们可以访问一个不存在的联盟的成员吗
- C++从另一个类访问公共静态向量的正确方法是什么
- 我的简单if-else语句是如何无法访问的代码
- 从C++dll访问C#中的一行主要参数
- TCP/IP 客户端是否可以连接到无法访问的 IP
- 接收音频块的异步TCP服务器会出现访问违规错误
- libtorrent和tcp ::受体在Windows上崩溃并违反访问
- 提升 Asio tcp::接受者访问冲突异常
- Zeromq:如何在 c++ 中访问 tcp 消息
- 提升连接后从TCP服务器访问TCP客户端IP地址+端口
- 如何访问tcp标头详细信息
- 删除 ssl::stream<ip::tcp::socket>* sslSocket 时提升访问冲突