消息发送确认
发送的消息怎么样才算失败或成功？如何确认？
当消息无法路由到队列时，确认消息路由失败。消息成功路由时，当需要发送的队列都发送成功后，进行确认消息，对于持久化队列意味着写入磁盘，对于镜像队列意味着所有镜像接收成功
使用springBoot,需要在application.properties配置文件中配置:
ConfirmCallback
消息发送到 Broker 后触发回调，确认消息是否到达 Broker 服务器,通过实现 ConfirmCallback 接口，复写confirm()方法,实现自己的处理逻辑,
注意:失败的回调,并不会传回,失败的消息,仅仅只是一个表示,告诉你成功与否,可以在send消息的时候,传入CorrelationData参数(),这样回调ConfirmCallback的时候,就可以拿到message()
如果需要对失败的消息做额外的重发处理,需要做额外的操作,如:使用redis,把发送的消息,存在redis中,返回ack,则删除redis的消息,定时获取redis中的消息,做重发处理
代码如下:
ReturnCallback
通过实现 ReturnCallback 接口，启动消息失败返回(成功无返回):
在初始化RabbitAdmin或者RabbitTemplate的时候,设置回调:
发送消息:
只有设置了Mandatory,才会在失败的时候调用ReturnCallback(方法)
消费确认
首先需要在application.properties配置去下,开启手动确认模式:
具体消费代码如下:
