commons/server-java
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2018-04-24 02:09:12 +09:00
parent 68763a3c73
commit 414c2cdb2f
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/com/loafle/commons/server/Server.java
View File

@ -67,20 +67,26 @@ public abstract class Server {
this.init(); this.init();
ChannelFuture f = serverBootstrap.bind(address).sync(); ChannelFuture cf = this.bind(serverBootstrap);
cf.sync();
this.onStart(); this.onStart();
f.channel().closeFuture().sync(); cf.channel().closeFuture().sync();
this.onStop();
} catch (Exception e) { } catch (Exception e) {
logger.error("Server", e); logger.error("Server", e);
} finally { } finally {
this.onStop();
bossGroup.shutdownGracefully(); bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully(); workerGroup.shutdownGracefully();
this.destroy(); this.destroy();
} }
} }
protected ChannelFuture bind(ServerBootstrap serverBootstrap) throws Exception {
return serverBootstrap.bind(address);
}
protected abstract void init() throws Exception; protected abstract void init() throws Exception;
protected abstract void onStart() throws Exception; protected abstract void onStart() throws Exception;
protected abstract void onStop() throws Exception; protected abstract void onStop() throws Exception;