[[409095]]

改版：

發(fā)送消息與訂閱消息取消使用amqp提供的消息序列化與反序列化功能，使用String類型，發(fā)送消息時(shí)手動(dòng)轉(zhuǎn)化為json字符串再發(fā)送，消費(fèi)消息時(shí)手動(dòng)json反序列化。

背景：

如果使用自動(dòng)序列化與反序列化功能，即給Rabbitmq配置Jackson2JsonMessageConverter消息轉(zhuǎn)化器，當(dāng)我們修改消息Body的java類型名稱或者包名時(shí)，消費(fèi)歷史消息就會(huì)拋出ClassNotFoundException異常。

1、不做兼容上線，但需要：

• 確保不會(huì)有新的消息進(jìn)入隊(duì)列;
• 確保隊(duì)列中的消息已經(jīng)消費(fèi)完。

2、粗暴方式，直接清空隊(duì)列，丟棄歷史消息;

3、做兼容，給舊消息創(chuàng)建一個(gè)類名匹配的消息Body類型，添加一個(gè)@RabbitHandler方法處理舊消息。

這是因?yàn)镽abbitmq為了實(shí)現(xiàn)一個(gè)隊(duì)列支持多個(gè)方法消費(fèi)(即@RabbitHandler注解的方法)，每個(gè)方法消費(fèi)不同Java類型的消息Body，在消費(fèi)到消息時(shí)，就需要先反序列化出消息Body，才能根據(jù)消息Body的類型去匹配一個(gè)消費(fèi)方法消費(fèi)消息，如DelegatingInvocableHandler#invoke方法源碼所示。

// org.springframework.amqp.rabbit.listener.adapter.DelegatingInvocableHandler#invoke 
public InvocationResult invoke(Message<?> message, Object... providedArgs) throws Exception {  
   // 獲取消息body類型 
   Class<? extends Object> payloadClass = message.getPayload().getClass(); 
   // 匹配的方法 
   InvocableHandlerMethod handler = getHandlerForPayload(payloadClass); 
   // 調(diào)用方法消費(fèi) 
   Object result = handler.invoke(message, providedArgs); 
   //.... 
} 

由于需要在匹配消息消費(fèi)方法之前就需要解析出消息Body，也就是要先知道消息Body的Java類型才能實(shí)現(xiàn)json反序列化，這就要求消息生產(chǎn)者在發(fā)送消息時(shí)不得不在消息頭添加一個(gè)參數(shù)表示消息Body的Java類型，如下圖所示。

在消息消費(fèi)階段，Jackson2JsonMessageConverter也需要先根據(jù)消息頭的TypeId獲取JavaType，再執(zhí)行反序列化操作，當(dāng)類名修改時(shí)，或者生產(chǎn)者和消費(fèi)者各自定義的類名不同，都將會(huì)導(dǎo)致反序列化失敗。

除非確保消息Body的類名不會(huì)變，且生產(chǎn)者與消費(fèi)者定義的完整類名相同，否則不建議使用自動(dòng)序列化與反序列化功能。

本文轉(zhuǎn)載自微信公眾號(hào)「Java藝術(shù)」，作者wujiuye 。轉(zhuǎn)載本文請(qǐng)聯(lián)系Java藝術(shù)公眾號(hào)。