|
@@ -1,5 +1,6 @@
|
|
|
using System.Collections.Generic;
|
|
|
using System.Net.Sockets;
|
|
|
+using ET.Client;
|
|
|
|
|
|
namespace ET.Server
|
|
|
{
|
|
@@ -18,25 +19,27 @@ namespace ET.Server
|
|
|
|
|
|
private static async ETTask Start(this BenchmarkClientComponent self)
|
|
|
{
|
|
|
- await ETTask.CompletedTask;
|
|
|
- //await TimerComponent.Instance.WaitAsync(1000);
|
|
|
+ await TimerComponent.Instance.WaitAsync(1000);
|
|
|
|
|
|
- //Scene scene = await SceneFactory.CreateServerScene(self, IdGenerater.Instance.GenerateId(), IdGenerater.Instance.GenerateInstanceId(),
|
|
|
- // self.DomainZone(), "bechmark", SceneType.Benchmark);
|
|
|
-
|
|
|
- //NetClientComponent netClientComponent = scene.AddComponent<NetClientComponent, AddressFamily>(AddressFamily.InterNetwork);
|
|
|
+ Scene scene = await SceneFactory.CreateServerScene(self, IdGenerater.Instance.GenerateId(), IdGenerater.Instance.GenerateInstanceId(),
|
|
|
+ self.DomainZone(), "bechmark", SceneType.Benchmark);
|
|
|
|
|
|
- //using Session session = netClientComponent.Create(StartSceneConfigCategory.Instance.BenchmarkServer.OuterIPPort);
|
|
|
- //List<ETTask<IResponse>> list = new List<ETTask<IResponse>>(100000);
|
|
|
- //for (int j = 0; j < 100000000; ++j)
|
|
|
- //{
|
|
|
- // list.Clear();
|
|
|
- // for (int i = 0; i < list.Capacity; ++i)
|
|
|
- // {
|
|
|
- // list.Add(session.Call(new C2G_Benchmark()));
|
|
|
- // }
|
|
|
- // await ETTaskHelper.WaitAll(list);
|
|
|
- //}
|
|
|
+ NetClientComponent netClientComponent = scene.AddComponent<NetClientComponent, AddressFamily, NetworkProtocol>(
|
|
|
+ AddressFamily.InterNetwork,
|
|
|
+ NetworkProtocol.KCP
|
|
|
+ );
|
|
|
+
|
|
|
+ using Session session = netClientComponent.Create(StartSceneConfigCategory.Instance.BenchmarkServer.OuterIPPort);
|
|
|
+ List<ETTask<IResponse>> list = new List<ETTask<IResponse>>(100000);
|
|
|
+ for (int j = 0; j < 100000000; ++j)
|
|
|
+ {
|
|
|
+ list.Clear();
|
|
|
+ for (int i = 0; i < list.Capacity; ++i)
|
|
|
+ {
|
|
|
+ list.Add(session.Call(new C2G_Benchmark()));
|
|
|
+ }
|
|
|
+ await ETTaskHelper.WaitAll(list);
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|