Masstransit 和 RabbitMQ - 连接了多少消费者

Question

我在“竞争消费者”模型和 Pub/Sub 模型中都使用 MassTransit 和 RabbitMQ。

3 层， 第一层 = UI，第二层 = 网关，第三层 = 许多分布式服务

我有一个有效的竞争消费者模型，但我希望通过 Pub/Sub 执行以下操作：

网关服务发布一条消息，所有连接的订阅者实例都使用该消息，然后响应网关。网关在其所有 3rd 层都响应之前不会响应 UI，网关会累积响应并最终传递回 UI。

我找不到在第二层检查 MassTransit（我是否使用 SAGA）的方法，以了解我在第三层有多少订户（以确定他们是否都做出了回应）。总体目标是 UI 获得来自第 3 层的累积结果的单一响应。

类似的问题是here - 目前还没有答案。

更新

实际上，我想计算 inboundPipeline 上的接收器数量。我应该这样做吗？有干净的方法吗？

Answer 1

Pub/Sub 通常不允许您知道给定消息存在多少消费者。整个想法是你没有耦合到那个答案。

为此，您需要将解决方案构建到您的应用程序中以跟踪它。当消费出现时，发布一条消息以供网关注册。当它关闭时，执行相同的操作以删除该注册。