消息的可靠性投递_概念

RabbitMQ消息投递的路径为：

生产者--->交换机--->队列--->消费者

在RabbitMQ工作的过程中，每个环节消息都可能传递失败，那么RabbitMQ是如何监听消息是否成功投递的呢？

• 确认模式（confirm）可以监听消息是否从生产者成功传递到交换机。
• 退回模式（return）可以监听消息是否从交换机成功传递到队列。
• 消费者消息确认（Consumer Ack）可以监听消费者是否成功处理消息。

首先我们准备两个SpringBoot项目，分别代表生产者和消费者，配置文件如下：

xxxxxxxxxx
spring:
  rabbitmq:
    host: 192.168.0.162
    port: 5672
    username: itbaizhan
    password: itbaizhan
    virtual-host: /
   
#日志格式
logging:
  pattern:
    console: '%d{HH:mm:ss.SSS} %clr(%-5level) ---  [%-15thread] %cyan(%-50logger{50}):%msg%n'

在生产者的配置类创建交换机和队列

xxxxxxxxxx
@Configuration
public class RabbitConfig {
    private final String EXCHANGE_NAME="my_topic_exchange";
    private final String QUEUE_NAME="my_queue";

    // 1.创建交换机
    @Bean("bootExchange")
    public Exchange getExchange(){
        return ExchangeBuilder
                .topicExchange(EXCHANGE_NAME) // 交换机类型
                .durable(true) // 是否持久化
                .build();
    }

    // 2.创建队列
    @Bean("bootQueue")
    public Queue getMessageQueue(){
        return QueueBuilder
                .durable(QUEUE_NAME) // 队列持久化
                .build();
    }

    // 3.将队列绑定到交换机
    @Bean
    public Binding bindMessageQueue(@Qualifier("bootExchange") Exchange exchange, @Qualifier("bootQueue") Queue queue){
        return BindingBuilder.bind(queue).to(exchange).with("my_routing").noargs();
    }
}

实时效果反馈

1. 在RabbitMQ中，可以监听消息是否从生产者成功传递到交换机

A confirm

B return

C Ack

D 以上说法都不对

2. 在RabbitMQ中，可以监听消费者是否成功处理消息

A confirm

B return

C Ack

D 以上说法都不对

答案

1=>A 2=>C