MQ消息转换器

  Spring的对消息对象的处理是由org.springframework.amqp.support.converter.MessageConverter来处理的。而默认实现是SimpleMessageConverter，基于JDK的ObjectOutputStream完成序列化。

  如果要修改只需要定义一个MessageConverter 类型的Bean即可。推荐用JSON方式序列化，步骤如下：

发送消息依赖 

1、引入依赖

    com.fasterxml.jackson.core
    jackson-databind

2、在publisher服务端声明MessageConverter

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

---

 接听消息转换

1、引入依赖

    com.fasterxml.jackson.core
    jackson-databind

2、在publisher服务端声明MessageConverter

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

3、然后定义一个消费者，监听object.queue队列并消费消息：

 @RabbitListener(queues = "object.queue")
public void listenObjectQueue(Map msg) {
    System.out.println("收到消息：【" + msg + "】");
}

---

SpringAMQP中消息的序列化和反序列化是怎么实现的？

利用MessageConverter实现的，默认是JDK的序列化

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