测试例程跑起来

Author: nnhy

.gitignore

@@ -261,3 +261,4 @@ __pycache__/
 *.pyc
 /BinEcho
 /BinNC
+/BinAgent

Benchmark/Config.cs

@@ -8,9 +8,9 @@ class Config
         #region 属性
         public String Address { get; set; }
 
-        public Int32 Times { get; set; }
+        public Int32 Times { get; set; } = 10000;
 
-        public Int32 Thread { get; set; }
+        public Int32 Thread { get; set; } = 100;
 
         public String Content { get; set; }
         #endregion

Benchmark/Program.cs

@@ -3,7 +3,9 @@
 using System.Linq;
 using System.Reflection;
 using System.Text;
+using System.Threading;
 using System.Threading.Tasks;
+using NewLife.Data;
 using NewLife.Log;
 using NewLife.Net;
 using NewLife.Reflection;
@@ -54,6 +56,7 @@ static void Work(Config cfg)
         {
             var uri = new NetUri(cfg.Address);
             if (cfg.Content.IsNullOrEmpty()) cfg.Content = "学无先后达者为师";
+            var pk = new Packet(cfg.Content.GetBytes());
 
             Console.ForegroundColor = ConsoleColor.Red;
             Console.WriteLine("NewLife.NC v{0}", AssemblyX.Entry.Version);
@@ -62,9 +65,33 @@ static void Work(Config cfg)
             Console.WriteLine("目标：{0}", uri);
             Console.WriteLine("请求：{0:n0}", cfg.Times);
             Console.WriteLine("并发：{0:n0}", cfg.Thread);
-            var buf = cfg.Content.GetBytes();
-            Console.WriteLine("并发：[{0:n0}] {1}", buf.Length, cfg.Content);
+            Console.WriteLine("并发：[{0:n0}] {1}", pk.Count, cfg.Content);
             Console.ResetColor();
+            Console.WriteLine();
+
+            // 多线程
+            var ts = new List<Task>();
+            var total = 0;
+            for (var i = 0; i < cfg.Thread; i++)
+            {
+                var tsk = Task.Run(() =>
+                {
+                    try
+                    {
+                        var client = uri.CreateRemote();
+                        client.Open();
+                        for (var k = 0; k < cfg.Times; k++)
+                        {
+                            client.Send(pk);
+                            Interlocked.Increment(ref total);
+                        }
+                    }
+                    catch { }
+                });
+                ts.Add(tsk);
+            }
+            Task.WaitAll(ts.ToArray());
+            Console.WriteLine("完成：{0:n0}", total);
         }
     }
 }

EchoAgent/EchoAgent.csproj

@@ -17,7 +17,7 @@
     <DebugSymbols>true</DebugSymbols>
     <DebugType>full</DebugType>
     <Optimize>false</Optimize>
-    <OutputPath>bin\Debug\</OutputPath>
+    <OutputPath>..\BinAgent\</OutputPath>
     <DefineConstants>DEBUG;TRACE</DefineConstants>
     <ErrorReport>prompt</ErrorReport>
     <WarningLevel>4</WarningLevel>
@@ -27,7 +27,7 @@
     <PlatformTarget>AnyCPU</PlatformTarget>
     <DebugType>pdbonly</DebugType>
     <Optimize>true</Optimize>
-    <OutputPath>bin\Release\</OutputPath>
+    <OutputPath>..\BinAgent\</OutputPath>
     <DefineConstants>TRACE</DefineConstants>
     <ErrorReport>prompt</ErrorReport>
     <WarningLevel>4</WarningLevel>