RabbitMQ中生产者丢消息的情况

生产端丢消息的情况

1、连接broker失败(连接地址写错、broker宕机)

• 通过try、catch解决

2、连接正常，不能发送到Exchange、发送到exchange但没有路由到queue(exchange写错、queue没有接受)

• 因为消息时异步发送的，所以只能通过回调的方式判断是否发送成功，然后在通过补偿机制进行补救。

回调的代码实现

把Exchange的名称故意写错(这里就不上图了)。

虽然返回的结果是正常的，但消息并没有实际路由到Queue中，从而丢消息。

• 解决方法：通过回调的方式判断是否发送成功、是否路由成功，如果出现了错误再通过补偿机制进行补救。

添加回调

• 默认是不开启回调的，因为对性能有影响
• 注入自己的RabbitTemplate，并添加回到
• 在配置文件中开启

package com.wcong.config;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;

/**
 * @author wcong
 * @version 1.0
 * @date 2020-07-29 22:23
 */
@Configuration
public class TemplateConfig {

    @Bean
    @Primary
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory){
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        //设置开启Mandatory,才能触发回调函数,无论消息推送结果怎么样都强制调用回调函数
        rabbitTemplate.setMandatory(true);

//        发送到Exchange的回调，发送成功：ack为true
        rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {
            @Override
            public void confirm(CorrelationData correlationData, boolean ack, String cause) {
                System.out.println("ConfirmCallback:     "+"相关数据："+correlationData);
                System.out.println("ConfirmCallback:     "+"是否确认："+ack);
                System.out.println("ConfirmCallback:     "+"原因："+cause);
//            进行相关补偿机制
            }
        });
//       路由回调，只有回调了这个方法，才表示这个消息被成功路由了。
        rabbitTemplate.setReturnCallback(new RabbitTemplate.ReturnCallback() {
            @Override
            public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {
                System.out.println("ReturnCallback:     "+"消息："+message);
                System.out.println("ReturnCallback:     "+"回应码："+replyCode);
                System.out.println("ReturnCallback:     "+"回应信息："+replyText);
                System.out.println("ReturnCallback:     "+"交换机："+exchange);
                System.out.println("ReturnCallback:     "+"路由键："+routingKey);
            }
        });

        return rabbitTemplate;
    }

}

模拟Exchange不存在

• 发现只触发了ConfirmCallback回调，没有触发ReturnCallback回调
• 你Exchange都没进，肯定不会触发ReturnCallback回调啊
  

模拟Exchange正常，路由错误

• 两个回调都触发了
• 先触发ReturnCallback回调，在触发ConfirmCallback回调
• 注意ReturnCallback回的状态码等值
  

正常的情况

• 只要回调了ReturnCallback方法，就表示这个消息路由失败了
• 没有回调了ReturnCallback方法，而且ConfirmCallback回调的ack为false，就表示交换机都没进。

本文地址：https://blog.csdn.net/qq_43332570/article/details/107696260