我为一个简单的场景编写了一个小测试： 一个发布者和一个订阅者 发布者发送1000000条消息 订阅者接收到这1000000条消息 使用 RabbitMQ，fanout 交换机，RabbitMq 节点类型 Ram 进行第一次测试：320 秒 使用 Redis，基本的 pub/Sub 进...

我一直在尝试不同的NodeJS发布/订阅实现，并且想知道哪种适合特定的应用程序。该应用程序的要求包括多通道、多用户3D环境中对象的实时同步。 我开始使用socket.io，创建了一个基本的频道数组，当用户发送消息时，它会循环遍历相应频道的用户并向用户客户端发送消息。这个方法效果很好，没有出现...

背景 我正在制作一个发布/订阅的典型应用程序，其中发布者向消费者发送消息。 发布者和消费者位于不同的机器上，它们之间的连接偶尔会断开。 目标 这里的目标是确保无论连接或机器发生什么事情，发布者发送的消息始终被消费者接收。 消息的排序并不是必须的。 问题 根据我的研究，Rabbit...

目前我使用RPC调用通过TCP与另一个微服务通信并获取响应，但我认为可以这样做： 不进行RPC调用，我能否使用发布/订阅来发送到一个服务，发布一些类似于request_user的频道，并订阅像object_user_response这样的频道，然后另一个已订阅此request_user的服务...

我正在寻找一个pub/sub引擎，需要满足以下要求： 非常低的延迟 < 0.5 秒 可扩展性强 可分片（基于地理位置） 我希望能够有多个pub/sub服务器，并且能够从任何服务器发布或订阅频道，无论在哪个服务器上声明了该频道。 例如： 如果用户A连接到服务器SRV1，而用户B...

我正在尝试构建一个物联网+数据分析系统，但我很难决定使用什么技术或服务进行摄取。最终目标的高级描述如下： 1. 物联网设备将数据推送到物联网网关（使用Zigbee、Z-wave、蓝牙等）。 2. 物联网网关（连接到互联网）将数据推送到发布/订阅系统。 3. 后端服务处理从发布/订阅系统输出的...

非常简单的问题。我正在使用nodejs作为后端构建实时游戏，想知道有没有关于哪个更可靠、哪个更高效的信息？我的代码中大量使用了Redis和Socket.io。因此，我想知道我应该使用Socket.io的Rooms还是更好地使用redis的pub-sub? 更新： 我意识到一个非常重要的原因，...

我一直在使用Angular并试图找到一种方法来跨整个组件树使用发布/订阅机制。 似乎EventEmitter只能发出一个事件，可以订阅到上一级 - 但不能更多。同样，它只向上树传播事件，而不是向下传播。 相关代码在此: plunker class App { onAncestor...

在尝试深入了解Kafka分布式模型时，来自StackOverflow的一句话让我热血沸腾，但我无法得到确认或否认。 引用如下： 所以，你拥有的订阅组越多，性能就越低，因为kafka需要将消息复制到所有这些组并保证其总体顺序。 就我从Kafka文档中理解的而言，多个消费者组类似于单个消费者...

我已经使用Kafka几个月了，但我意识到一些核心概念对我来说还不是很清楚。我的疑问与consumerId、groupId和offsets之间的关系有关。在我们的应用程序中，我们需要使用发布-订阅范例来使用Kafka，因此我们为每个消费者使用不同的组ID，这些ID是随机生成的。 我曾经认为设置...