surging作者出具压测结果

技术分享 2年前 (2022-07-17) 0 999+

前言

首先回应下@wen-wen 所贴的压测报告，我也把我和客户压测碰到的问题，和压测结果贴出来,这个结果是由客户提供的。不会有任何的舞弊手脚问题

问题一：Task.Run慎用

首先在最新的社区版本已经把Task.run全部去掉了(包括了kestrel RPC调用服务)，当你的程序有比较耗时的业务处理的时候，Task可以提升性能，但是不耗时的时候，也许就不能提高性能，反而成为瓶颈，因为当一批Task.run未执行完，新一批的请求又来了，就会阻塞造成cpu的升高，所以之前在netty 的ServerHandler中使用task.run ，在压测不带业务的服务时候，因为都是纳秒级的响应，所以造成了task的阻塞，执行万次的循环压测，CPU一直在20%左右，后续已经通过netty 的业务线程进行处理，CPU一直稳定在6%左右，代码如下

 if (_logger.IsEnabled(LogLevel.Debug))                 _logger.LogDebug($"准备启动服务主机，监听地址：{endPoint}。");              IEventLoopGroup bossGroup = new MultithreadEventLoopGroup(1);             IEventLoopGroup workerGroup = new MultithreadEventLoopGroup();//Default eventLoopCount is Environment.ProcessorCount * 2             var bootstrap = new ServerBootstrap();                         if (AppConfig.ServerOptions.Libuv)             {                 var dispatcher = new DispatcherEventLoopGroup();                 bossGroup = dispatcher;                 workerGroup = new WorkerEventLoopGroup(dispatcher);                 bootstrap.Channel<TcpServerChannel>();             }             else             {                 bossGroup = new MultithreadEventLoopGroup(1);                 workerGroup = new MultithreadEventLoopGroup();                 bootstrap.Channel<TcpServerSocketChannel>();             }             var workerGroup1 = new SingleThreadEventLoop();// 声明业务线程             bootstrap             .Option(ChannelOption.SoBacklog, AppConfig.ServerOptions.SoBacklog)             .ChildOption(ChannelOption.Allocator, PooledByteBufferAllocator.Default)              .Group(bossGroup, workerGroup)             .ChildHandler(new ActionChannelInitializer<IChannel>(channel =>             {                 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) =>                                            {                     var sender = new DotNettyServerMessageSender(_transportMessageEncoder, contenxt);                     await OnReceived(sender, message);                 },  _logger));             }));             try             {                 _channel = await bootstrap.BindAsync(endPoint);                 if (_logger.IsEnabled(LogLevel.Debug))                     _logger.LogDebug($"服务主机启动成功，监听地址：{endPoint}。");             }             catch             {                  _logger.LogError($"服务主机启动失败，监听地址：{endPoint}。 ");
    }
        }