1 什么是Confirm机制
- 消息的确认 Pro投递消息后,若Broker收到消息,则会给Pro一个应答
- Pro接收应答 用来确定该消息是否正常地发送到Broker,这种方式也是消息可靠性投递的核心保障
2 Confirm机制流程图
Pro发送消息到Broker,Broker接收到消息后,产生回送响应 Pro中有一个Confirm Listener异步监听响应应答
3 如何实现Confirm确认消息?
- 在channel上开启确认模式:
channel.confirmSelect()
- 在channel上添加监听:
addConfirmListener
,监听成功和失败的返回结果,根据具体的结果对消息进行重新发送、或记录日志等后续处理
4 代码实战
- Con
- Pro
- 检验 server 是否启动 lsof -i:5672
- 启动Con,检查管控台
- 启动Pro