fix[channel]: wrong channel object was used

net/src/main/java/com/zfoo/net/core/AbstractServer.java

@@ -52,8 +52,6 @@ public abstract class AbstractServer<C extends Channel> extends ChannelInitializ
 
     protected ChannelFuture channelFuture;
 
-    protected Channel channel;
-
     public AbstractServer(HostAndPort host) {
         this.hostAddress = host.getHost();
         this.port = host.getPort();
@@ -91,7 +89,6 @@ public abstract class AbstractServer<C extends Channel> extends ChannelInitializ
         // 异步
         channelFuture = bootstrap.bind(hostAddress, port);
         channelFuture.syncUninterruptibly();
-        channel = channelFuture.channel();
 
         allServers.add(this);
 
@@ -111,14 +108,6 @@ public abstract class AbstractServer<C extends Channel> extends ChannelInitializ
                 logger.warn(e.getMessage(), e);
             }
         }
-
-        if (channel != null) {
-            try {
-                channel.close();
-            } catch (Exception e) {
-                logger.warn(e.getMessage(), e);
-            }
-        }
     }
 
     public synchronized static void shutdownAllServers() {

net/src/main/java/com/zfoo/net/core/tcp/TcpServer.java

@@ -32,7 +32,7 @@ public class TcpServer extends AbstractServer<SocketChannel> {
     }
 
     @Override
-    protected void initChannel(SocketChannel socketChannel) throws Exception {
+    protected void initChannel(SocketChannel channel) throws Exception {
         channel.pipeline().addLast(new IdleStateHandler(0, 0, 180));
         channel.pipeline().addLast(new ServerIdleHandler());
         channel.pipeline().addLast(new TcpCodecHandler());

net/src/main/java/com/zfoo/net/core/udp/UdpServer.java

@@ -57,7 +57,6 @@ public class UdpServer extends AbstractServer<Channel> {
         // 异步
         channelFuture = bootstrap.bind(hostAddress, port);
         channelFuture.syncUninterruptibly();
-        channel = channelFuture.channel();
 
         allServers.add(this);