在配置文件中添加:spring.rabbitmq.publisher-confirm-type=correlated
spring:
rabbitmq:
host: 10.211.55.5
username: admin
password: admin
port: 5672
virtual-host: /test
publisher-confirm-type: correlated
- NONE:禁用发布确认模式,是默认值
- CORRELATED:发布消息成功到交换器后会触发回调方法
- SIMPLE:有两种效果。一是和 CORRELATED 一样会触发回调方法;二是在发布消息成功后使用 rabbitTemplate 调用 waitForConfirms 或 waitForConfirmsOrDie 方法,等待 broker 节点返回发送结果,根据返回结果来判定下一步的逻辑。要注意的点是 waitForConfirmsOrDie 方法如果返回 false 则会关闭 channel,回导致接下来无法发送消息到 broker。



