SpringAMQP-消息转换器

这边发送消息接收消息默认是jdk的序列化方式，发送到服务器是以字节码的形式，我们看不懂也很占内存，所以我们要手动设置一下 我这边设置成json的序列化方式，注意发送方和接收方的序列化方式要保持一致 不然回报错。

引入依赖，建议直接在父工程引入。

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

在配置类里配置一下：接收方和发送方都要有

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

配置好之后编写测试代码:

向object.queue队列发送map的消息

    @Test
    public void testObjectQueue(){
        Map<Integer,String> map = new HashMap<>();
        String queueName="object.queue";
        map.put(1,"刘岚");
        map.put(2,"范冰冰");
        rabbitTemplate.convertAndSend(queueName, map);
    }

接收该消息:

    @RabbitListener(queues = "object.queue")
    public void listenObjectQueue(Map<Integer, String> msg) {
        System.out.println("从object.queue中接收到消息:" + msg);
    }

测试成功:

测试失败是这样:如果接收者和发送者的序列化不一样会报这样的错