feat(startup): 集成 KCP 服务器启动

- 添加 IsEnableKcp 和 KcpPort 配置属性
- 在 AppStartUpByServer 中集成 KCP 服务器启动逻辑
- 添加 KCP 服务器相关本地化键

Author: AlianBlank

GameFrameX.Localization/Keys.StartUp.cs

@@ -565,6 +565,72 @@ public static class WebSocketServer
             public const string ServiceNotEnabled = "StartUp.WebSocketServer.ServiceNotEnabled";
         }
 
+        /// <summary>
+        /// KCP服务器相关消息
+        /// </summary>
+        public static class KcpServer
+        {
+            /// <summary>
+            /// 客户端断开连接 - 远程终端: {0}
+            /// </summary>
+            /// <remarks>
+            /// 键名: StartUp.KcpServer.ClientDisconnected
+            /// 用途: 当KCP客户端断开连接时记录
+            /// 参数: {0} - 远程端点
+            /// </remarks>
+            public const string ClientDisconnected = "StartUp.KcpServer.ClientDisconnected";
+
+            /// <summary>
+            /// 新客户端连接 - 远程终端: {0}
+            /// </summary>
+            /// <remarks>
+            /// 键名: StartUp.KcpServer.NewClientConnection
+            /// 用途: 当新KCP客户端连接时记录
+            /// 参数: {0} - 远程端点
+            /// </remarks>
+            public const string NewClientConnection = "StartUp.KcpServer.NewClientConnection";
+
+            /// <summary>
+            /// 启动KCP服务器 类型: {0}, 地址: {1}, 端口: {2}
+            /// </summary>
+            /// <remarks>
+            /// 键名: StartUp.KcpServer.StartingServer
+            /// 用途: 当开始启动KCP服务器时记录
+            /// 参数: {0} - 服务器类型, {1} - 地址, {2} - 端口
+            /// </remarks>
+            public const string StartingServer = "StartUp.KcpServer.StartingServer";
+
+            /// <summary>
+            /// 启动KCP服务器完成 类型: {0}, 地址: {1}, 端口: {2}
+            /// </summary>
+            /// <remarks>
+            /// 键名: StartUp.KcpServer.StartupComplete
+            /// 用途: 当KCP服务器启动完成时记录
+            /// 参数: {0} - 服务器类型, {1} - 地址, {2} - 端口
+            /// </remarks>
+            public const string StartupComplete = "StartUp.KcpServer.StartupComplete";
+
+            /// <summary>
+            /// 启动KCP服务器失败 类型: {0}, 地址: {1}, 端口: {2}, 原因: 端口无效或被占用
+            /// </summary>
+            /// <remarks>
+            /// 键名: StartUp.KcpServer.StartupFailed
+            /// 用途: 当KCP服务器启动失败时记录警告
+            /// 参数: {0} - 服务器类型, {1} - 地址, {2} - 端口
+            /// </remarks>
+            public const string StartupFailed = "StartUp.KcpServer.StartupFailed";
+
+            /// <summary>
+            /// 启动KCP服务器 类型: {0}, 地址: {1}, 端口: {2}, 原因: KCP服务器被禁用
+            /// </summary>
+            /// <remarks>
+            /// 键名: StartUp.KcpServer.ServerDisabled
+            /// 用途: 当KCP服务器被禁用时记录
+            /// 参数: {0} - 服务器类型, {1} - 地址, {2} - 端口
+            /// </remarks>
+            public const string ServerDisabled = "StartUp.KcpServer.ServerDisabled";
+        }
+
         /// <summary>
         /// 发现中心相关消息
         /// </summary>

GameFrameX.StartUp/AppStartUpByServer.cs

@@ -29,11 +29,13 @@
 //  Official Documentation: https://gameframex.doc.alianblank.com/
 // ==========================================================================================
 
+using System.Net;
 using GameFrameX.AppHost.ServiceDefaults;
 using GameFrameX.Foundation.Logger;
 using GameFrameX.Foundation.Localization.Core;
 using GameFrameX.NetWork.Abstractions;
 using GameFrameX.NetWork.HTTP;
+using GameFrameX.NetWork.Kcp;
 using GameFrameX.NetWork.Message;
 using GameFrameX.SuperSocket.Connection;
 using GameFrameX.SuperSocket.Primitives;
@@ -171,6 +173,41 @@ protected virtual ValueTask OnDisconnected(IAppSession appSession, CloseEventArg
         return ValueTask.CompletedTask;
     }
 
+    /// <summary>
+    /// KCP客户端连接成功处理
+    /// </summary>
+    /// <param name="remoteEndPoint">远程端点</param>
+    /// <returns></returns>
+    protected virtual ValueTask OnKcpConnected(EndPoint remoteEndPoint)
+    {
+        LogHelper.Info(LocalizationService.GetString(Localization.Keys.StartUp.KcpServer.NewClientConnection, remoteEndPoint));
+        return ValueTask.CompletedTask;
+    }
+
+    /// <summary>
+    /// KCP消息处理方法
+    /// </summary>
+    /// <param name="session">游戏应用会话</param>
+    /// <param name="message">接收到的消息</param>
+    protected virtual void KcpPackageHandler(IGameAppSession session, IMessage message)
+    {
+        if (Setting.IsDebug && Setting.IsDebugReceive)
+        {
+            LogHelper.Debug(LocalizationService.GetString(Localization.Keys.StartUp.TcpServer.MessageReceived, ServerType, message.ToFormatMessageString()));
+        }
+    }
+
+    /// <summary>
+    /// KCP客户端断开连接处理
+    /// </summary>
+    /// <param name="remoteEndPoint">远程端点</param>
+    /// <returns></returns>
+    protected virtual ValueTask OnKcpDisconnected(EndPoint remoteEndPoint)
+    {
+        LogHelper.Info(LocalizationService.GetString(Localization.Keys.StartUp.KcpServer.ClientDisconnected, remoteEndPoint));
+        return ValueTask.CompletedTask;
+    }
+
     /// <summary>
     /// 客户端连接成功时的处理方法。
     /// </summary>
@@ -358,6 +395,34 @@ private async Task StartServer(List<BaseHttpHandler> baseHandler, Func<string, B
             LogHelper.Info(LocalizationService.GetString(Localization.Keys.StartUp.WebSocketServer.ServiceNotEnabled, ServerType, Setting.WsPort));
         }
 
+        // 启动KCP服务器
+        if (Setting.IsEnableKcp)
+        {
+            var kcpPort = Setting.KcpPort > 0 ? Setting.KcpPort : Setting.InnerPort;
+            if (kcpPort > 0 && NetHelper.PortIsAvailable(kcpPort))
+            {
+                LogHelper.Info(LocalizationService.GetString(Localization.Keys.StartUp.KcpServer.StartingServer, ServerType, Setting.InnerHost, kcpPort));
+                var kcpServer = new KcpServer(
+                    kcpPort,
+                    new KcpOptions { Enable = true },
+                    Setting,
+                    KcpPackageHandler,
+                    OnKcpConnected,
+                    OnKcpDisconnected
+                );
+                _ = kcpServer.StartAsync();
+                LogHelper.Info(LocalizationService.GetString(Localization.Keys.StartUp.KcpServer.StartupComplete, ServerType, Setting.InnerHost, kcpPort));
+            }
+            else
+            {
+                LogHelper.Warning(LocalizationService.GetString(Localization.Keys.StartUp.KcpServer.StartupFailed, ServerType, Setting.InnerHost, kcpPort));
+            }
+        }
+        else
+        {
+            LogHelper.Info(LocalizationService.GetString(Localization.Keys.StartUp.KcpServer.ServerDisabled, ServerType, Setting.InnerHost, Setting.KcpPort));
+        }
+
         // await StartHttpServerAsync(hostBuilder,baseHandler, httpFactory, aopHandlerTypes, minimumLevelLogLevel);
         await StartHttpServer(baseHandler, httpFactory, aopHandlerTypes, minimumLevelLogLevel);
 

GameFrameX.Utility/Setting/AppSetting.cs

@@ -418,6 +418,22 @@ public string ToFormatString()
     /// </remarks>
     public bool IsEnableUdp { get; set; } = false;
 
+    /// <summary>
+    /// 是否启用KCP
+    /// </summary>
+    /// <remarks>
+    /// Whether to enable KCP. Default is false.
+    /// </remarks>
+    public bool IsEnableKcp { get; set; } = false;
+
+    /// <summary>
+    /// KCP端口
+    /// </summary>
+    /// <remarks>
+    /// KCP server port. Default is 0 (uses same port as TCP).
+    /// </remarks>
+    public int KcpPort { get; set; } = 0;
+
     /// <summary>
     /// 内部主机地址
     /// </summary>