From 1baab088ad558ced16622ad4ad2ec331ee16661c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=A7=A6=E8=8B=B1=E6=9D=B0?= <327782001@qq.com> Date: Thu, 24 Aug 2023 14:30:14 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E5=87=BA=E5=85=A5=E6=A0=88=E5=A4=84?= =?UTF-8?q?=E7=90=86=E5=99=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/kwan/shuyu/demo/EchoExceptionHandler.java | 7 +++++++ .../java/com/kwan/shuyu/demo/EchoOutSelfHandler.java | 9 ++++++++- .../main/java/com/kwan/shuyu/demo/EchoServerHandler.java | 7 +++++++ 3 files changed, 22 insertions(+), 1 deletion(-) 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 075c7d9..c0d2e88 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 4b93da3..5e59d7e 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 3d389ad..f50b7a2 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 -- GitLab