From 915f3ea59a0c30dc6b91a928e2b52f3e95d0bab2 Mon Sep 17 00:00:00 2001 From: zhangshanxue Date: Tue, 17 Dec 2019 11:40:17 +0800 Subject: [PATCH] =?UTF-8?q?=E5=85=B3=E9=97=AD=E6=AD=BB=E9=94=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/ljsd/jieling/netty/server/NettyGameServer.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/netty/src/main/java/com/ljsd/jieling/netty/server/NettyGameServer.java b/netty/src/main/java/com/ljsd/jieling/netty/server/NettyGameServer.java index 0cbcd9959..fb62959de 100644 --- a/netty/src/main/java/com/ljsd/jieling/netty/server/NettyGameServer.java +++ b/netty/src/main/java/com/ljsd/jieling/netty/server/NettyGameServer.java @@ -90,11 +90,11 @@ public class NettyGameServer extends AbstractServer { ChannelFuture channelFuture = serverBootstrap.bind(getLocalAddress().getPort()).sync(); this.channel = channelFuture.channel(); //同步关闭改异步回调 优雅关闭netty - this.channel.closeFuture().addListener((ChannelFutureListener) future -> close()); + this.channel.closeFuture().addListener((ChannelFutureListener) future -> LOGGER.info("netty shutdown completed")); } catch (Exception e) { + close(); throw new ConnectException("close exception", getLocalAddress(), null); } finally { - // close(); } } @@ -136,10 +136,8 @@ public class NettyGameServer extends AbstractServer { } catch (Throwable var2) { LOGGER.error("close NettyChannel exception" + var2); } - bossGroup.shutdownGracefully(); workerGroup.shutdownGracefully(); - } catch (Exception e) { LOGGER.error("close exception", getLocalAddress()); }