Netty分布式pipeline管道異常傳播事件源碼解析
講完了inbound事件和outbound事件的傳輸流程, 這一小節(jié)剖析異常事件的傳輸流程
傳播異常事件
簡(jiǎ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è)趆andler的channelRead方法中主動(dòng)拋出異常, 模擬程序中出現(xiàn)異常的場(chǎng)景, 經(jīng)測(cè)試會(huì)發(fā)現(xiàn), 程序最終會(huì)走到exceptionCaught方法中, 獲取異常對(duì)象并打印其信息
那么拋出異常之后, 是如何走到exceptionCaught方法的呢?
我們回顧之前小節(jié)channelRead事件的傳播流程, channelRead方法是在AbstractChannelHandlerContext類(lèi)的invokeChannelRead方法中被調(diào)用
我們跟到invokeChannelRead這個(gè)方法
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)用戶(hù)自定義的handler的channelRead方法發(fā)生異常之后, 會(huì)被捕獲, 并調(diào)用notifyHandlerException方法, 并傳入異常對(duì)象, 也就是我們示例中拋出的異常
我們跟到fireChannelRead方法中:
private void notifyHandlerException(Throwable cause) {
//代碼省略
invokeExceptionCaught(cause);
}再繼續(xù)跟到invokeExceptionCaught方法中:
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方法, 也就是我們重寫(xiě)的exceptionCaught方法
知道了為什么會(huì)走到exceptionCaught方法之后, 我們?cè)龠M(jìn)行剖析異常事件的傳播流程
我還是通過(guò)兩種寫(xiě)法來(lái)進(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 {
//寫(xiě)法1
ctx.fireChannelRead(cause);
//寫(xiě)法2
ctx.pipeline().fireExceptionCaught(cause);
}這兩種寫(xiě)法我們并不陌生, 可能我們能直接猜到, 第一種寫(xiě)法是從當(dāng)前節(jié)點(diǎn)進(jìn)行傳播, 第二種寫(xiě)法則從頭結(jié)點(diǎn)或者尾節(jié)點(diǎn)進(jìn)行轉(zhuǎn)播, 那么和傳播inbound事件或outbound事件有什么區(qū)別呢?我們先以第二種寫(xiě)法為例, 剖析異常事件傳輸?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)開(kāi)始的
跟進(jìn)invokeExceptionCaught方法
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的父類(lèi)AbstractChannelHandlerContext中的方法:
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方法
跟進(jìn)exceptionCaught方法:
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
ctx.fireExceptionCaught(cause);
}這里僅僅是繼續(xù)傳播異常事件, 這時(shí)候我們發(fā)現(xiàn), 這個(gè)寫(xiě)法和我們剛才提到傳播異常事件的兩種寫(xiě)法的第一種寫(xiě)法一樣:
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
//寫(xiě)法1
ctx.fireChannelRead(cause);
//寫(xiě)法2
ctx.pipeline().fireExceptionCaught(cause);
}根據(jù)我們之前的學(xué)習(xí), 我們知道第一種寫(xiě)法是從當(dāng)前節(jié)點(diǎn)傳播, 而第二種寫(xiě)法是從頭傳播, 并且要求傳播事件一定要使用第一種寫(xiě)法, 否則事件到這里會(huì)重新從頭傳播進(jìn)而引發(fā)不可預(yù)知錯(cuò)誤, 這個(gè)結(jié)論在異常傳播同樣適用, 同學(xué)們一定要注意這點(diǎn)
我們繼續(xù)跟fireExceptionCaught方法, 這里會(huì)走到AbstractChannelHandlerContex類(lèi)的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)往下傳播,
跟到invokeExceptionCaught方法中
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)槲覀兪菑膆ead節(jié)點(diǎn)開(kāi)始剖析的, 所以這里很有可能就是用戶(hù)自定義的handler, 如果用戶(hù)沒(méi)有重寫(xiě)exceptionCaught方法, 則會(huì)交給用戶(hù)handler的父類(lèi)處理
我們以ChannelInboundHandlerAdapter為例看它的該方法實(shí)現(xiàn):
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
throws Exception {
ctx.fireExceptionCaught(cause);
}我們看到這里繼續(xù)向下傳播了異常事件
走到這里我們會(huì)知道, 如果我們沒(méi)有重寫(xiě)exceptionCaught方法, 異常事件會(huì)一直傳播到鏈表的底部, 就是tail節(jié)點(diǎn)
我們跟到TailConext的exceptionCaught方法:
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
onUnhandledInboundException(cause);
}我們看到最終這里釋放了異常對(duì)象
以上就是有關(guān)異常事件的傳播，更多關(guān)于Netty分布式pipeline管道異常傳播的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
如何基于Spring使用工廠(chǎng)模式實(shí)現(xiàn)程序解耦
這篇文章主要介紹了如何基于Spring使用工廠(chǎng)模式實(shí)現(xiàn)程序解耦,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-12-12
java中Servlet處理亂碼的方法，需要的朋友可以參考一下2013-03-03
線(xiàn)程是進(jìn)程中的一個(gè)實(shí)體，是被系統(tǒng)獨(dú)立調(diào)度和分派的基本單位，線(xiàn)程自己不擁有系統(tǒng)資源，只擁有一點(diǎn)在運(yùn)行中必不可少的資源，但它可與同屬一個(gè)進(jìn)程的其它線(xiàn)程共享進(jìn)程所擁有的全部資源。下面這篇文章主要給大家介紹了Java線(xiàn)程死亡的幾種情況,需要的朋友可以參考下。2017-01-01
SpringBoot攔截器excludePathPatterns方法不生效的解決方案
這篇文章主要介紹了SpringBoot攔截器excludePathPatterns方法不生效的解決方案，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-07-07
Java基礎(chǔ)學(xué)習(xí)之構(gòu)造方法詳解
這篇文章主要為大家詳細(xì)介紹了Java基礎(chǔ)學(xué)習(xí)中構(gòu)造方法的概述及注意事項(xiàng)，文中的示例代碼講解詳細(xì)，對(duì)我們學(xué)習(xí)Java有一定幫助，需要的可以參考一下2022-08-08
在本文中小編給大家分享了關(guān)于springboot中mybatis注解形式的介紹，有興趣的可以跟著學(xué)習(xí)下。2018-10-10
Spring?Data?JPA系列QueryByExampleExecutor使用詳解
這篇文章主要為大家介紹了Spring?Data?JPA系列QueryByExampleExecutor使用示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-09-09
mybatis-plus通用枚舉@JsonValue接收參數(shù)報(bào)錯(cuò)No enum constant
最近在使用mybatis-plus時(shí)用到了通用枚舉,遇到了問(wèn)題,本文主要介紹了mybatis-plus通用枚舉@JsonValue接收參數(shù)報(bào)錯(cuò)No enum constant,具有一定的參考價(jià)值,感興趣的可以了解一下2023-09-09
Spring Boot定時(shí)+多線(xiàn)程執(zhí)行過(guò)程解析
這篇文章主要介紹了Spring Boot定時(shí)+多線(xiàn)程執(zhí)行過(guò)程解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-01-01
教你如何精準(zhǔn)統(tǒng)計(jì)出你的接口"QPS"
今天小編就為大家分享一篇關(guān)于QPS的精準(zhǔn)計(jì)算方法，小編覺(jué)得內(nèi)容挺不錯(cuò)的，現(xiàn)在分享給大家，具有很好的參考價(jià)值，需要的朋友一起跟隨小編來(lái)看看吧2021-08-08