前言

image

??最近在接到了一個(gè)需求，大概是通過RabbitMq給xx子系統(tǒng)同步用戶數(shù)據(jù)句灌，要提供單個(gè)同步和批量同步悟耘。內(nèi)心暗喜這不簡(jiǎn)單的很嘛。三下五除二就把代碼給寫完了先紫，大概長(zhǎng)這樣：

public void syncUserSingle(User user) {
    // 省略一大堆業(yè)務(wù)代碼
    rabbitTemplate.convertAndSend("q_sync_user_single", user);
}

public void syncUserBatch(List<User> userList) {
    // 省略一大堆業(yè)務(wù)代碼
    rabbitTemplate.convertAndSend("q_sync_user_batch", userList);
}

??但是在聯(lián)調(diào)的過程中治泥，遇到了一個(gè)比較奇葩的問題。單個(gè)用戶進(jìn)行同步時(shí)遮精，子系統(tǒng)可以正常消費(fèi)居夹。然后進(jìn)行批量同步的時(shí)候，子系統(tǒng)報(bào)錯(cuò)了本冲。并拋出java.lang.ClassCastException提示 LinkedHashMap cannot xxxx class 准脂。于是負(fù)責(zé)子系統(tǒng)的哥們笑嘻嘻的（表面笑嘻嘻）走過來對(duì)我說，不是約定List<User> 為啥發(fā)個(gè)Map過來檬洞？

??看到這個(gè)錯(cuò)誤狸膏，著實(shí)讓我摸不到頭腦榨婆。頓時(shí)一堆疑問用上心頭窘奏， 為啥單個(gè)對(duì)象可以昭卓，List就不行呢砍濒？我發(fā)的是List<User>數(shù)據(jù)，為啥變成Map了钦扭？雖然一大堆疑問兔乞，但是只能笑嘻嘻的說戏溺，我檢查一下哈性昭。

image

問題重現(xiàn)

• 項(xiàng)目依賴

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.2.RELEASE</version>
        <relativePath/>
    </parent>
    <!-- 省略部分信息 -->
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
    </dependencies>
</project>

發(fā)送方

• 初始化隊(duì)列

@Configuration
public class QueueConfig {
    @Bean
    public Queue test() {
        return new Queue("test");
    }
}

• 配置RabbitTemplete

@Configuration
public class RabbitTemplateConfig {
    @Autowired
    public RabbitTemplateConfig(RabbitTemplate rabbitTemplate) {
        // 設(shè)置Json消息轉(zhuǎn)換器
        rabbitTemplate.setMessageConverter(new Jackson2JsonMessageConverter());
    }
}

• 發(fā)送接口

@Controller
@RequestMapping("/test")
public class TestController {

    @Resource
    private RabbitTemplate template;

    @GetMapping("/send")
    public void send() {
        template.convertAndSend("test", Collections.singletonList(new User(20, "不一樣的科技宅")));
    }
}

• User類

@Data
@AllArgsConstructor
public class User {
    /**
     * 年齡
     */
    private Integer age;

    /**
     * 姓名
     */
    private String name;
}

接收方

• 監(jiān)聽配置

@Configuration
public class RabbitListenerConfig {

    @Bean
    public SimpleRabbitListenerContainerFactory customFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer,
                                                              ConnectionFactory connectionFactory) {
        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
        // 設(shè)置消息轉(zhuǎn)換器
        factory.setMessageConverter(new Jackson2JsonMessageConverter());
        configurer.configure(factory, connectionFactory);
        return factory;
    }

}

• 接收方

@Service
public class UserService {

    public void save(List<User> userList) {
        userList.forEach(System.out::println);
    }
    
}

@Componentpublic class Receiver {    @Resource    private UserService userService;    @RabbitListener(queues = "test", containerFactory = "customFactory")    public void receive(@Payload List<User> msg) {        userService.save(msg);    }}

錯(cuò)誤日志

image

好家伙果然失敗了拦止，這百分百必現(xiàn)的bug呀县遣。

分析問題原因

??首先錯(cuò)誤信息是在消費(fèi)端拋出來的糜颠，按理應(yīng)該是消費(fèi)端出問題概率較大汹族。但是如果和他說的一樣，我生產(chǎn)端發(fā)送的消息就是錯(cuò)誤的其兴，從而導(dǎo)致消費(fèi)端出問題呢顶瞒？這對(duì)這個(gè)疑問，我先斷開消費(fèi)端元旬，然后發(fā)送一條消息榴徐，并通過Rabbitmq的管控臺(tái)來查看消息的內(nèi)容是否正確。

image

消息內(nèi)容如下圖所示：

image

??通過上圖可以發(fā)現(xiàn)匀归，消息體(payload)是一個(gè)標(biāo)準(zhǔn)的json串坑资，并且TypeId也是List，并不是錯(cuò)誤信息中的LinkedHashMap穆端。哈哈哈袱贮，到此可以石錘是消費(fèi)端反序列化的問題了。趕緊把鍋甩出去体啰，抽他呀的（自嗨而已）攒巍，我寫的代碼怎么可能有bug。

image

??對(duì)我愛學(xué)習(xí)的我荒勇，肯定不愿意就這樣算了柒莉。必須刨根問底，給他上一課沽翔。于是我在google一圈發(fā)現(xiàn)這竟然是這個(gè)bug兢孝。有個(gè)老哥也發(fā)現(xiàn)了，并提交了一個(gè)issues: spring-ampq/issues/1279仅偎。

image

??大致是說：嘗試從 Spring Boot 2.3.1 升級(jí)到 2.3.3西潘，然后再升級(jí)到 2.3.6。錯(cuò)誤信息依然是：List<Foo> foos是LikedHashMap哨颂，而不是Foo對(duì)象喷市。并通過遠(yuǎn)程調(diào)試確認(rèn)了這種情況。出于某種原因威恼，他認(rèn)為沒有正確使用泛型類型品姓。恢復(fù)到 Spring-AMQP 2.2.7 使它再次工作箫措，并且對(duì)象確實(shí)是Foo腹备。

image

??然后garyrussell這個(gè)人說：他們添加了對(duì)抽象類反序列化的支持，如果配置不正確斤蔓，這會(huì)對(duì)消息轉(zhuǎn)換器產(chǎn)生一些副作用植酥。然后調(diào)查了一下，確認(rèn)這是一個(gè)錯(cuò)誤。是由于List是抽象的友驮，新代碼認(rèn)為它不能反序列化漂羊。

解決方法是：

converter.setAlwaysConvertToInferredType(true);

后面還提到在 GH-1729: Fix JSON Regression修復(fù)這個(gè)問題，修復(fù)的代碼如下：

image

??通過閱讀代碼發(fā)現(xiàn)卸留，修改前的邏輯是: 如果推斷類型是抽象的走越，則返回false也就代表不能轉(zhuǎn)換成推斷類型。然后被轉(zhuǎn)換成LinkedHashMap耻瑟。這也就是出現(xiàn) LinkedHashMap cannot cast xxxx class的主要原因旨指。

??修改后變成了：如果推斷類型是抽象的并且不是容器類型，返回false喳整。也就意味著谆构，雖然推斷類型是抽象的，但是如果是容器類型框都，并且容器內(nèi)的對(duì)象不是抽象的低淡，則可以被轉(zhuǎn)換。這樣一來避免了上述問題的產(chǎn)生了瞬项。

??前面還提到了通過增加配置來解決蔗蹋。解決起來就相對(duì)簡(jiǎn)單粗暴了，始終轉(zhuǎn)換推斷類型囱淋。

解決辦法

??到此問題分析完畢猪杭，簡(jiǎn)單總結(jié)一下解決方法。主要有兩種：

1. 在消費(fèi)端開啟如下配置即可：

// 始終轉(zhuǎn)換推斷類型
converter.setAlwaysConvertToInferredType(true);

2. 升級(jí)版本：由于GH-1729: Fix JSON Regression合并到了2.2.13.RELEASE妥衣。所以只需要將 spring-amqp 升級(jí)到 2.2.13.RELEASE 或以上皂吮。或者升級(jí)SpringBoot版本到2.3.7.RELEASE税手。

結(jié)尾

??如果覺得對(duì)你有幫助蜂筹，可以多多評(píng)論，多多點(diǎn)贊哦芦倒，也可以到我的主頁看看艺挪，說不定有你喜歡的文章，也可以隨手點(diǎn)個(gè)關(guān)注哦兵扬，謝謝麻裳。

??我是不一樣的科技宅，每天進(jìn)步一點(diǎn)點(diǎn)器钟，體驗(yàn)不一樣的生活津坑。我們下期見！