提供邢台企业做网站注册公司

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

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

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

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

    @Beanpublic MessageConverter jsonMessageConverter(){return new Jackson2JsonMessageConverter();}

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

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

    @Testpublic 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);}

测试成功:

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