From d3cdbf19b53e24a1417364b098f7b8f71f36a208 Mon Sep 17 00:00:00 2001
From: wzy <wzy19931122ai@163.com>
Date: Sun, 28 Feb 2021 19:47:04 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/netty/client/ClientChannelHandler.java | 7 ++++++-
1 files changed, 6 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/netty/client/ClientChannelHandler.java b/src/main/java/com/xcong/excoin/netty/client/ClientChannelHandler.java
index 33bc9b8..2917b8d 100644
--- a/src/main/java/com/xcong/excoin/netty/client/ClientChannelHandler.java
+++ b/src/main/java/com/xcong/excoin/netty/client/ClientChannelHandler.java
@@ -1,5 +1,6 @@
package com.xcong.excoin.netty.client;
+import com.xcong.excoin.netty.common.ClientChannelManager;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import lombok.extern.slf4j.Slf4j;
@@ -19,7 +20,7 @@
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
- log.info("消息收到");
+ ClientChannelManager.addServerGroup(ctx.channel());
}
@Override
@@ -27,4 +28,8 @@
log.info("消息收到");
}
+ @Override
+ public void channelInactive(ChannelHandlerContext ctx) throws Exception {
+ ClientChannelManager.removeServerGroup(ctx.channel());
+ }
}
\ No newline at end of file
--
Gitblit v1.9.1