一、问题背景

---

在SpringAMQP的发送方法中，接收消息的类型是Object，也就是说我们可以发送任意对象类型的消息，接下来做个小实验

如下，注入一个队列到容器中，接着在提供一个服务生产者供测试，发送一个对象数据，观察 RabbitMQ 客户端队列数据形式

@Configuration
public class FanoutConfig {

    @Bean
    public Queue objectQueue() {
        return new Queue("object.queue");
    }

}

    @Test
    public void testObjectMessage() {
        HashMap<String, Object> map = new HashMap<>();
        map.put("国家", "china");
        rabbitTemplate.convertAndSend("object.queue", map);
    }

 运行后，查看 RabbitMQ 队列数据如下：

为什么发送的消息变成了这个样子呢？

这是因为SpringAMQP会帮我们序列化为字节后发送：Spring的对消息对象的处理是由org.springframework.amqp.support.converter.MessageConverter 来处理的。而默认实现是SimpleMessageConverter，基于JDK的ObjectOutputStream完成序列化。 

但是这样的数据就有可能引发以下两种问题：

1. 转化后数据过长，影响传输效率。
2. 容易引发 sql 注入问题。

二、从消息转化器根源解决问题

---

我们只需要在服务生产者和消费者的 Spring 启动类中都重新定义一个 MessageConverter 类型的Bean即可。这里推荐用JSON方式序列化~

具体步骤如下：

1.引入依赖

因为服务生产者和服务消费者都需要 JSON 来序列化和反序列化，因此直接在的父类中引入依赖即可

        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
        </dependency>

 

2.在服务生产者和消费者中都重新定义一个 MessageConverter，注入到 Spring 容器中

使用 @Bean 注解注入即可

@SpringBootApplication
public class ConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }

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

}

@SpringBootApplication
public class PublisherApplication {
    public static void main(String[] args) {
        SpringApplication.run(PublisherApplication.class);
    }

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

再尝试发送数据，结果如下：

Ps：注意发送方与接收方必须使用相同的MessageConverter