RabbitMq发送消息确认

rabbitmq发送消息确认分为两个阶段：

• 生产者->Broker
• 交换机 -> 队列
  
  image.png
  
  在第一阶段，rabbitmq提供了一个ConfirmCallback的回调函数，当消息被Broker接收到就会触发ConfirmCallback回调。

//配置消息投递交换机回调机制
        rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {
            /**
             * 消息投递交换机回调方法（生产者投递到交换机）
             * @param correlationData 当前消息的唯一关联数据（消息唯一ID)
             * @param ack 消息是否成功收到（是否投递成功）
             * @param cause 消息投递失败原因
             */
            @Override
            public void confirm(CorrelationData correlationData, boolean ack, String cause) {

                log.info("消息投递交换机反馈,correlationData:"+correlationData+"  ack:"+ack+" cause:"+cause);
            }
        });

同时提供了一个配置参数publisher-confirm-type:

• publisher-confirm-type: none
  表示禁用发布确认模式，默认值，使用此模式之后，不管消息有没有发送到Broker都不会触发ConfirmCallback回调
• publisher-confirm-type: correlated
  表示消息成功到达Broker后触发ConfirmCalllBack回调
• publisher-confirm-type: simple
  simple模式下如果消息成功到达Broker后一样会触发ConfirmCalllBack回调，发布消息成功后使用rabbitTemplate调用waitForConfirms或waitForConfirmsOrDie方法等待broker节点返回发送结果，根据返回结果来判定下一步的逻辑。

在第二阶段中，broker中交换机发送消息到队列失败后，提供了一个ReturnCallBack回调函数，可以通过该函数对消息进行补偿等业务操作。

//配置消息交换机投递到队列回调机制
        rabbitTemplate.setReturnCallback(new RabbitTemplate.ReturnCallback() {
            /**
             * 消息投递回调（交换机投递到队列），消息投递失败才触发该机制
             * @param message 投递失败的消息详细信息
             * @param replyCode 回复的状态码
             * @param replyText 回复的文本内容
             * @param exchange  消息投递的交换机
             * @param routingKey 消息投递的路由键
             */
            @Override
            public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {
                log.info("消息投递队列失败回调，Message"+message+" code:"+replyCode+" text:"+replyText+" exchange:"+exchange+" routingKey:"+routingKey);
            }
        });

该回调函数需要在配置文件中通过参数publisher-returns: true开启。