[增加] 增加Actor 初始化异常的问题容错

Author: AlianBlank

GameFrameX.Core/BaseHandler/BaseComponentHandler.cs

@@ -1,7 +1,9 @@
 using GameFrameX.Core.Abstractions.Agent;
 using GameFrameX.Core.Actors;
+using GameFrameX.Core.Utility;
 using GameFrameX.Foundation.Logger;
 using GameFrameX.NetWork.Abstractions;
+using Serilog;
 
 namespace GameFrameX.Core.BaseHandler;
 
@@ -29,30 +31,50 @@ public abstract class BaseComponentHandler : BaseMessageHandler
     /// 初始化
     /// </summary>
     /// <returns>初始化任务</returns>
-    protected abstract Task InitActor();
+    protected abstract Task<bool> InitActor();
 
     /// <summary>
     /// 初始化
     /// </summary>
     /// <param name="message">网络消息</param>
     /// <param name="netWorkChannel">网络通道</param>
     /// <returns>初始化任务</returns>
-    public override async Task Init(INetworkMessage message, INetWorkChannel netWorkChannel)
+    public override async Task<bool> Init(INetworkMessage message, INetWorkChannel netWorkChannel)
     {
-        await base.Init(message, netWorkChannel);
-        await InitActor();
+        var initSuccess = await base.Init(message, netWorkChannel);
+        if (!initSuccess)
+        {
+            return false;
+        }
+
+        initSuccess = await InitActor();
+        if (!initSuccess)
+        {
+            return false;
+        }
+
         if (CacheComponent == null)
         {
             if (ActorId == default)
             {
                 LogHelper.Fatal($"ActorId is 0, can not get component，{message.GetType().FullName}, close channel");
                 NetWorkChannel.Close();
-                return;
+                return false;
             }
 
-            CacheComponent = await ActorManager.GetComponentAgent(ActorId, ComponentAgentType);
-            // LogHelper.Info(CacheComp);
+            try
+            {
+                CacheComponent = await ActorManager.GetComponentAgent(ActorId, ComponentAgentType);
+            }
+            catch (Exception e)
+            {
+                Log.Fatal(e, "get component failed, close channel");
+                NetWorkChannel.Close();
+                return false;
+            }
         }
+
+        return true;
     }
 
     /// <summary>

GameFrameX.Core/BaseHandler/BaseMessageHandler.cs

@@ -35,13 +35,13 @@ public abstract class BaseMessageHandler : IMessageHandler
     /// <param name="message">消息对象</param>
     /// <param name="netWorkChannel">网络渠道</param>
     /// <returns>初始化任务</returns>
-    public virtual Task Init(INetworkMessage message, INetWorkChannel netWorkChannel)
+    public virtual Task<bool> Init(INetworkMessage message, INetWorkChannel netWorkChannel)
     {
         _stopwatch = new Stopwatch();
         Message = message;
         NetWorkChannel = netWorkChannel;
         _isInit = true;
-        return Task.CompletedTask;
+        return Task.FromResult(true);
     }
 
     /// <summary>

GameFrameX.Core/BaseHandler/GlobalComponentHandler.cs

@@ -13,7 +13,7 @@ public abstract class GlobalComponentHandler : BaseComponentHandler
     /// 初始化
     /// </summary>
     /// <returns></returns>
-    protected override Task InitActor()
+    protected override Task<bool> InitActor()
     {
         if (ActorId <= 0)
         {
@@ -22,7 +22,7 @@ protected override Task InitActor()
             ActorId = ActorIdGenerator.GetActorId(actorType);
         }
 
-        return Task.CompletedTask;
+        return Task.FromResult(true);
     }
 }
 

GameFrameX.Core/BaseHandler/PlayerComponentHandler.cs

@@ -13,7 +13,7 @@ public abstract class PlayerComponentHandler : BaseComponentHandler
     /// 初始化
     /// </summary>
     /// <returns></returns>
-    protected override Task InitActor()
+    protected override Task<bool> InitActor()
     {
         if (ActorId <= 0)
         {
@@ -25,7 +25,7 @@ protected override Task InitActor()
             ActorId = ActorIdGenerator.GetActorId(GlobalConst.ActorTypePlayer);
         }
 
-        return Task.CompletedTask;
+        return Task.FromResult(true);
     }
 }
 

GameFrameX.Hotfix/Logic/Player/Login/ReqPlayerLoginHandler.cs

@@ -8,7 +8,7 @@ internal sealed class ReqPlayerLoginHandler : PlayerComponentHandler<PlayerCompo
     /// 这个地方需要设置ActorID为玩家的ID,否则会报错，该代码只会执行一次。全局唯一。不能移除该代码，也请不要修改该函数ActorID
     /// </summary>
     /// <returns></returns>
-    protected override Task InitActor()
+    protected override Task<bool> InitActor()
     {
         if (ActorId <= 0 && Message is ReqPlayerLogin reqPlayerLogin)
         {

GameFrameX.NetWork/IMessageHandler.cs

@@ -30,7 +30,7 @@ public interface IMessageHandler
     /// <param name="message">消息对象</param>
     /// <param name="netWorkChannel">网络渠道</param>
     /// <returns></returns>
-    Task Init(INetworkMessage message, INetWorkChannel netWorkChannel);
+    Task<bool> Init(INetworkMessage message, INetWorkChannel netWorkChannel);
 
     /// <summary>
     /// 内部执行