Change business thread processing to MultithreadEventLoopGroup

fanliang11 · Apr 10, 2024 · 11a1db5 · 11a1db5
1 parent 739c7c8
commit 11a1db5
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/Surging.Core/Surging.Core.DotNetty/DotNettyServerMessageListener.cs b/src/Surging.Core/Surging.Core.DotNetty/DotNettyServerMessageListener.cs
@@ -79,7 +79,7 @@ public async Task StartAsync(EndPoint endPoint)
                 workerGroup = new MultithreadEventLoopGroup();
                 bootstrap.Channel<TcpServerSocketChannel>();
             }
-            var workerGroup1 = new SingleThreadEventLoop();
+            var eventExecutor = new MultithreadEventLoopGroup(); 
             bootstrap
             .Option(ChannelOption.SoBacklog, AppConfig.ServerOptions.SoBacklog)
             .ChildOption(ChannelOption.Allocator, PooledByteBufferAllocator.Default)
@@ -89,8 +89,8 @@ public async Task StartAsync(EndPoint endPoint)
                 var pipeline = channel.Pipeline;
                 pipeline.AddLast(new LengthFieldPrepender(4));
                 pipeline.AddLast(new LengthFieldBasedFrameDecoder(int.MaxValue, 0, 4, 0, 4));
-                pipeline.AddLast(workerGroup1, "HandlerAdapter", new TransportMessageChannelHandlerAdapter(_transportMessageDecoder));
-                pipeline.AddLast(workerGroup1, "ServerHandler", new ServerHandler(async (contenxt, message) =>
+                pipeline.AddLast(eventExecutor, "HandlerAdapter", new TransportMessageChannelHandlerAdapter(_transportMessageDecoder));
+                pipeline.AddLast(eventExecutor, "ServerHandler", new ServerHandler(async (contenxt, message) =>
                 {
                     var sender = new DotNettyServerMessageSender(_transportMessageEncoder, contenxt);
                     await OnReceived(sender, message);
@@ -168,4 +168,4 @@ public override void ExceptionCaught(IChannelHandlerContext context, Exception e
 
         #endregion Help Class
     }
-}
+}