代碼Review，瑞出事來了！

作者：小姐姐養(yǎng)的狗 2022-03-28 14:32:29

開發(fā)

我實(shí)在是想不通，代碼review就是用來發(fā)現(xiàn)問題的。結(jié)果這review會一開下來，大家都在背后諷刺我。這到底是我的問題呢？還是這個團(tuán)隊(duì)的問題呢？讓人搞不懂。

不久之前，部門進(jìn)行了一次代碼評審。

代碼整體比較簡單，該吹B的地方都已經(jīng)吹過了，無非是些if else的老問題而已。當(dāng)翻到一段定時任務(wù)的一步執(zhí)行代碼時，我的雙眼一亮，覺得該BB兩句了。

誰知這群家伙，評審的時候滿滿的認(rèn)同感，但評審結(jié)束不久，就給我冠了個事B的稱號。

今天我就把當(dāng)時的這些話兒整理整理，讓大家說道說道，我到底是不是個事B。

一個任務(wù)處理例子

代碼的結(jié)構(gòu)大體是這樣的。

通過定時，這段代碼每天晚上凌晨都要對數(shù)據(jù)庫的記錄進(jìn)行一遍對賬。主要的邏輯，就是使用獨(dú)立的線程，漸進(jìn)式的讀取數(shù)據(jù)庫中的相關(guān)記錄，然后把這些記錄，放在循環(huán)中逐條進(jìn)行處理。

ExecutorService service = Executors.newFixedThreadPool(10);
...
service.submit(()->{
    while(true){
        if(CollectionUtils.isEmpty(items)){
            break;
        }
        List<Data> items = queryPageData(start, end); // 分頁邏輯
        for(Data item : items){
            try {
                Thread.sleep(10L);
            } catch (InterruptedException e) {
                //noop 
            }
            processItem(item);
        }
    }
});ExecutorService service = Executors.newFixedThreadPool(10);
...
service.submit(()->{
    while(true){
        if(CollectionUtils.isEmpty(items)){
            break;
        }
        List<Data> items = queryPageData(start, end); // 分頁邏輯
        for(Data item : items){
            try {
                Thread.sleep(10L);
            } catch (InterruptedException e) {
                //noop 
            }
            processItem(item);
        }
    }
});

等一下。在代碼馬上被翻過去的時候，我叫停了，這里的processItem沒有捕獲異常。

通常情況下，這不會有什么問題。但靜好的歲月，總是偶爾會被一些隨機(jī)的事故打斷。如果這是你任務(wù)的完整代碼，那它就有一種非常隱晦的故障處理方式。即使你的單元測試寫的再好，這段代碼我們依然可以通過遠(yuǎn)程投毒的方式，通過問題記錄來讓它產(chǎn)生問題。

是的。以上代碼的根本原因，就是沒有捕捉processItem函數(shù)可能產(chǎn)生的異常。如果在記錄處理的時候，有任何一條拋出了異常，不管是checked異常還是unchecked異常，整個任務(wù)的執(zhí)行都會終止!

不要覺得簡單哦，踩過這個坑的同學(xué)，請記得扣個666。或者翻一下你的任務(wù)執(zhí)行代碼，看看是不是也有這個問題。

Java編譯器在很多情況下都會提示你把異常給捕捉了，但總有些異常會逃出去，比如空指針異常。如下圖，RuntimeException和Error都屬于unchecked異常。

RuntimeException可以不用try...catch進(jìn)行處理，但是如果一旦出現(xiàn)異常，則會導(dǎo)致程序中斷執(zhí)行，JVM將統(tǒng)一處理這些異常。

你捕捉不到它，它自然會讓你的任務(wù)完蛋。

如果你想要異步的執(zhí)行一些任務(wù)，最好多花一點(diǎn)功夫到異常設(shè)計(jì)上面。在這上面翻車的同學(xué)比比皆是，這輛車并不介意再帶上你一個。

評審的小伙很謙虛，馬上就現(xiàn)場修改了代碼。

不要生吞異常

且看修改后的代碼。

ExecutorService service = Executors.newFixedThreadPool(10);
...
service.submit(()->{
    while(true){
        if(CollectionUtils.isEmpty(items)){
            break;
        }
        List<Data> items = queryPageData(start, end); // 分頁邏輯
        for(Data item : items){
            try {
                Thread.sleep(10L);
            } catch (InterruptedException e) {
                //noop 
            }
            try{
                processItem(item);
            }catch(Exception ex){
                LOG.error(...,ex);
            }
        }
    }
});
...
service.shutdownNow();

為了控制任務(wù)執(zhí)行的頻率，sleep大法是個有效的方法。

代碼里考慮的很周到，按照我們上述的方式捕捉了異常。同時，還很貼心的把sleep相關(guān)的異常也給捕捉了。這里不貼心也沒辦法，因?yàn)椴谎a(bǔ)齊這部分代碼的話，編譯無法通過，我們姑且認(rèn)為是開發(fā)人員的水平夠?qū)拧?/p>

由于sleep拋出的是InterruptedException，所以代碼什么也沒處理。這也是我們代碼里常見的操作。不信打開你的項(xiàng)目，忽略InterruptedException的代碼肯定多如牛毛。

此時，你去執(zhí)行這段代碼，雖然線程池使用了暴力的shutdownNow函數(shù)，但你的代碼依然無法終止，它將一直run下去。因?yàn)槟愫雎粤薎nterruptedException異常。

當(dāng)然，我們可以在捕捉到InterruptedException的時候，終止循環(huán)。

try {
    Thread.sleep(10L);
} catch (InterruptedException e) {
    break;
}

雖然這樣能夠完成預(yù)期，但一般InterruptedException卻不是這么處理的。正確的處理方式是這樣的：

while (true) {
    Thread currentThread = Thread.currentThread();
    if(currentThread.isInterrupted()){
        break;
    }
    try {
        Thread.sleep(1L);
    } catch (InterruptedException e) {
        currentThread.interrupt();
    }
}

除了捕捉它，我們還要再次把interrupt狀態(tài)給復(fù)位，否則它就隨著捕捉給清除了。InterruptedException在很多場景非常的重要。當(dāng)有些方法一直阻塞著線程，比如耗時的計(jì)算，會讓整個線程卡在那里什么都干不了，InterruptedException可以中斷任務(wù)的執(zhí)行，是非常有用的。

但是對我們現(xiàn)在代碼的邏輯來說，并沒有什么影響。被評審的小伙伴不滿意的說。

還有問題！

有沒有影響是一回事，是不是好的習(xí)慣是另一回事。我盡量的裝了一下B，其實(shí)，你的異常處理代碼里還有另外隱藏的問題。

還有什么問題？大家都一改常日慵懶的表情，你倒是說說。

我們來看一下小伙伴現(xiàn)場改的問題。他直接使用catch捕獲了這里的異常，然后記錄了相應(yīng)的日志。我要說的問題是，這里的Exception粒度是不對的，太粗魯。

try{
    processItem(item);
}catch(Exception ex){
    LOG.error(...,ex);
}

processItem函數(shù)拋出了IOException，同時也拋出了InterruptedException，但我們都一致對待為普通的Exception，這樣就無法體現(xiàn)上層函數(shù)拋出異常的意圖。

比如processItem函數(shù)拋出了一個TimeoutExcepiton，期望我們能夠基于它做一些重試;或者拋出了SystemBusyExcption，期望我們能夠多sleep一會，給服務(wù)器一點(diǎn)時間。這種粗粒度的異常一股腦的將它們捕捉，在新異常添加的時候根本無法發(fā)現(xiàn)這些代碼，會發(fā)生風(fēng)險(xiǎn)。

一時間會議室里寂靜無比。

我覺得你說的很對，一位比較資深的老鳥說，你的意思是把所有的異常情況都分別捕捉，進(jìn)行精細(xì)化處理。但最后你還是要使用Exception來捕捉RuntimeException，異常還是捕捉不到啊。

果然是不同凡響的發(fā)問。

優(yōu)秀的、標(biāo)準(zhǔn)的代碼寫法，其中無法實(shí)施的一個重要因素，就是項(xiàng)目中的其他代碼根本不按規(guī)矩來。如果我們下層的代碼，進(jìn)行了正確的空指針判斷、數(shù)組越界操作，或者使用類似guava的Preconditions這類API進(jìn)行了前置的異常翻譯，上面的這種問題根本不用回答。

但上面這種代碼的情況，我們就需要手動的捕捉RuntimeException，進(jìn)行單獨(dú)的處理。

你們這個項(xiàng)目，爛代碼太多了，所以不好改。我雖然有情商，但我更有脾氣。

大家不歡而散。