node.js - 分布式发布/订阅，每个消息类型只有一个消费者

Question

我不知道是在这里提问还是在 Programmers.SE 上提问更好，所以如果我有这个错误，请迁移。

首先，简单介绍一下我要实现的目标。我有一个 node.js 应用程序，它从一个源(一个 socket.io 客户端)获取消息，然后对消息进行处理，这可能会导致零个或多个消息返回到发件人或其中的其他客户端组。

对于处理，我想基本上只是将消息插入队列，然后它通过各种可能启动自己的项目的消息处理器工作，最终，运行 socket.io 的位被告知“嘿, 发回此消息"

作为一个具体的例子，假设用户登录服务，登录消息然后被放入队列中，授权处理器在那里获取它，做这件事，然后将一条消息放回队列中说客户端已经授权。这可以追溯到连接到客户端的 socket.io 套接字，以及可能感兴趣的其他客户端。它还可以转到其他可能想要对授权进行更多处理的子系统(查找用户信息、根据他们的数据向客户端发送更多信息等)。

如果我想要强耦合，这会很容易，但我之前尝试过，它只会变成一堆非常脆弱的意大利面条代码，我想避免这种情况。设置中的另一个问题是这应该是可集群的，这才是真正的问题所在。可能有不止一个，比如说，授权处理器在运行。但授权消息应该只处理一次。

因此，简而言之，我正在寻找一种模式/技术，基本上可以让我拥有多个消息订阅者“组”，并且每个组只处理一次消息。

我考虑过让处理器的每个实例生成一个唯一的名称，该名称将用作 Reids 中的列表。然后，该名称将在某种调度处理程序中注册，并放入该组订阅者的集合中。然后，当一条消息到达时，调度程序会从该集合中随机抽取一个成员，并将其放入该列表中。虽然这看起来可行，但它似乎有些过于复杂和脆弱。

核心问题是我从来没有设计过这样的系统，所以我什至不确定使用或查找的正确术语。如果有人能为此指出正确的方向，我将不胜感激。

Answer 1

我认为你的描述类似于https://www.getbridge.com/服务。我最终基于 zeromq 编写了自己的程序，它允许您注册服务、req -> <- rec 和 channel ，它们是 pub/sub worker。

至于设计，我使用了客户端 -> 代理 -> 服务和 channel ，它们都是使用自动发现即插即用的，你让服务向打开 tcp 连接的代理注册它们的模式，以便其他代理上的代理服务器可以与该代理组服务通信。然后内部服务和客户端通过首选的 unix 套接字或 ipc channel 连接。