为什么需要RabbitMQ消息转换?

SpringAMQP中消息队列传递Object对象,是通过JDK将Object对象的进行序列化,但JDK默认性能较差,同时AMQP协议封装数据是字节流,将来在RabbitMQ客户端看起来是一长串,我们通过修改底层默认MessageConverter处理。可以实现Json形式传递,短小精悍,性能也更好一些!

实现RabbitMQ替换字节流传输!

我们就需要Jackson依赖

        <dependency>
            <groupId>com.fasterxml.jackson.dataformat</groupId>
            <artifactId>jackson-dataformat-xml</artifactId>
            <version>2.13.3</version>
        </dependency>

声明Bean

import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
 
    @Bean
    public MessageConverter json(){
        return new Jackson2JsonMessageConverter();
    }

完成🎉!