Spring会把你发送的消息序列化为字节发送给MQ，接收消息的时候，还会把字节反序列化为Java对象。
image.png
只不过，默认情况下Spring采用的序列化方式是JDK序列化。众所周知，JDK序列化存在下列问题：

  • 数据体积过大
  • 有安全漏洞
  • 可读性差

    测试默认转换器

    1. @Test
    2. public void testSendMap() throws InterruptedException {
    3.   // 准备消息
    4.   Map<String,Object> msg = new HashMap<>();
    5.   msg.put("name", "Jack");
    6.   msg.put("age", 21);
    7.   // 发送消息
    8.   rabbitTemplate.convertAndSend("simple.queue","", msg);
    9. }
    发送了消息后在mq控制台可以看到序列化的字符串，一个简单的map序列化后这么长。
    image.png

    配置JSON转换器

    显然，JDK序列化方式并不合适。我们希望消息体的体积更小、可读性更高，因此可以使用JSON方式来做序列化和反序列化。
    在父工程引入依赖
    1. <dependency>
    2.   <groupId>com.fasterxml.jackson.dataformat</groupId>
    3.   <artifactId>jackson-dataformat-xml</artifactId>
    4.   <version>2.9.10</version>
    5. </dependency>
    配置消息转换器。
    在publisher和consumer两个服务的配置类中添加一个Bean即可： ```java package cn.itcast.mq.config;

import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter; import org.springframework.amqp.support.converter.MessageConverter; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;

@Configuration public class MyMqConfig { @Bean public MessageConverter jsonMessageConverter(){ return new Jackson2JsonMessageConverter(); } }

  1. 既然发送的是Map类型，接受消息同样用Map类型
  2. ```java
  3. package cn.itcast.mq.listener;
  5. import org.springframework.amqp.rabbit.annotation.RabbitListener;
  6. import org.springframework.stereotype.Component;
  8. import java.util.Map;
  11. @Component
  12. public class SpringRabbitListener {
  14.     @RabbitListener(queues = "simple.queue")
  15.     public void listenSimpleQueue(Map<String,Object> msg){
  16.         System.out.println(msg.toString());
  17.     }
  19. }

image.png