如何在C++中使用 ZeroMQ 发送包含数组的结构时解决错误
How to solve an Error while sending a structure containing an array using ZeroMQ in C++
客户端向服务器发送一个结构(包含数组)十次。服务器的工作是接收此结构并打印它。但它只接收一次结构并打印它并退出,给出此错误
"terminate called after throwing an instance of 'zmq::error_t'
"。
这是客户端C++代码:
#include <zmq.hpp>
#include <string.h>
#include <stdio.h>
#include <unistd.h>
#include <sys/socket.h>
#include <zmq2.h>
#include "structure.h"
int main (void)
{
int flags=0,value,buffer[10];
printf ("Connecting to hello world server…n");
void *context = zmq_ctx_new ();
void *requester = zmq_socket (context, ZMQ_REQ);
zmq_connect (requester, "tcp://localhost:5555");
for(int i=0;i!=10;i++)
{
msg.arr[i]=i;
}
for(int i=0;i!=10;i++)
{
printf ("Sending Hello %d…n", i);
zmq_send(requester,&msg, sizeof(Message),0);
}
zmq_close (requester);
zmq_ctx_destroy (context);
return 0;
}
这是服务器C++代码:
#include <stdint.h>
#include "structure.h"
#include "zmq.hpp"
#include <string>
#include <iostream>
#include <unistd.h>
int main () {
int val;
zmq::context_t context (1);
zmq::socket_t socket (context, ZMQ_REP);
socket.bind ("tcp://*:5555");
while(true)
{
Message* msg;
zmq::message_t zmsg;
socket.recv(&zmsg);
msg = (Message*)zmsg.data();
for(int i=0;i<10;i++)
{
std::cout<<msg->arr[i]<<std::endl;
}
sleep(1);
}
return 0;
}
这是structure.h
struct Message
{
int arr[10];
}msg;
如何从服务器端接收所有十个结构并打印收到的十个结构?
提前谢谢。
最好使用 XREQ/XREP 的 PUSH/PULL,
因为原始的 REP/REQ 强制执行严格的 .send()-.recv()-.send()-.recv()
- 链...如果您的需求与上面所说的完全一致,那么只需更改 ZeroMQ 可扩展形式通信原型模式就足够了。
如果您选择尽可能接近REQ/REP
"相似性",请使用XREQ/XREP
,如果有更多话要说并计划进一步扩展分布式信令/消息传递服务基础设施,最好使用串联单向软管C->S
+S->C
使用一对PUSH/PULL
+PUSH/PULL
。
如果消息传递范式可以只使用一对独占的节点,则PAIR/PAIR
可能是一种选择,其中PAIR/PAIR
(如实现的那样)不提供以后扩展到.connect()
N:1
或1:M
或N:M
对等节点框架的方法。
相关文章:
- 将包含C样式数组的对象初始化为成员变量(C++)
- C++ 打印包含数据结构的数组
- 通过分隔符分隔包含 UTF-16 BE 文本的uint8_t数组
- 包含作为成员C++函数的结构数组
- 循环访问还包含未使用元素的字符串数组
- C++两个对象,其中包含指向同一数组不同部分的指针
- 查找包含 N 个元素的数组的最小值和最大值
- 无法将字符数组转换为包含 utf-8 字符的字符串
- 常量数组如何在每个元素中只能包含字符,而 char* 数组能够指向每个元素中的字符串?
- 我怎么知道数组包含多少个元素C++?
- 返回一个数组,该数组包含数组中的数量,该数组数量较小或等于给定数组中的元素
- 字符串的变体数组包含替代空间
- C++ -- 指向结构数组的指针,该数组包含指向不起作用的类数组的指针
- 返回连续数字的逻辑假设数组包含元素 1,9,2,3,4,9,6,7,8,那么它应该返回 2,3,4,6,7,8
- 声明一个类型为String的数组,该数组包含带填充的数字
- 如何使数组包含从基类继承的类
- 当用c++编写数组时,我尝试将数组包含到另一个类中,但不起作用
- 为什么这个字符数组包含未填充的内存
- 函数数组包含来自不同对象的函数
- 成员数组包含类的实例。无法决定在哪里放置修改此类变量的方法