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

妖狐艹你老母 2023-01-02 03:28 157阅读 0赞

# 教程说明 #

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

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

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

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

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

在确认模式中，当Producer发送消息之后，不管是否到达队列（交换机）都会触发Producer端的一个回调函数，在回调函数参数中能够判断此次消息是否发送成功，我们可以根据反馈的信息来做相应的处理

搭建消息生产者；采用RabbitMQ整合Spring环境（参考前面工程）

#### 编写spring.xml配置文件： ####

**开启确认模式**：在connectionFactory中开启确认模式`publisher-confirms="true"`

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:rabbit="http://www.springframework.org/schema/rabbit" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/rabbit http://www.springframework.org/schema/rabbit/spring-rabbit.xsd">
        
        <context:property-placeholder location="classpath:rabbitmq.properties"/>
    
        
        <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" />
        
        <rabbit:admin connection-factory="connectionFactory" />
    
        
        <rabbit:template id="rabbitTemplate" connection-factory="connectionFactory"/>
    
        
        <rabbit:queue id="test_queue_confirm" name="test_queue_confirm"></rabbit:queue>
    
        <rabbit:direct-exchange name="test_exchange_confirm">
            <rabbit:bindings>
                <rabbit:binding queue="test_queue_confirm" key="confirm"></rabbit:binding>
            </rabbit:bindings>
        </rabbit:direct-exchange>
    </beans>

#### 测试代码： ####

package com.lscl.rabbitmq;
    
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.amqp.core.Message;
    import org.springframework.amqp.rabbit.connection.CorrelationData;
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.test.context.ContextConfiguration;
    import org.springframework.test.context.junit4.SpringRunner;
    
    @RunWith(SpringRunner.class)
    @ContextConfiguration(locations = "classpath:spring.xml")
    public class ProducerTest { 
    
        @Autowired
        private RabbitTemplate rabbitTemplate;
    
        /** * 确认模式： * 步骤： * 1. 确认模式开启：ConnectionFactory中开启publisher-confirms="true" * 2. 在rabbitTemplate定义ConfirmCallBack回调函数 */
        @Test
        public void testConfirm() { 
    
            //2. 定义回调
            rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() { 
                /** * * @param correlationData 相关配置信息 * @param ack exchange交换机 是否成功收到了消息; true:成功 false:失败 * @param cause 失败原因 */
                @Override
                public void confirm(CorrelationData correlationData, boolean ack, String cause) { 
    
                    System.out.println("confirm方法被执行了....");
    
                    if (ack) { 
                        //接收成功
                        System.out.println("接收成功消息" + cause);
                    } else { 
                        //接收失败
                        System.out.println("接收失败消息" + cause);
                        //做一些处理，让消息再次发送。
                    }
                }
            });
    
            //3. 发送消息
            rabbitTemplate.convertAndSend("test_exchange_confirm", "confirm", "message confirm....");
        }
    }

当消息无法发送出去时，`ack`为`false`，消息正常发送时，`ack`为`true`

**需要注意一点：在上述案例中，消息是发送给`test_exchange_confirm`交换机的，如果消息不能发送给该交换机（例如名字写错）那么ack为false，如果能发送给交换机ack为true，即使消息没有路由到Queue上（例如Routing Key写错）**

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