diff --git a/net/src/main/java/com/zfoo/net/core/AbstractServer.java b/net/src/main/java/com/zfoo/net/core/AbstractServer.java index 63cd609a..6bdc4084 100644 --- a/net/src/main/java/com/zfoo/net/core/AbstractServer.java +++ b/net/src/main/java/com/zfoo/net/core/AbstractServer.java @@ -52,8 +52,6 @@ public abstract class AbstractServer 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 extends ChannelInitializ // 异步 channelFuture = bootstrap.bind(hostAddress, port); channelFuture.syncUninterruptibly(); - channel = channelFuture.channel(); allServers.add(this); @@ -111,14 +108,6 @@ public abstract class AbstractServer 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() { diff --git a/net/src/main/java/com/zfoo/net/core/tcp/TcpServer.java b/net/src/main/java/com/zfoo/net/core/tcp/TcpServer.java index 5e9ef313..59c1ec83 100644 --- a/net/src/main/java/com/zfoo/net/core/tcp/TcpServer.java +++ b/net/src/main/java/com/zfoo/net/core/tcp/TcpServer.java @@ -32,7 +32,7 @@ public class TcpServer extends AbstractServer { } @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()); diff --git a/net/src/main/java/com/zfoo/net/core/udp/UdpServer.java b/net/src/main/java/com/zfoo/net/core/udp/UdpServer.java index 3ae45ad1..1774de76 100644 --- a/net/src/main/java/com/zfoo/net/core/udp/UdpServer.java +++ b/net/src/main/java/com/zfoo/net/core/udp/UdpServer.java @@ -57,7 +57,6 @@ public class UdpServer extends AbstractServer { // 异步 channelFuture = bootstrap.bind(hostAddress, port); channelFuture.syncUninterruptibly(); - channel = channelFuture.channel(); allServers.add(this);