《RabbitMQ系列教程-第七章-02-消息确认机制之回退模式》

墨蓝 2023-01-02 03:29 135阅读 0赞

# 教程说明 #

*  本系列教程目录大纲：[《RabbitMQ系列教程-目录大纲》][RabbitMQ_-]

--------------------

*  本系列教程配套代码：[https://gitee.com/Horizon1024/rabbitmt.git][https_gitee.com_Horizon1024_rabbitmt.git]（码云地址）

--------------------

# 消息确认机制之回退模式 #

在回退模式中，当`Producer`发送消息之后，队列无法接受到消息时，触发回调函数

#### 配置spring.xml ####

开启回退模式：在connectionFactory中开启确认模式`publisher-returns="true"`

<rabbit:connection-factory id="connectionFactory" host="${rabbitmq.host}" port="${rabbitmq.port}" username="${rabbitmq.username}" password="${rabbitmq.password}" virtual-host="${rabbitmq.virtual-host}" publisher-confirms="true" publisher-returns="true" />

#### 编写测试类： ####

设置Exchange处理消息的模式：`rabbitTemplate.setMandatory(true);`，当消息没有路由到Queue，则触发回调函数

/** * 回退模式： 当消息发送给Exchange后，Exchange路由到Queue失败时 才会执行 ReturnCallBack * 步骤： * 1. 开启回退模式:publisher-returns="true" * 2. 设置ReturnCallBack * 3. 设置Exchange处理消息的模式： * 1. 如果消息没有路由到Queue，则丢弃消息（默认） * 2. 如果消息没有路由到Queue，返回给消息发送方ReturnCallBack */
    @Test
    public void testReturn() { 
    
        // 开启消息回退
        rabbitTemplate.setMandatory(true);
    
        //2.设置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) { 
                System.out.println("return 执行了....");
    
                System.out.println("message: " + message);
                System.out.println("replyCode: " + replyCode);
                System.out.println("replyText: " + replyText);
                System.out.println("exchange: " + exchange);
                System.out.println("routingKey: " + routingKey);
    
                //处理
            }
        });
    
        //3. 发送消息
        rabbitTemplate.convertAndSend("test_exchange_confirm", "confirm", "message confirm....");
    }

**在上述案例中，消息没有路由到Queue上则触发回调，如果消息连交换机都没有到，那么则不会触发回调**

[RabbitMQ_-]: https://blog.csdn.net/Bb15070047748/article/details/112194912
[https_gitee.com_Horizon1024_rabbitmt.git]: https://gitee.com/Horizon1024/rabbitmt.git