RabbitMQ发布者如何确认工作？

Question

我看过了狂犬病的文档，https://www.rabbitmq.com/confirms.html#publisher-confirms

使用标准的AMQP0-9-1，确保消息不丢失的唯一方法是使用事务--使通道事务性，然后对每条消息或一组消息发布、提交。在这种情况下，事务是不必要的重量级事务，吞吐量降低了250倍。为了纠正这一情况，引入了一种确认机制。它模仿协议中已经存在的使用者确认机制。 要启用确认，客户端发送confirm.select方法。取决于是否设置了no-wait，代理可能会使用一个concerm.select-ok来响应。一旦在信道上使用了confirm.select方法，就可以说它处于确认模式。事务性通道不能进入确认模式，一旦通道处于确认模式，就不能进行事务处理。

目前我正在使用春兔库的RabbitTemplate.convertAndSend发送消息.我使用事务性通道将消息发布到rabbitmq，因为文档的速度较慢，而且我可以通过使用publisher-确认来提高吞吐量。

但我对此不太清楚。

如果我想要启用确认，那么需要进行哪些更改，以及如何处理异常？我的再审机制是什么？此发布者是否以异步方式确认工作？事务是否同步工作？

任何建议都是非常感谢的。

Answer 1

如果您等待每个单个发送的确认，使用publisher确认将不会显著提高事务的性能。如果您发送多条消息并等待稍后确认，它们将对您有很大帮助。

事务是同步的。确认是完全异步的。

见确认并返回。

启用确认时，提供对模板的回调，当接收到确认时将调用该回调。将相关数据添加到发送中，这是在回调中提供的，因此您可以确定此确认是用于哪个发送。此外，相关数据(在最近的版本中)提供了一个Future<?>，您可以等待它以同步的方式接收确认。

那就是你处理任何例外情况的地方。

我希望这能帮上忙。

样品回购中有一个确认并返回样例Spring应用程序，但是它是在将来添加到CorrelationData之前创建的。那个很快就会修好。

相关数据可以包含原始消息，从而启用重试。