|
34 | 34 | using GameFrameX.Foundation.Localization.Core; |
35 | 35 | using GameFrameX.NetWork.Abstractions; |
36 | 36 | using GameFrameX.NetWork.HTTP; |
37 | | -using GameFrameX.NetWork.Kcp; |
| 37 | +// using GameFrameX.NetWork.Kcp; |
38 | 38 | using GameFrameX.NetWork.Message; |
39 | 39 | using GameFrameX.SuperSocket.Connection; |
40 | 40 | using GameFrameX.SuperSocket.Primitives; |
@@ -387,33 +387,33 @@ private async Task StartServer(List<BaseHttpHandler> baseHandler, Func<string, B |
387 | 387 | // 启动KCP服务器 |
388 | 388 | if (Setting.IsEnableKcp) |
389 | 389 | { |
390 | | - var kcpPort = Setting.KcpPort > 0 ? Setting.KcpPort : Setting.InnerPort; |
391 | | - if (kcpPort > 0 && NetHelper.PortIsAvailable(kcpPort)) |
392 | | - { |
393 | | - LogHelper.Info(LocalizationService.GetString(Localization.Keys.StartUp.KcpServer.StartingServer, ServerType, Setting.InnerHost, kcpPort)); |
394 | | - var kcpServer = new KcpServer( |
395 | | - kcpPort, |
396 | | - new KcpOptions { Enable = true }, |
397 | | - Setting, |
398 | | - KcpPackageHandler, |
399 | | - OnKcpConnected, |
400 | | - OnKcpDisconnected |
401 | | - ); |
402 | | - _ = kcpServer.StartAsync(); |
403 | | - LogHelper.Info(LocalizationService.GetString(Localization.Keys.StartUp.KcpServer.StartupComplete, ServerType, Setting.InnerHost, kcpPort)); |
404 | | - } |
405 | | - else |
406 | | - { |
407 | | - LogHelper.Warning(LocalizationService.GetString(Localization.Keys.StartUp.KcpServer.StartupFailed, ServerType, Setting.InnerHost, kcpPort)); |
408 | | - if (kcpPort > 0) |
409 | | - { |
410 | | - var occupiedProcesses = NetHelper.GetPortOccupyingProcesses(kcpPort); |
411 | | - if (occupiedProcesses.Count > 0) |
412 | | - { |
413 | | - LogHelper.Warning($"KCP端口[{kcpPort}]占用详情: {string.Join(" | ", occupiedProcesses)}"); |
414 | | - } |
415 | | - } |
416 | | - } |
| 390 | + // var kcpPort = Setting.KcpPort > 0 ? Setting.KcpPort : Setting.InnerPort; |
| 391 | + // if (kcpPort > 0 && NetHelper.PortIsAvailable(kcpPort)) |
| 392 | + // { |
| 393 | + // LogHelper.Info(LocalizationService.GetString(Localization.Keys.StartUp.KcpServer.StartingServer, ServerType, Setting.InnerHost, kcpPort)); |
| 394 | + // var kcpServer = new KcpServer( |
| 395 | + // kcpPort, |
| 396 | + // new KcpOptions { Enable = true }, |
| 397 | + // Setting, |
| 398 | + // KcpPackageHandler, |
| 399 | + // OnKcpConnected, |
| 400 | + // OnKcpDisconnected |
| 401 | + // ); |
| 402 | + // _ = kcpServer.StartAsync(); |
| 403 | + // LogHelper.Info(LocalizationService.GetString(Localization.Keys.StartUp.KcpServer.StartupComplete, ServerType, Setting.InnerHost, kcpPort)); |
| 404 | + // } |
| 405 | + // else |
| 406 | + // { |
| 407 | + // LogHelper.Warning(LocalizationService.GetString(Localization.Keys.StartUp.KcpServer.StartupFailed, ServerType, Setting.InnerHost, kcpPort)); |
| 408 | + // if (kcpPort > 0) |
| 409 | + // { |
| 410 | + // var occupiedProcesses = NetHelper.GetPortOccupyingProcesses(kcpPort); |
| 411 | + // if (occupiedProcesses.Count > 0) |
| 412 | + // { |
| 413 | + // LogHelper.Warning($"KCP端口[{kcpPort}]占用详情: {string.Join(" | ", occupiedProcesses)}"); |
| 414 | + // } |
| 415 | + // } |
| 416 | + // } |
417 | 417 | } |
418 | 418 | else |
419 | 419 | { |
|
0 commit comments