diff --git a/netty-02-induction/src/main/java/com/kwan/shuyu/demo/EchoExceptionHandler.java b/netty-02-induction/src/main/java/com/kwan/shuyu/demo/EchoExceptionHandler.java index 075c7d9337fc085c9b5164ce437f5ad0fcafaa81..c0d2e880f829d9cf076c099626889b85dbec5c08 100644 --- a/netty-02-induction/src/main/java/com/kwan/shuyu/demo/EchoExceptionHandler.java +++ b/netty-02-induction/src/main/java/com/kwan/shuyu/demo/EchoExceptionHandler.java @@ -3,6 +3,13 @@ package com.kwan.shuyu.demo; import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter; +/** + * 异常处理器 + * + * @author : qinyingjie + * @version : 2.2.0 + * @date : 2023/8/24 14:29 + */ public class EchoExceptionHandler extends ChannelInboundHandlerAdapter { @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { diff --git a/netty-02-induction/src/main/java/com/kwan/shuyu/demo/EchoOutSelfHandler.java b/netty-02-induction/src/main/java/com/kwan/shuyu/demo/EchoOutSelfHandler.java index 4b93da30899e6acb1d03b4bcd00a120194aa36c8..5e59d7ee0b35c9058174f154d260335c96f10590 100644 --- a/netty-02-induction/src/main/java/com/kwan/shuyu/demo/EchoOutSelfHandler.java +++ b/netty-02-induction/src/main/java/com/kwan/shuyu/demo/EchoOutSelfHandler.java @@ -7,6 +7,14 @@ import io.netty.channel.ChannelOutboundHandlerAdapter; import io.netty.channel.ChannelPromise; import io.netty.util.CharsetUtil; + +/** + * 出栈处理器 + * + * @author : qinyingjie + * @version : 2.2.0 + * @date : 2023/8/24 14:28 + */ public class EchoOutSelfHandler extends ChannelOutboundHandlerAdapter { @Override public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception { @@ -22,7 +30,6 @@ public class EchoOutSelfHandler extends ChannelOutboundHandlerAdapter { } }); } - @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) { System.out.println("im in"); diff --git a/netty-02-induction/src/main/java/com/kwan/shuyu/demo/EchoServerHandler.java b/netty-02-induction/src/main/java/com/kwan/shuyu/demo/EchoServerHandler.java index 3d389ad6ed70fbe984e10f144c5d5adb1ab86a20..f50b7a2df75282702ba5fed810a70f8370bf5854 100644 --- a/netty-02-induction/src/main/java/com/kwan/shuyu/demo/EchoServerHandler.java +++ b/netty-02-induction/src/main/java/com/kwan/shuyu/demo/EchoServerHandler.java @@ -7,6 +7,13 @@ import io.netty.channel.ChannelInboundHandlerAdapter; import io.netty.util.CharsetUtil; +/** + * 入栈处理器 + * + * @author : qinyingjie + * @version : 2.2.0 + * @date : 2023/8/24 14:29 + */ @ChannelHandler.Sharable public class EchoServerHandler extends ChannelInboundHandlerAdapter { @Override