decode交由其他线程

insert-app/src/main/java/db/netty/NettyServer.java

@@ -98,7 +98,7 @@ public class NettyServer {
                     @Override
                     public void initChannel(final Channel ch) throws Exception {
                         ChannelPipeline p = ch.pipeline();
-                        p.addLast(encoder, decoder);
+                        p.addLast(workerGroup, encoder, decoder);
                         p.addLast(workerGroup, nettyServerHandler);
                     }
                 });