spring-integration - 使用 Spring Integration 和 AMQP，我可以创建竞争消费者的 Pub-Sub 组吗？

Question

我想创建一个如下图所示的设置：

这可以通过 Spring Integration 对 AMQP 的支持来完成吗？即图中的通信通道可以是AMQP吗？目标是这样的：

1. 图片中的每个组件都可以是一个单独的服务器。
2. 我可以扩大每个消费者群体。
3. 每个消费者组中只有一名工作人员处理该消息。
4. 每个消费者组接收每条消息。

我查看了文档，但不确定 SI 提供的两个 AMQP 消息通道实现（点对点和发布/订阅）是否可以在这里解决问题。特别是，点对点通道是否会像常规直接通道一样工作，即支持多个端点，只有一个端点接收每条消息？

非常感谢！

Answer 1

fanout用发布到交换的出站通道适配器替换 pub-sub 通道。

将 2 个队列绑定到扇出交换；每个人都会得到一份消息的副本。

为每个消费者使用入站通道适配器，每个消费者都监听适当的队列；两组消费者将竞争他们的消息。