springboot2.x集成RabbitMQ实现消息发送确认与消息接收确认（ACK）

梦里梦外; 2023-06-17 10:51 7阅读 0赞

### 前言 ###

首先看回调机制：

*  消息不管是否投递到交换机都进行ConfirmCallback回调，投递成功ack=true，否则为false
 *  交换机匹配到队列成功则不进行ReturnCallback回调，否则先进行ReturnCallback回调再进行ConfirmCallback回调
 *  如果消息成功投递到交换机，但没匹配到队列，则ConfirmCallback回调ack仍为true

我的springboot版本springBootVersion = '2.2.1.RELEASE'

### ConfirmCallback ###

首先需要在yml配置：

publisher-confirm-type: correlated

/**
         * 测试消息确认回调（必须在yml配置publisher-confirm-type: correlated）
         */
        @GetMapping("sendConfirmCallback")
        public Resp sendConfirmCallback() {
            rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
                System.out.println("ack:" + ack);
                if (!ack) {
                    System.out.println("异常处理");
                }
            });
            amqpTemplate.convertAndSend("test-queue", "测试ack确认模式");
            return Resp.success("ok", null);
        }

### ReturnCallback ###

需要在yml配置

publisher-returns: true

@Autowired
        private AmqpTemplate amqpTemplate;
        @Resource
        private RabbitTemplate rabbitTemplate; 
    
       /**
         * 启动消息失败返回，比如路由不到队列时触发回调
         * 测试发布回调（必须在yml配置publisher-returns: true）
         */
        @GetMapping("sendReturnCallback")
        public Resp sendReturnCallback() {
            RabbitTemplate.ReturnCallback returnCallback = (message, replyCode, replyText, exchange, routingKey) -> {
                System.out.println("========returnCallback=============");
                System.out.println("========returnCallback=============");
            };
            rabbitTemplate.setReturnCallback(returnCallback);
            amqpTemplate.convertAndSend("test-", "测试发布回调模式");
            return Resp.success("ok", null);
        }