[增加]1. 增加网络渠道的设置参数配置

GameFrameX · Jul 29, 2024 · c7b17fd · c7b17fd
1 parent 1314ec4
commit c7b17fd
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 2 deletions.
diff --git a/GameFrameX.NetWork/BaseNetWorkChannel.cs b/GameFrameX.NetWork/BaseNetWorkChannel.cs
@@ -1,7 +1,9 @@
 using System.Collections.Concurrent;
 using GameFrameX.Extension;
+using GameFrameX.Log;
 using GameFrameX.NetWork.Abstractions;
 using GameFrameX.NetWork.Messages;
+using GameFrameX.Setting;
 using GameFrameX.SuperSocket.Server.Abstractions.Session;
 using GameFrameX.SuperSocket.WebSocket.Server;
 using GameFrameX.Utility;
@@ -38,6 +40,11 @@ public class BaseNetWorkChannel : INetWorkChannel
         /// </summary>
         public bool IsWebSocket { get; }
 
+        /// <summary>
+        /// 设置
+        /// </summary>
+        public AppSetting Setting { get; }
+
         /// <summary>
         /// WebSocket会话
         /// </summary>
@@ -47,13 +54,17 @@ public class BaseNetWorkChannel : INetWorkChannel
         /// 初始化
         /// </summary>
         /// <param name="session"></param>
+        /// <param name="setting"></param>
         /// <param name="messageEncoder"></param>
         /// <param name="rpcSession"></param>
         /// <param name="isWebSocket"></param>
-        public BaseNetWorkChannel(IGameAppSession session, IMessageEncoderHandler messageEncoder, IRpcSession rpcSession, bool isWebSocket)
+        public BaseNetWorkChannel(IGameAppSession session, AppSetting setting, IMessageEncoderHandler messageEncoder, IRpcSession rpcSession, bool isWebSocket)
         {
+            setting.CheckNotNull(nameof(setting));
+            messageEncoder.CheckNotNull(nameof(messageEncoder));
             Session         = session;
             IsWebSocket     = isWebSocket;
+            Setting         = setting;
             _messageEncoder = messageEncoder;
             RpcSession      = rpcSession;
             if (isWebSocket)
@@ -83,6 +94,10 @@ public virtual async Task WriteAsync(IMessage messageObject, int uniId = 0, int
             messageObject.CheckNotNull(nameof(messageObject));
 
             var messageData = _messageEncoder.Handler(messageObject);
+            if (Setting.IsDebug && Setting.IsDebugSend)
+            {
+                LogHelper.Debug($"---发送{messageObject.ToFormatMessageString()}");
+            }
 
             if (IsWebSocket)
             {

diff --git a/GameFrameX.NetWork/DefaultNetWorkChannel.cs b/GameFrameX.NetWork/DefaultNetWorkChannel.cs
@@ -1,4 +1,5 @@
 using GameFrameX.NetWork.Abstractions;
+using GameFrameX.Setting;
 using GameFrameX.SuperSocket.Server.Abstractions.Session;
 
 namespace GameFrameX.NetWork;
@@ -12,10 +13,11 @@ public class DefaultNetWorkChannel : BaseNetWorkChannel
     /// 初始化
     /// </summary>
     /// <param name="session"></param>
+    /// <param name="setting"></param>
     /// <param name="messageEncoder"></param>
     /// <param name="rpcSession"></param>
     /// <param name="isWebSocket"></param>
-    public DefaultNetWorkChannel(IGameAppSession session, IMessageEncoderHandler messageEncoder, IRpcSession rpcSession = null, bool isWebSocket = false) : base(session, messageEncoder, rpcSession, isWebSocket)
+    public DefaultNetWorkChannel(IGameAppSession session, AppSetting setting, IMessageEncoderHandler messageEncoder, IRpcSession rpcSession = null, bool isWebSocket = false) : base(session,setting, messageEncoder, rpcSession, isWebSocket)
     {
     }
 }