rabbitmq的confirm模式获取correlationData为null解决办法

绝地灬酷狼 2024-02-20 13:09 45阅读 0赞

### 回调函数confirm中的correlationData=null ###

// 实现confirm回调,发送到和没发送到exchange,都触发
    @Override
    public void confirm(CorrelationData correlationData, boolean ack, String cause) {
        // 参数说明:
        // correlationData: 相关数据,可以在发送消息时,进行设置该参数
        // ack: 结果
        // cause: 原因
    
        if (ack) {
            log.info("【ConfirmCallback】消息已经送达Exchange，ack已发");
    
        } else {
            ReturnedMessage message = correlationData.getReturned();
    
            if (message != null) {
                String msgData = new String(message.getMessage().getBody());
                log.error("消息发送到 exchange {} 失败,原因: {},id: {}, routingKey: {},body: {}", message.getExchange(), cause, correlationData.getId(), message.getRoutingKey(), msgData);
            } else {
                log.error("消息发送 exchange 失败,原因: {},id: {}", correlationData.getId(),cause);
            }
    
        }
    }

### 解决办法 ###

在convertAndSend方法中传入correlationData数据

@SpringBootTest
    class RabbitmqDemoApplicationTests {
    
        @Test
        void contextLoads() {
        	// 模拟消息
            BattleSubmitMqVo msg = new BattleSubmitMqVo().setUserId(1L).setRoomId("123").setTimes(300L);
            // 工具类发送消息到mq
            MqUtil.sendMsgToMq(RabbitConfig.BATTLE_PAPER_EXCHANGE,RabbitConfig.BATTLE_PAPER_ROUTING_KEY, msg);
    
        }
    
    }

### 工具类 ###

package com.example.rabbitmqdemo.util;
    
    import cn.hutool.json.JSONUtil;
    import com.sun.istack.internal.NotNull;
    import org.springframework.amqp.core.Message;
    import org.springframework.amqp.core.MessagePostProcessor;
    import org.springframework.amqp.core.ReturnedMessage;
    import org.springframework.amqp.rabbit.connection.CorrelationData;
    import org.springframework.amqp.rabbit.core.RabbitTemplate;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import javax.annotation.PostConstruct;
    
    /**
     * desc:
     *
     * @author qts
     * @date 2023/11/3 0003
     */
    @Component
    public class MqUtil {
    
        private static RabbitTemplate rabbitTemplate;
    
        @Autowired
        private RabbitTemplate rabbitTemplate2;
    
        @PostConstruct
        public void init(){
            rabbitTemplate = rabbitTemplate2;
        }
    
        /**
         * 发送消息并
         * 添加 CorrelationData数据
         * @param exchange
         * @param routingKey
         * @param msg
         */
        public static void sendMsgToMq(String exchange, String routingKey, Object msg){
            CorrelationData correlationData = new CorrelationData();
            correlationData.setReturned(new ReturnedMessage(new Message(JSONUtil.toJsonStr(msg).getBytes()),1,"1",exchange,routingKey));
    
            rabbitTemplate.convertAndSend(exchange,routingKey,msg,correlationData);
        }
    
        /**
         * 发送消息
         * 添加 CorrelationData数据, 消息后处理回调
         * @param exchange
         * @param routingKey
         * @param msg
         * @param messagePostProcessor 消息后处理回调
         */
        public static void sendMsgToMq(String exchange, String routingKey, Object msg,MessagePostProcessor messagePostProcessor){
            CorrelationData correlationData = new CorrelationData();
            correlationData.setReturned(new ReturnedMessage(new Message(JSONUtil.toJsonStr(msg).getBytes()),1,"1",exchange,routingKey));
    
            rabbitTemplate.convertAndSend(exchange,routingKey,msg,messagePostProcessor,correlationData);
        }
    }

### 效果 ###

得到了值  
![在这里插入图片描述][beb730da0f2747768c74f502ca01798a.png]

[springboot集成rabbitmq][springboot_rabbitmq]

[beb730da0f2747768c74f502ca01798a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/02/20/fe00f5f181be47558aba610bd5dacc44.png
[springboot_rabbitmq]: https://blog.csdn.net/weixin_44684303/article/details/129880424?ops_request_misc=%257B%2522request%255Fid%2522%253A%2522169900090816800186593143%2522%252C%2522scm%2522%253A%252220140713.130102334.pc%255Fblog.%2522%257D&request_id=169900090816800186593143&biz_id=0&utm_medium=distribute.pc_search_result.none-task-blog-2~blog~first_rank_ecpm_v1~rank_v31_ecpm-1-129880424-null-null.nonecase&utm_term=mq&spm=1018.2226.3001.4450