[增加]1. 增加消息处理器的时间耗时

Author: AlianBlank

GameFrameX.Core/BaseHandler/BaseComponentHandler.cs

@@ -53,7 +53,7 @@ public override async Task Init(INetworkMessage message, INetWorkChannel netWork
     /// <returns>内部执行任务</returns>
     public override Task InnerAction()
     {
-        CacheComponent.Tell(ActionAsync);
+        CacheComponent.Tell(InnerActionAsync);
         return Task.CompletedTask;
     }
 

GameFrameX.Core/BaseHandler/BaseMessageHandler.cs

@@ -1,57 +1,86 @@
-using GameFrameX.NetWork;
+using System.Diagnostics;
+using GameFrameX.Log;
+using GameFrameX.NetWork;
 using GameFrameX.NetWork.Abstractions;
+using GameFrameX.Setting;
 
-namespace GameFrameX.Core.BaseHandler;
-
-/// <summary>
-/// 基础消息处理器
-/// </summary>
-public abstract class BaseMessageHandler : IMessageHandler
+namespace GameFrameX.Core.BaseHandler
 {
     /// <summary>
-    /// 网络频道
+    /// 基础消息处理器
     /// </summary>
-    public INetWorkChannel NetWorkChannel { get; private set; }
+    public abstract class BaseMessageHandler : IMessageHandler
+    {
+        /// <summary>
+        /// 网络频道
+        /// </summary>
+        public INetWorkChannel NetWorkChannel { get; private set; }
 
-    /// <summary>
-    /// 消息对象
-    /// </summary>
-    public INetworkMessage Message { get; private set; }
+        /// <summary>
+        /// 消息对象
+        /// </summary>
+        public INetworkMessage Message { get; private set; }
 
-    private bool _isInit;
+        private bool _isInit;
 
-    /// <summary>
-    /// 初始化
-    /// 子类实现必须调用
-    /// </summary>
-    /// <param name="message">消息对象</param>
-    /// <param name="netWorkChannel">网络渠道</param>
-    /// <returns></returns>
-    public virtual Task Init(INetworkMessage message, INetWorkChannel netWorkChannel)
-    {
-        Message = message;
-        NetWorkChannel = netWorkChannel;
-        _isInit = true;
-        return Task.CompletedTask;
-    }
+        /// <summary>
+        /// 监控器
+        /// </summary>
+        private Stopwatch _stopwatch;
 
-    /// <summary>
-    /// 动作异步
-    /// </summary>
-    /// <returns></returns>
-    protected abstract Task ActionAsync();
+        /// <summary>
+        /// 初始化
+        /// 子类实现必须调用
+        /// </summary>
+        /// <param name="message">消息对象</param>
+        /// <param name="netWorkChannel">网络渠道</param>
+        /// <returns>初始化任务</returns>
+        public virtual Task Init(INetworkMessage message, INetWorkChannel netWorkChannel)
+        {
+            _stopwatch = new Stopwatch();
+            Message = message;
+            NetWorkChannel = netWorkChannel;
+            _isInit = true;
+            return Task.CompletedTask;
+        }
 
-    /// <summary>
-    /// 执行
-    /// </summary>
-    /// <returns></returns>
-    public virtual Task InnerAction()
-    {
-        if (_isInit == false)
+        /// <summary>
+        /// 动作异步
+        /// </summary>
+        /// <returns>动作执行任务</returns>
+        protected abstract Task ActionAsync();
+
+        /// <summary>
+        /// 内部动作异步
+        /// 记录执行时间并调用 <see cref="ActionAsync"/>
+        /// </summary>
+        /// <returns>动作执行任务</returns>
+        protected Task InnerActionAsync()
         {
-            throw new Exception("消息处理器未初始化,请调用先Init方法，如果已经子类实现了Init方法，请调用在子类Init中调用父类Init方法");
+            if (GlobalSettings.IsDebug)
+            {
+                _stopwatch.Restart();
+                var result = ActionAsync();
+                _stopwatch.Stop();
+                LogHelper.Debug($"消息处理器：{GetType().Name} 执行耗时：{_stopwatch.ElapsedMilliseconds} ms");
+                return result;
+            }
+
+            return ActionAsync();
         }
 
-        return ActionAsync();
+        /// <summary>
+        /// 执行
+        /// </summary>
+        /// <returns>执行任务</returns>
+        public virtual Task InnerAction()
+        {
+            if (_isInit == false)
+            {
+                throw new Exception("消息处理器未初始化,请调用先Init方法，如果已经子类实现了Init方法，请调用在子类Init中调用父类Init方法");
+            }
+
+            return InnerActionAsync();
+        }
     }
 }