zeromq相关内容
我需要使用ZeroMQ推拉式套接字模式在C ++中编写一个客户端 - 服务器应用程序。客户端必须对服务器接口中指定的函数进行RPC调用。我不知道是否有一个开源和商业可用的库/框架为此目的主要是在C ++。我做了一些googling,似乎有些事情写在python,但我喜欢在C + +如果可能的话,ZeroMQ方便。任何建议/指导是赞赏。谢谢。 解决方案 Thrift RPC框架与ZeroMQ
..
说明: 我有一个名为 GenericMessage 的C ++类,它只保存ID和数据成员(见下面的代码片段1 - GenericMessage.hxx)。我的目的是序列化这个类的实例,并通过实现推式模式的ZeroMQ套接字发送它。 序列化和发送任务已在类ZMQHandler (请参阅sendToBE函数)中实现,它放在头文件名ZMQHandler.hxx中在下面的代码段2 中。此类通过
..
对于自定义服务器,我打算使用 int zmq :: poll(zmq_pollitemt_t * items , int nitems,long timeout = -1) 。函数,我认为是unix轮询函数的包装,但包括 zmq :: socket_t 旁边的文件描述符。该函数按我的预期工作,直到我按ctrl + x或在终端中运行 $ kill my_server_pid 。我希望调查以-1或者抛
..
请考虑下面的示例代码(我以一个例子快速键入它,如果有错误没关系 - 我对理论感兴趣)。 bool shutDown = false; // global int main() { CreateThread(NULL,0,& MessengerLoop,NULL,0,NULL); //做其他程序的东西... } DWORD WINAPI MessengerLoo
..
我想使用ZeroMQ在C ++中实现服务器/客户端交互( http://zeromq.org/ ) 。 我的要求是实现一个函数,其中如果客户端向服务器发送请求,则服务器应该将多个数据(按顺序)发送回客户端。 ZeroMQ规定了像req-res,pub-sub这样的模型,推拉,但这不支持我的要求,因为: 1)Req-rep模式总是期望一个返回消息,即它被设计为发送和接收的组合
..
我需要在ZMQ套接字上发送一个对象(用GPB序列化)。目前代码有一个额外的副本。如何直接将序列化数组写入 message_t 的数据? ABT_CommunicationProtocol introPacket; //填充数据包 message_t introMessage; size_t dataLenght = introPacket.ByteSize(); char *
..
请考虑下面的示例代码(我以一个例子快速键入它,如果有错误没关系 - 我对理论感兴趣)。 bool shutDown = false; // global int main() { CreateThread(NULL,0,& MessengerLoop,NULL,0,NULL); //做其他程序的东西... } DWORD WINAPI MessengerLoo
..
我需要在ZMQ套接字上发送一个对象(用GPB序列化)。目前代码有一个额外的副本。如何直接将序列化数组写入 message_t 的数据? ABT_CommunicationProtocol introPacket; //填充数据包 message_t introMessage; size_t dataLenght = introPacket.ByteSize(); char *
..
我想在Linux(服务器)主机上的一个应用程序与虚拟机中Win7(客户端)上的应用程序通信。选择的是ZeroMQ。但是如何管理异步任务? 让我举个例子: VM中的应用程序以任意间隔生成任务并将其发送到Linux框。这将处理它们,但需要一些时间来回答。此时,REQ / REP模式中的套接字被阻止,并且来自WinApp的传入任务无法转发到LinuxApp。我应该如何解决这个问题?这是如何解决,
..
我正在寻找ZeroMQ,看看它是否适合软实时应用程序。我非常高兴地看到小有效载荷的延迟在30微秒左右的范围内。 我有一个简单的发布商和订阅者,基本上是从网络上的例子复制而来,通过localhost发送一个字节。 我玩了两天w /不同 sockopts m出去。 任何帮助将不胜感激。 pub #include #include
..
我想在Linux(服务器)主机上的一个应用程序与虚拟机中Win7(客户端)上的应用程序通信。选择的是ZeroMQ。但是如何管理异步任务? 让我举个例子: VM中的应用程序以任意间隔生成任务并将其发送到Linux框。这将处理它们,但需要一些时间来回答。此时,REQ / REP模式中的套接字被阻止,并且来自WinApp的传入任务无法转发到LinuxApp。我应该如何解决这个问题?这是如何解决,
..
我想在Linux(服务器)主机上的一个应用程序与虚拟机中Win7(客户端)上的应用程序通信。选择的是ZeroMQ。但是如何管理异步任务? 让我举个例子: VM中的应用程序以任意间隔生成任务并将其发送到Linux框。这将处理它们,但需要一些时间来回答。此时,REQ / REP模式中的套接字被阻止,并且来自WinApp的传入任务无法转发到LinuxApp。我应该如何解决这个问题?这是如何解决,
..
我试图通过ZMQ通过网络发送一个相当大的Flatbuffers对象,然后使用C + +读取它。当访问对象时,我得到未处理的异常,我不知道如何解决。即使此最小示例失败: flatbuffers模式: 命名空间平缓 table TestBuf { testStatus:bool; testNumber:double; testInt:int; } root_type Te
..
我是ZeroMQ的新手,通过echo客户端 - 服务器模式(请求 - 回复)的C ++ hello-world示例。服务器如下: // // C ++中的Hello World服务器 //绑定REP socket to tcp:// *:5555 //从客户端预期“Hello”,回复“World” // #include #include
..
我想要的是当一个消息队列接收到一个int N,处理函数将在N秒后被调用。 如果两个附近消息队列的持续时间秒大于int N,它运行OK,但处理程序将在一个窗口中打印“操作已取消”处理程序,当两个接收到的消息队列之间的持续时间秒小于N,这不是我想要的。 我非常感谢任何帮助。 > #include #include #in
..
我想实现一个简单的消息使用NetMQ(下面我想达到什么是一个稍微更详尽的描述)。结果 位试验和错误我后两个应用程序之间传递已经发现我不能只是发送或接收邮件马上a连接/绑定来电之后,因为它们是非阻塞,实际上即使连接尚未建立回报。结果 。对于现在的我与Thread.sleep()方法解决了这个,但是这有一个不好的味道吧,绝对无去生产系统。 所以,问题是,怎样的One应该做它NetMQ / Z
..
我有一个中等规模的网络上的简单的发布 - 订阅设置,使用ZMQ 2.1。虽然有些用户正在使用C#绑定,别人都在用Python绑定,而我遇到的问题是不是一样的。 如果我拉网线从机中运行的用户,我得到一个未开捕错误立即终止该订户。 下面是用Python(而不是实际的生产代码,但足以重现该问题)用户的一个非常简单的例子: 进口ZMQ DEF主(服务器地址,端口): =背景
..
我请求进来为不同的样品(S1,S2,..)需要以线性方式进行处理(即,只有一个说在时刻S1-请求可以被处理)。我有工作人员服务,可以处理请求给予N个。我如何能实现RPC的队列模式,使得样品消耗一个在时间和仍然允许不同样本之间计算的分配? 我想与实现这一兔MQ因为它的简单性,群集功能,但我愿意考虑其他的解决方案也是如此。 下面是说明问题(有两名工人图片) 工人1 + -----
..
场景 我试图发送一个数据(比如字符串从通过ZeroMQ C#сonsole应用的Node.js服务器类型) 信息: 使用C#的clrzmq和ZeroMQ库为C#和Node.js的分别为 我能够执行的从Node.js的推拉,也的推 - 拉从C# 所以,有一件事是证实 ZeroMQ - 的智能交通层是安装在机器上(Windows 7的64位) 问题 我不能够从
..
我使用Xamarin Studio中的Mac上,是 clrzmq 通过的NuGet。 clrzmq上libzmq.dll引用包括在内。我的应用程序编译罚款,但是当我尝试运行它,我得到这样的: 未处理的异常: 系统。 DllNotFoundException:在libzmq (包装管理到本机)ZMQ.C:在ZMQ.Context..ctor(的Int32 io_threads)[0x0
..