為什么我不推薦你使用RabbitMQ的消息轉(zhuǎn)換功能
改版：
發(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)。
