java - 阻塞路由直到消费者收到消息

Question

我有这样的路线：

[producer1]--->[blocker]--->                 
                           |--->[aggregator]---> [consumer]
[producer2]---------------->

Producer1并将producer2消息推送到aggregator. 如果有两条 id 相同的消息，则聚合完成，聚合后的消息将被路由到消费者。

producer1发送消息后是否可以阻止路由aggregator？类似的东西wait until the consumer receives the aggregated message。

Answer 1

不，这是不可能的，因为聚合器是两条腿的。因此，聚合器的输出与输入的内容无关。

但是，您可以构建一个 java bean 并使用 CountDownLatch，然后在调用聚合器后阻塞，然后在您从聚合器发出传出消息时发出倒计时信号。