理解Celluloid并发性
以下是我的Celluloid代码。client1.rb 其中一个客户端。(我将其命名为客户端1)client2.rb 这是另外一个客户端。(命名为客户端2)注意:以上两个客户端之间唯一的区别是发送给服务器的文本。(分别为'client-1'和'client-2')当我对这两个客户端进行测试(同...
使用Pub/Sub（Java绑定）的ZeroMQ主题过滤
我该如何让ZeroMQ支持主题和模式匹配？ 例如：stocks.* stocks.appl 根据我理解的 ZeroMQ.. 主题将成为消息的一部分，所以我需要某种方式来将主题与订阅者实际接收到的消息分开。 分离主题和消息的最佳方法是什么？是否需要使用特殊字符（例如 SOH）？
ZMQ轮询不起作用。
当我运行以下代码时，第一次调用` zmq_poll`时出现错误（即返回 `-1`）。 `zmq_errno()` 返回 `128` 并且 `zmr_strerror(128)` 调用返回 `"未知错误"`。 我已经使用C++和ZMQ有一段时间了，没有任何问题，但是无论多么简单，我都无法使`zm...
zmq poller是如何工作的？
我很困惑关于zmq中的poller是做什么用的。《zguide》只是简要介绍了它作为从多个套接字中读取的一种方式。这对我来说不是一个令人满意的答案，因为它没有解释如何有超时套接字。 我知道zeromq: how to prevent infinite wait? 对push/pull模式进行了...
零MQ上下文背后的原理是什么？
在浏览ZeroMQ（一个非常有用的套接字替代品，如果你不知道）时，我在邮件列表中发现了这个问题： 使用多个上下文：使用多个上下文有什么缺点？ 使用多个上下文是否有缺点？ 我有一个类包装器，我希望尽可能保持简单。 我可以修改它以允许在单个上下文下进行多个...
ZeroMQ：如何防止无限等待？
我刚开始使用ZMQ。我正在设计一个应用程序，其工作流程如下: 众多客户端（随机PULL地址）之一向5555的服务器推送请求 服务器永远在等待客户端推送。当有一个推送到来时，就会为该特定请求生成一个工作进程。是的，工作进程可以同时存在。 当该进程完成任务后，它会向客户端推送结果。 我认为...
检测ZeroMQ队列中丢失的消息
由于似乎无法查询/检查底层ZeroMQ队列/缓冲区套接字的利用率，因此是否有一种方法可以在发布者套接字发送/排队时检测到由于完整的缓冲区而丢弃消息的情况? 例如，如果发布者队列已满，则 zmq_send 操作将简单地丢弃该消息。 基本上，我想实现的是一种检测队列紧张和/或充满的情况的方法，...
RX 和 RabbitMQ 或 ZeroMQ 这样的消息队列相比有什么优劣之处？
我对这些高级并发范式还比较新，我开始使用scala RX绑定。所以我试图了解RX与RabbitMQ或ZeroMQ等消息队列的区别。 它们都似乎使用订阅/发布范例。在某个地方，我看到了一条关于RX在RabbitMQ之上运行的推文。 有人能解释一下RX和消息队列之间的区别吗？为什么我要选择一个...