22得票4回答
ZeroMQ消息大小长度限制?

假设有多台机器正在使用Python的ZeroMQ客户端进行交互。 这些消息自然地被格式化为字符串。 是否存在消息(字符串)长度的限制?

22得票1回答
为什么/何时使用DDS而不是ZeroMQ?

我阅读了以下内容: DDS vs AMQP vs ZeroMQ http://mnb.ociweb.com/mnb/MiddlewareNewsBrief-201004.html 看起来使用ZMQ没有使用DDS更好: ZMQ的延迟更低。 对我来说,ZMQ的API更加清晰简洁。 我不...

22得票1回答
AWS SNS的延迟和吞吐量是否足够好,可以替代专用的MQ进行发布/订阅?

出于高可用性的考虑,我正在考虑将应用程序中的自托管解决方案(使用ZeroMQ)切换到AWS简单通知服务进行发布/订阅。SNS是应用程序的后端,因此应该具有合理的实时性。 我可以期望SNS的延迟和吞吐量是多少?

22得票1回答
ZeroMQ和Python中的多个订阅过滤器

我想在Python中使用一个套接字订阅多个ZeroMQ过滤器。sock.setsockopt(zmq.SUBSCRIBE, 'first.filter') sock.setsockopt(zmq.SUBSCRIBE, 'second.filter') 但是这并不起作用。只有第一个被考虑。然而,...

21得票3回答
理解zeromq的Java绑定

我正在调查使用zeromq作为Java项目中的消息传递解决方案,但我发现有关Java绑定的说明有些难以理解。 http://www.zeromq.org/bindings:java 我不熟悉Java绑定,因此可能会有一些愚蠢的问题,请有人帮我理解: 为什么需要安装任何东西? 在一个机器上...

21得票3回答
Python + ZMQ:无法在当前状态下完成操作

我正在尝试使用请求-响应模式通过zeromq使python程序与另一个python程序通信。客户端程序应该向服务器程序发送请求,后者进行回复。 我有两个服务器,当其中一个服务器出现故障时,另一个服务器接管。当第一个服务器工作时,通信完美运行,但是当第一个服务器失败并且我向第二个服务器发出请求...

20得票3回答
0MQ:如何以线程安全的方式使用ZeroMQ?

我阅读了ZeroMq指南,并遇到以下内容: 您绝不能在线程之间共享ØMQ套接字。ØMQ套接字不是线程安全的。从技术上讲,这是可能的,但它需要使用信号量、锁或互斥体。这将使您的应用程序变得缓慢和脆弱。唯一一个合理地在线程之间共享套接字的地方是语言绑定需要对套接字进行垃圾回收等魔法的地方。 ...

20得票6回答
如何安全地让ZeroMQ工作进程“挂断”?

本周我开始使用ZeroMQ,在使用请求-响应模式时,我不确定如何让工作者安全地“挂起”并关闭他的套接字,而不会丢掉消息并导致发送该消息的客户永远无法获得响应。假设一个用Python编写的工作者如下:import zmq c = zmq.Context() s = c.socket(zmq.RE...

20得票5回答
在Ubuntu上编译JZMQ

大家好,我正在尝试按照以下地址的说明进行操作:https://github.com/nathanmarz/storm/wiki/Installing-native-dependencies,在Ubuntu 12.04机器上安装Zero MQ以作为Storm的依赖。但是,在运行make命令时,我...

20得票2回答
Redis集群与ZeroMQ在Pub/Sub中的比较,用于水平扩展的分布式系统

如果我要设计一个巨大的分布式系统,其吞吐量应该与系统中的订阅者数量和频道数量成线性比例增长,那么哪个更好呢? 1)Redis Cluster(仅适用于 Redis 3.0 alpha 版本,如果它处于集群模式下,则可以在一个完全不同的节点发布并在另一个节点中订阅,消息将传播并到达您)。发布的...