SpringBoot整合RabbitMQ案例

叁歲伎倆 2022-03-02 16:08 241阅读 0赞

### 一、引入相关Jar ###

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

### 二、配置全局环境  ###

#配置rabbitmq
    spring.rabbitmq.host=192.168.43.118
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest
    spring.rabbitmq.port=5672
    spring.rabbitmq.virtual-host=/

### 三、编写单元测试  ###

@Autowired
        RabbitTemplate rabbitTemplate;
    
        @Test
        public void contextLoads() {
            rabbitTemplate.convertAndSend("exchange.direct","zhq.news",new User("张三",20));
        }
        @Test
        public void receive(){
            Object object = rabbitTemplate.receiveAndConvert("zhq.news");
            System.out.println(object);
            System.out.println(object.getClass());
        }

默认是JDK的序列化是二字节码，可读性差：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70][]

可以自己定义序列化方式，可以通过编写自定义配置类：

@Configuration
    public class MyAMQPConfig {
        /**
         * 注入Json序列化器
         * @return
         */
        @Bean
        public MessageConverter messageConverter(){
            return new Jackson2JsonMessageConverter();
        }
    
    }

得到：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70 1][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70]: /images/20220302/a2ff83989355471b8a0aca4843f58b75.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3htMzkzMzkyNjI1_size_16_color_FFFFFF_t_70 1]: /images/20220302/b3ce465996e6467f8b342a301da30715.png