SpringBoot整合RabbitMQ消息队列基本环境搭建

Posted 2023-01-02 轨.迹

SpringBoot版本：2.6.13

1. 导入amqp依赖

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

2. 配置文件配置mq所在机器的ip和端口号

spring:
    rabbitmq:
        host: 192.168.xxx.xxx
        port: 5672
        virtual-host: /
        listener:
          direct:
            acknowledge-mode: manual

3. 启动类上添加注解启用消息队列

@EnableRabbit

4. 配置消息队列转换格式

@Configuration
public class MyRabbitMQConfig 

    /**
     * 使用JSON序列化机制，进行消息转换
     */
    @Bean
    public MessageConverter messageConverter() 
        return new Jackson2JsonMessageConverter();
    

5. 配置交换机、队列、交换机和队列的绑定关系

继续补充Config文件即可

    // 配置交换机
    @Bean
    public Exchange testExchange() 
        // String name, boolean durable, boolean autoDelete, Map<String, Object> arguments
        return new TopicExchange();
    

    // 配置队列    
    @Bean
    public Queue testQueue() 
        // String name, boolean durable, boolean exclusive, boolean autoDelete, @Nullable Map<String, Object> arguments
        return new Queue();
    

    // 配置绑定关系
    @Bean
    public Binding testBinding() 
        // String destination, DestinationType destinationType, String exchange, String routingKey, @Nullable Map<String, Object> arguments
        return new Binding();