[增加]1. 增加网络发送消息给客户端的时候导致其他消息卡住的问题

Author: AlianBlank

GameFrameX.NetWork.Abstractions/INetWorkChannel.cs

@@ -18,11 +18,16 @@ public interface INetWorkChannel
     IRpcSession RpcSession { get; }
 
     /// <summary>
-    /// 异步写入消息
+    /// 异步写入消息到网络通道
     /// </summary>
-    /// <param name="msg">消息对象</param>
-    /// <param name="errorCode">错误码</param>
-    /// <returns></returns>
+    /// <param name="msg">要发送的网络消息对象,包含消息内容和相关元数据</param>
+    /// <param name="errorCode">错误码,默认为0表示无错误。当发生错误时,可以通过此参数传递错误码</param>
+    /// <returns>表示异步操作的Task对象。当消息成功写入时完成,如果发生错误则抛出异常</returns>
+    /// <remarks>
+    /// 此方法用于将消息异步发送到网络通道。
+    /// 如果errorCode不为0,接收方可以根据错误码进行相应的错误处理。
+    /// 调用此方法时需要确保网络通道处于打开状态。
+    /// </remarks>
     Task WriteAsync(INetworkMessage msg, int errorCode = 0);
 
     /// <summary>

GameFrameX.NetWork/BaseNetWorkChannel.cs

@@ -23,6 +23,11 @@ public class BaseNetWorkChannel : INetWorkChannel
     /// </summary>
     protected readonly CancellationTokenSource CancellationTokenSource = new();
 
+    /// <summary>
+    /// 网络发送超时时间,单位秒
+    /// </summary>
+    protected readonly TimeSpan NetWorkSendTimeOutSecondsTimeSpan;
+
     /// <summary>
     /// 初始化
     /// </summary>
@@ -37,6 +42,7 @@ public BaseNetWorkChannel(IGameAppSession session, AppSetting setting, IRpcSessi
         IsWebSocket = isWebSocket;
         Setting = setting;
         RpcSession = rpcSession;
+        NetWorkSendTimeOutSecondsTimeSpan = TimeSpan.FromSeconds(Setting.NetWorkSendTimeOutSeconds);
         if (isWebSocket)
         {
             _webSocketSession = (WebSocketSession)session;
@@ -101,22 +107,22 @@ public virtual async Task WriteAsync(INetworkMessage messageObject, int errorCod
             return;
         }
 
-        if (IsWebSocket)
+        using (var cts = new CancellationTokenSource(NetWorkSendTimeOutSecondsTimeSpan))
         {
             try
             {
-                await _webSocketSession.SendAsync(messageData);
-            }
-            catch (Exception e)
-            {
-                LogHelper.Error(e);
+                if (IsWebSocket)
+                {
+                    await _webSocketSession.SendAsync(messageData, cts.Token);
+                }
+                else
+                {
+                    await GameAppSession.SendAsync(messageData, cts.Token);
+                }
             }
-        }
-        else
-        {
-            try
+            catch (OperationCanceledException exception)
             {
-                await GameAppSession.SendAsync(messageData);
+                LogHelper.Error($"消息发送超时被取消:{exception.Message}");
             }
             catch (Exception e)
             {