From b6615de779c11bb09910ae83525c20236d3d1f8a Mon Sep 17 00:00:00 2001 From: "SmallChi(Koike)" <564952747@qq.com> Date: Sun, 15 Dec 2019 23:16:35 +0800 Subject: [PATCH] =?UTF-8?q?1.=E4=BF=AE=E6=94=B9=E5=AE=A2=E6=88=B7=E7=AB=AF?= =?UTF-8?q?=E5=88=9D=E5=A7=8B=E5=8C=96=E8=BF=9E=E6=8E=A5=E5=B0=86=E5=90=8C?= =?UTF-8?q?=E6=AD=A5=E6=94=B9=E4=B8=BA=E5=BC=82=E6=AD=A5=202.=E4=BF=AE?= =?UTF-8?q?=E6=94=B9=E5=85=88=E5=BB=BA=E7=AB=8B=E8=BF=9E=E6=8E=A5=E5=9C=A8?= =?UTF-8?q?=E6=89=B9=E9=87=8F=E8=AF=B7=E6=B1=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../Services/CleintBenchmarkHostedService.cs | 62 ++++++++++--------- .../appsettings.json | 3 +- src/JT808.DotNetty.Client/JT808TcpClient.cs | 6 +- 3 files changed, 41 insertions(+), 30 deletions(-) diff --git a/src/JT808.DotNetty.CleintBenchmark/Services/CleintBenchmarkHostedService.cs b/src/JT808.DotNetty.CleintBenchmark/Services/CleintBenchmarkHostedService.cs index b6d61ab..69bcf96 100644 --- a/src/JT808.DotNetty.CleintBenchmark/Services/CleintBenchmarkHostedService.cs +++ b/src/JT808.DotNetty.CleintBenchmark/Services/CleintBenchmarkHostedService.cs @@ -23,10 +23,6 @@ namespace JT808.DotNetty.CleintBenchmark.Services private readonly IJT808TcpClientFactory jT808TcpClientFactory; - private CancellationTokenSource cts=new CancellationTokenSource(); - - private TaskFactory taskFactory; - public CleintBenchmarkHostedService( ILoggerFactory loggerFactory, IJT808TcpClientFactory jT808TcpClientFactory, @@ -35,7 +31,6 @@ namespace JT808.DotNetty.CleintBenchmark.Services this.jT808TcpClientFactory = jT808TcpClientFactory; clientBenchmarkOptions = clientBenchmarkOptionsAccessor.Value; logger = loggerFactory.CreateLogger("CleintBenchmarkHostedService"); - taskFactory = new TaskFactory(); } public Task StartAsync(CancellationToken cancellationToken) { @@ -44,39 +39,50 @@ namespace JT808.DotNetty.CleintBenchmark.Services ThreadPool.GetMaxThreads(out var maxWorkerThreads, out var maxCompletionPortThreads); logger.LogInformation($"GetMinThreads:{minWorkerThreads}-{minCompletionPortThreads}"); logger.LogInformation($"GetMaxThreads:{maxWorkerThreads}-{maxCompletionPortThreads}"); - //ThreadPool.SetMaxThreads(20, 20); - //ThreadPool.GetMaxThreads(out var setMaxWorkerThreads, out var setMaxCompletionPortThreads); - //logger.LogInformation($"SetMaxThreads:{setMaxWorkerThreads}-{setMaxCompletionPortThreads}"); + //先建立连接 for (int i=0;i< clientBenchmarkOptions.DeviceCount; i++) { - taskFactory.StartNew((item) => + var client = jT808TcpClientFactory.Create(new JT808DeviceConfig((i+1+ clientBenchmarkOptions.DeviceTemplate).ToString(), + clientBenchmarkOptions.IP, + clientBenchmarkOptions.Port)); + } + + ThreadPool.QueueUserWorkItem((state) => + { + while (!cancellationToken.IsCancellationRequested) { - var client = jT808TcpClientFactory.Create(new JT808DeviceConfig(((int)item+1+ clientBenchmarkOptions.DeviceTemplate).ToString(), clientBenchmarkOptions.IP, clientBenchmarkOptions.Port)); - int lat = new Random(1000).Next(100000, 180000); - int Lng = new Random(1000).Next(100000, 180000); - while (!cts.IsCancellationRequested) + Parallel.ForEach(jT808TcpClientFactory.GetAll(), new ParallelOptions { MaxDegreeOfParallelism = 100 }, (item) => { - client.Send(JT808MsgId.位置信息汇报.Create(client.DeviceConfig.TerminalPhoneNo,new JT808_0x0200() + try { - Lat = lat, - Lng = Lng, - GPSTime = DateTime.Now, - Speed = 50, - Direction = 30, - AlarmFlag = 5, - Altitude = 50, - StatusFlag = 10 - })); - Thread.Sleep(clientBenchmarkOptions.Interval); - } - }, i,cts.Token); - } + int lat = new Random(1000).Next(100000, 180000); + int Lng = new Random(1000).Next(100000, 180000); + item.Send(JT808MsgId.位置信息汇报.Create(item.DeviceConfig.TerminalPhoneNo, new JT808_0x0200() + { + Lat = lat, + Lng = Lng, + GPSTime = DateTime.Now, + Speed = 50, + Direction = 30, + AlarmFlag = 5, + Altitude = 50, + StatusFlag = 10 + })); + } + catch (Exception ex) + { + logger.LogError(ex, ""); + } + }); + Thread.Sleep(clientBenchmarkOptions.Interval); + } + }); return Task.CompletedTask; } public Task StopAsync(CancellationToken cancellationToken) { - cts.Cancel(); + jT808TcpClientFactory.Dispose(); logger.LogInformation("StopAsync..."); return Task.CompletedTask; } diff --git a/src/JT808.DotNetty.CleintBenchmark/appsettings.json b/src/JT808.DotNetty.CleintBenchmark/appsettings.json index eb6044b..21a624a 100644 --- a/src/JT808.DotNetty.CleintBenchmark/appsettings.json +++ b/src/JT808.DotNetty.CleintBenchmark/appsettings.json @@ -13,9 +13,10 @@ } }, "ClientBenchmarkOptions": { - "IP": "", + "IP": "127.0.0.1", "Port": 808, "DeviceCount": 100, + "Interval": 1000, "DeviceTemplate": 300000 //需要多台机器同时访问，那么可以根据这个避开重复终端号 100000-200000-300000 } } diff --git a/src/JT808.DotNetty.Client/JT808TcpClient.cs b/src/JT808.DotNetty.Client/JT808TcpClient.cs index 7baefd9..dc67dad 100644 --- a/src/JT808.DotNetty.Client/JT808TcpClient.cs +++ b/src/JT808.DotNetty.Client/JT808TcpClient.cs @@ -14,6 +14,7 @@ using JT808.DotNetty.Client.Metadata; using JT808.DotNetty.Client.Codecs; using JT808.DotNetty.Client.Services; using JT808.Protocol; +using System.Threading.Tasks; namespace JT808.DotNetty.Client { @@ -57,7 +58,10 @@ namespace JT808.DotNetty.Client channel.Pipeline.AddLast("jt808TcpClientConnection", new JT808TcpClientConnectionHandler(this)); channel.Pipeline.AddLast("jt808TcpService", new JT808TcpClientHandler(jT808ReceiveAtomicCounterService,this)); })); - clientChannel = bootstrap.ConnectAsync(IPAddress.Parse(DeviceConfig.TcpHost), DeviceConfig.TcpPort).Result; + Task.Run(async () => + { + clientChannel = await bootstrap.ConnectAsync(IPAddress.Parse(DeviceConfig.TcpHost), DeviceConfig.TcpPort); + }); } public async void Send(JT808ClientRequest request)