Spring Boot 中的 RabbitMQ 消息发送配置

曾经终败给现在 2023-10-13 09:07 44阅读 0赞

## Spring Boot 中的 RabbitMQ 消息发送配置 ##

### 1. 什么是 RabbitMQ ###

RabbitMQ 是一个开源的消息代理系统，它实现了 AMQP（高级消息队列协议）标准，并支持多种消息传输协议。它具有高可用性、可扩展性和可靠性，广泛应用于分布式系统、微服务架构、异步任务处理、日志收集等场景。

RabbitMQ 的核心概念包括：

*  Producer：消息生产者，负责将消息发送到 RabbitMQ 服务器。
 *  Exchange：消息交换机，负责接收 Producer 发送的消息，并将其路由到一个或多个 Queue。
 *  Queue：消息队列，负责存储消息。
 *  Consumer：消息消费者，从 Queue 中获取消息并进行处理。  
    ![在这里插入图片描述][1b111d975fc740eabfe8e2eb8fc2d9b4.png]

### 2. Spring Boot 中的 RabbitMQ 自动配置 ###

Spring Boot 提供了对 RabbitMQ 的自动配置支持，通过在配置文件中添加以下配置，即可快速集成 RabbitMQ：

spring.rabbitmq.host=your-host
    spring.rabbitmq.port=your-port
    spring.rabbitmq.username=your-username
    spring.rabbitmq.password=your-password

Spring Boot 的 RabbitMQ 自动配置会根据上述配置创建一个 `ConnectionFactory` 对象，并使用 `RabbitTemplate` 封装一些常用的 RabbitMQ 操作，例如发送消息、接收消息等。

在使用 Spring Boot 的 RabbitMQ 自动配置时，我们需要添加 RabbitMQ 的依赖：

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-amqp</artifactId>
    </dependency>

### 3. RabbitMQ 消息发送配置 ###

#### 3.1. 发送消息 ####

在 Spring Boot 中，我们可以使用 `RabbitTemplate` 来发送消息。`RabbitTemplate` 提供了一个简单的 API，用于发送消息到 RabbitMQ 服务器。以下是一个发送消息的示例代码：

@Autowired
    private RabbitTemplate rabbitTemplate;
    
    public void sendMessage(String message) {
        
        rabbitTemplate.convertAndSend("exchangeName", "routingKey", message);
    }

在这个示例中，我们使用 `RabbitTemplate` 的 `convertAndSend` 方法来发送消息。其中，`exchangeName` 表示消息交换机的名称，`routingKey` 表示消息路由键，`message` 表示要发送的消息内容。

#### 3.2. 消息确认 ####

RabbitMQ 提供了消息确认机制，用于确保消息被正确地发送到 RabbitMQ 服务器。在 Spring Boot 中，我们可以通过配置 `RabbitTemplate` 来开启消息确认机制。以下是一个开启消息确认机制的示例代码：

@Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
        
            if (!ack) {
        
                log.error("Message send failed: {}", cause);
            }
        });
        return rabbitTemplate;
    }

在这个示例中，我们通过设置 `RabbitTemplate` 的 `ConfirmCallback` 来开启消息确认机制。当消息发送成功时，`ConfirmCallback` 的 `ack` 参数为 `true`，否则为 `false`，`cause` 参数表示发送失败的原因。

#### 3.3. 消息序列化 ####

在 Spring Boot 中，我们可以使用 `MessageConverter` 来对消息进行序列化和反序列化。默认情况下，Spring Boot 使用 `SimpleMessageConverter` 对消息进行序列化和反序列化。如果我们需要使用自定义的序列化方式，可以实现 `MessageConverter` 接口，并将其配置到 `RabbitTemplate` 中。以下是一个自定义的消息序列化器的示例代码：

public class MyMessageConverter implements MessageConverter {
        
        @Override
        public Message toMessage(Object object, MessageProperties messageProperties) throws MessageConversionException {
        
            // 将对象转换为字节数组
            byte[] body = new byte[0];
            try {
        
                ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
                ObjectOutputStream objectOutputStream = new ObjectOutputStream(byteArrayOutputStream);
                objectOutputStream.writeObject(object);
                objectOutputStream.flush();
                body = byteArrayOutputStream.toByteArray();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
            // 创建 Message 对象
            Message message = new Message(body, messageProperties);
            return message;
        }
    
        @Override
        public Object fromMessage(Message message) throws MessageConversionException {
        
            // 将字节数组转换为对象
            Object object = null;
            try {
        
                ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(message.getBody());
                ObjectInputStream objectInputStream = new ObjectInputStream(byteArrayInputStream);
                object = objectInputStream.readObject();
            } catch (IOException | ClassNotFoundException e) {
        
                e.printStackTrace();
            }
            return object;
        }
    }
    
    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        
        RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setMessageConverter(new MyMessageConverter());
        return rabbitTemplate;
    }

在这个示例中，我们实现了一个自定义的消息序列化器 `MyMessageConverter`，并将其配置到 `RabbitTemplate` 中。在 `MyMessageConverter` 中，我们通过实现 `toMessage` 和 `fromMessage` 方法来对消息进行序列化和反序列化。

### 4. 总结 ###

Spring Boot 提供了对 RabbitMQ 的自动配置支持，可以帮助我们快速集成 RabbitMQ，并提供一些默认的配置，例如连接池、消息确认机制、消息序列化等。在使用 Spring Boot 的 RabbitMQ 自动配置时，我们可以使用 `RabbitTemplate` 来发送消息，也可以通过配置 `RabbitTemplate` 来开启消息确认机制和使用自定义的消息序列化器。

如果您正在开发一个基于 Spring Boot 的应用程序，并需要使用 RabbitMQ 来实现消息发送功能，那么 Spring Boot 中的 RabbitMQ 自动配置是您的一个不错的选择。

[1b111d975fc740eabfe8e2eb8fc2d9b4.png]: https://img-blog.csdnimg.cn/1b111d975fc740eabfe8e2eb8fc2d9b4.png