這邊發送消息接收消息默認是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);}
測試成功:
測試失敗是這樣:如果接收者和發送者的序列化不一樣會報這樣的錯