从 ZMQ PUB 套接字获取订阅者过滤器
我在FAQ中注意到，在Monitoring section，不可能获取连接的对等点列表或在对等点连接/断开连接时得到通知。 这是否意味着无法知道PUB/XPUB套接字应发布哪些主题的上游反馈？还是有一些方法可以访问这些数据？ 我知道ZMQ >= 3.0 "支持发布者的PUB/SUB过滤"，...
在多个订阅者之间共享RxBindings可观察事件
我正在使用RxBindings库中的Focus Observable来响应焦点变化。由于我想要验证输入并触发动画，所以需要两次焦点事件。Jake Wharton建议在一个observable上进行多个订阅时使用share()操作符。但是如果我在使用share()后操纵observable，第一...
ZeroMQ使用多部分消息的发布/订阅功能无法正常工作
这是我的脚本。 #!/usr/bin/env python import traceback import sys import zmq from time import sleep print "Creating the zmq.Context" context = zmq.Cont...
我应该使用什么？Socket.io房间还是Redis pub-sub？
非常简单的问题。我正在使用nodejs作为后端构建实时游戏，想知道有没有关于哪个更可靠、哪个更高效的信息？我的代码中大量使用了Redis和Socket.io。因此，我想知道我应该使用Socket.io的Rooms还是更好地使用redis的pub-sub? 更新： 我意识到一个非常重要的原因，...
如何使用Faye列出活跃的订阅者？
我正在使用Faye来分发消息，它运行良好。但是我想检索给定频道的活动连接，并且事情的表现有些不同：请参见“列出频道上的活动订阅者”。 我想显示当前在聊天室中聊天的用户列表。我尝试通过扩展程序拦截/meta/subscribe通道来实现这一点，但我不太确定如何向服务器发送像用户名这样的数据。 ...
NServiceBus：无法找到（消息）的元数据。
我正在尝试发布如下消息： _bus.Publish(new BatchCompleted { BatchId = batch.Id}); 并在BatchCompletedHandler中处理它： public class BatchCompletedHandler: IHandleMe...
如何基于用户权限使用Spring-Websocket拒绝主题订阅
我正在实现股票应用程序的一个版本，其中服务器能够根据用户权限拒绝某些主题的订阅。在spring-websocket中有没有这样做的方法？ 例如： 在股票示例项目中，我们有三个工具的价格主题：Apple、Microsoft和Google，并且有两个用户：User1和User2。 User1应该...
Redis发布时没有订阅者
在 Redis 的发布/订阅中，如果在没有订阅者的情况下有数据被发布，则数据会有点丢失。 我希望的是当订阅者订阅时，发布者能够收到通知。 一种方法可能是保持循环发布并在发布者找到至少一个订阅者时中断循环。但我认为那不是一个好方法。（而且我不能保持指数退避）。 while(1) { ...
AWS SNS的延迟和吞吐量是否足够好，可以替代专用的MQ进行发布/订阅？
出于高可用性的考虑，我正在考虑将应用程序中的自托管解决方案（使用ZeroMQ）切换到AWS简单通知服务进行发布/订阅。SNS是应用程序的后端，因此应该具有合理的实时性。 我可以期望SNS的延迟和吞吐量是多少？
没有中介的ZeroMQ发布-订阅+动态发现
我正在测试ZeroMQ作为中型系统的Pub-Sub（服务总线）基础设施。我们大约有50个节点，所有这些节点都应该是发布者和订阅者。网络有点像星形拓扑结构，但边缘之间会“通信”。我们需要动态发现（无需硬编码参与者的网络地址），但也不需要单点故障（SPOF）。 我已经阅读了http://zero...