support async startup netty server

Author: ipipman

src/main/java/cn/ipman/cache/CacheManApplication.java

@@ -2,8 +2,10 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.scheduling.annotation.EnableAsync;
 
 @SpringBootApplication
+@EnableAsync
 public class CacheManApplication {
 
     public static void main(String[] args) {

src/main/java/cn/ipman/cache/server/IMCacheServer.java

@@ -2,17 +2,15 @@
 
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.buffer.PooledByteBufAllocator;
-import io.netty.channel.Channel;
-import io.netty.channel.ChannelInitializer;
-import io.netty.channel.ChannelOption;
-import io.netty.channel.EventLoopGroup;
+import io.netty.channel.*;
 import io.netty.channel.epoll.EpollChannelOption;
 import io.netty.channel.nio.NioEventLoopGroup;
 import io.netty.channel.socket.SocketChannel;
 import io.netty.channel.socket.nio.NioServerSocketChannel;
 import io.netty.handler.logging.LogLevel;
 import io.netty.handler.logging.LoggingHandler;
 import io.netty.util.concurrent.DefaultThreadFactory;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Component;
 
 /**
@@ -35,6 +33,7 @@ public void init() {
         workerGroup = new NioEventLoopGroup(16, new DefaultThreadFactory("redis-work"));
     }
 
+    @Async
     @Override
     public void startup() {
         try {
@@ -65,8 +64,7 @@ protected void initChannel(SocketChannel ch) {
         } catch (Exception e) {
             throw new RuntimeException(e);
         } finally {
-            bossGroup.shutdownGracefully();
-            workerGroup.shutdownGracefully();
+            shutdown();
         }
     }