这边发送消息接收消息默认是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);}
测试成功:
测试失败是这样:如果接收者和发送者的序列化不一样会报这样的错