From 11a1db513c9a1e27059a9739aa064a730afbe4b1 Mon Sep 17 00:00:00 2001 From: fanliang11 <137629448@qq.com> Date: Wed, 10 Apr 2024 17:49:41 +0800 Subject: [PATCH] Change business thread processing to MultithreadEventLoopGroup Change business thread processing to MultithreadEventLoopGroup --- .../DotNettyServerMessageListener.cs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/Surging.Core/Surging.Core.DotNetty/DotNettyServerMessageListener.cs b/src/Surging.Core/Surging.Core.DotNetty/DotNettyServerMessageListener.cs index 0b813e14..09480f25 100644 --- 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(); } - 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 } -} \ No newline at end of file +}