欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

netty中pipeline異常事件分析

 更新時(shí)間：2023年04月25日 11:22:27   作者：寬仔的編程之路  
這篇文章主要為大家介紹了netty中pipeline異常事件分析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

異常處理的場(chǎng)景

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    throw new Exception("throw Exception");
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
    System.out.println(cause.getMessage());
}

我們?cè)?code>handler的channelRead方法中主動(dòng)拋出異常, 模擬程序中出現(xiàn)異常的場(chǎng)景, 經(jīng)測(cè)試會(huì)發(fā)現(xiàn), 程序最終會(huì)走到exceptionCaught方法中, 獲取異常對(duì)象并打印其信息

那么拋出異常之后, 是如何走到exceptionCaught方法的呢?

我們回顧之前小節(jié)channelRead事件的傳播流程, channelRead方法是在AbstractChannelHandlerContext類的invokeChannelRead方法中被調(diào)用

AbstractChannelHandlerContext.invokeChannelRead

private void invokeChannelRead(Object msg) {
    if (invokeHandler()) {
        try {
            //調(diào)用了當(dāng)前handler的channelRead方法, 其實(shí)就是head對(duì)象調(diào)用自身的channelRead方法
            ((ChannelInboundHandler) handler()).channelRead(this, msg);
        } catch (Throwable t) {
            //發(fā)生異常的時(shí)候在這里捕獲異常
            notifyHandlerException(t);
        }
    } else {
        fireChannelRead(msg);
    }
}

這里不難看出, 當(dāng)調(diào)用戶自定義的handler的channelRead方法發(fā)生異常之后, 會(huì)被捕獲, 并調(diào)用notifyHandlerException方法, 并傳入異常對(duì)象, 也就是我們示例中拋出的異常

AbstractChannelHandlerContext.notifyHandlerException(Throwable cause)

private void notifyHandlerException(Throwable cause) {
    //代碼省略
    invokeExceptionCaught(cause);
}

AbstractChannelHandlerContext.invokeExceptionCaught(final Throwable cause)

private void invokeExceptionCaught(final Throwable cause) {
    if (invokeHandler()) {
        try {
            //當(dāng)前handler調(diào)用exceptionCaught()方法
            handler().exceptionCaught(this, cause);
        } catch (Throwable error) {
            //代碼省略
        }
    } else {
        fireExceptionCaught(cause);
    }
}

走到這里一切都明白了, 這里調(diào)用了當(dāng)前handler的exceptionCaught方法, 也就是我們重寫的exceptionCaught方法

知道了為什么會(huì)走到exceptionCaught方法之后, 我們?cè)龠M(jìn)行剖析異常事件的傳播流程

兩種寫法

@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
    System.out.println(cause.getMessage());
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
    //寫法1
    ctx.fireChannelRead(cause);
    //寫法2
    ctx.pipeline().fireExceptionCaught(cause);
}

這兩種寫法我們并不陌生, 可能我們能直接猜到, 第一種寫法是從當(dāng)前節(jié)點(diǎn)進(jìn)行傳播, 第二種寫法則從頭結(jié)點(diǎn)或者尾節(jié)點(diǎn)進(jìn)行轉(zhuǎn)播, 那么和傳播inbound事件或outbound事件有什么區(qū)別呢?我們先以第二種寫法為例, 剖析異常事件傳輸?shù)恼麄€(gè)流程

DefualtChannelPipeline.fireExceptionCaught

public final ChannelPipeline fireExceptionCaught(Throwable cause) {
    AbstractChannelHandlerContext.invokeExceptionCaught(head, cause);
    return this;
}

我們看到invokeExceptionCaught傳入了head節(jié)點(diǎn), 我們可以猜測(cè), 異常事件的傳播是從head節(jié)點(diǎn)開始的

AbstractChannelHandlerContext.invokeExceptionCaught(head, cause)

static void invokeExceptionCaught(final AbstractChannelHandlerContext next, final Throwable cause) {
    ObjectUtil.checkNotNull(cause, "cause");
    EventExecutor executor = next.executor();
    if (executor.inEventLoop()) {
        //執(zhí)行下一個(gè)節(jié)點(diǎn)的異常方法
        next.invokeExceptionCaught(cause);
    } else {
        try {
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    next.invokeExceptionCaught(cause);
                }
            });
        } catch (Throwable t) {
            //忽略代碼
        }
    }
}

因?yàn)檫@里是傳入的是head節(jié)點(diǎn), 所以這里的next指向head節(jié)點(diǎn)。

我們跟到invokeExceptionCaught方法中, 這里其實(shí)是headContext的父類AbstractChannelHandlerContext中的方法

AbstractChannelHandlerContext.invokeExceptionCaught(cause)

private void invokeExceptionCaught(final Throwable cause) {
    if (invokeHandler()) {
        try {
            //當(dāng)前handler調(diào)用exceptionCaught()方法
            handler().exceptionCaught(this, cause);
        } catch (Throwable error) {
            //代碼省略
        }
    } else {
        fireExceptionCaught(cause);
    }
}

這里又是我們熟悉的邏輯, 調(diào)用當(dāng)前handler的exceptionCaught方法, 因?yàn)楫?dāng)前handler是head, 所以首先會(huì)調(diào)用headContext的exceptionCaught方法

exceptionCaught方法

public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
    ctx.fireExceptionCaught(cause);
}

這里僅僅是繼續(xù)傳播異常事件, 這時(shí)候我們發(fā)現(xiàn), 這個(gè)寫法和我們剛才提到傳播異常事件的兩種寫法的第一種寫法一樣

@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
    //寫法1
    ctx.fireChannelRead(cause);
    //寫法2
    ctx.pipeline().fireExceptionCaught(cause);
}

根據(jù)我們之前的學(xué)習(xí), 我們知道第一種寫法是從當(dāng)前節(jié)點(diǎn)傳播, 而第二種寫法是從頭傳播, 并且要求傳播事件一定要使用第一種寫法, 否則事件到這里會(huì)重新從頭傳播進(jìn)而引發(fā)不可預(yù)知錯(cuò)誤, 這個(gè)結(jié)論在異常傳播同樣適用, 同學(xué)們一定要注意這點(diǎn)

我們繼續(xù)跟fireExceptionCaught方法, 這里會(huì)走到AbstractChannelHandlerContex類的fireExceptionCaught方法

AbstractChannelHandlerContex.fireExceptionCaught

public ChannelHandlerContext fireExceptionCaught(final Throwable cause) {
    //傳播異常事件的時(shí)候, 直接拿了當(dāng)前節(jié)點(diǎn)的下一個(gè)節(jié)點(diǎn)
    invokeExceptionCaught(next, cause);
    return this;
}

這個(gè)時(shí)候我們發(fā)現(xiàn), 這里并沒(méi)有去獲取下一個(gè)的inbound節(jié)點(diǎn)還是outbound節(jié)點(diǎn), 而是直接通過(guò)next拿到下一個(gè)節(jié)點(diǎn), 這就說(shuō)明在異常事件傳播的過(guò)程中是不區(qū)分inbound事件還是outbound事件的, 都是直接從head節(jié)點(diǎn)按照鏈表結(jié)構(gòu)往下傳播

AbstractChannelHandlerContex.invokeExceptionCaught(next, cause)

static void invokeExceptionCaught(final AbstractChannelHandlerContext next, final Throwable cause) {
    ObjectUtil.checkNotNull(cause, "cause");
    EventExecutor executor = next.executor();
    if (executor.inEventLoop()) { 
        next.invokeExceptionCaught(cause);
    } else {
        try {
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    next.invokeExceptionCaught(cause);
                }
            });
        } catch (Throwable t) {
            //代碼省略
        }
    }
}

這里又是我們熟悉的邏輯, 我們知道invokeExceptionCaught中執(zhí)行了next的exceptionCaught, 這里的next, 因?yàn)槲覀兪菑?code>head節(jié)點(diǎn)開始剖析的, 所以這里很有可能就是用戶自定義的handler, 如果用戶沒(méi)有重寫exceptionCaught方法, 則會(huì)交給用戶handler的父類處理

我們以ChannelInboundHandlerAdapter為例看它的該方法實(shí)現(xiàn)

public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
        throws Exception {
    ctx.fireExceptionCaught(cause);
}

我們看到這里繼續(xù)向下傳播了異常事件

走到這里我們會(huì)知道, 如果我們沒(méi)有重寫exceptionCaught方法, 異常事件會(huì)一直傳播到鏈表的底部, 就是tail節(jié)點(diǎn)

我們跟到TailConext的exceptionCaught方法

public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
    onUnhandledInboundException(cause);
}

我們看到最終這里釋放了異常對(duì)象，以上就是netty中pipeline異常事件分析的詳細(xì)內(nèi)容，更多關(guān)于netty pipeline異常事件的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

相關(guān)文章

最新評(píng)論