1
1
using System . Collections . Concurrent ;
2
2
using GameFrameX . Extension ;
3
+ using GameFrameX . Log ;
3
4
using GameFrameX . NetWork . Abstractions ;
4
5
using GameFrameX . NetWork . Messages ;
6
+ using GameFrameX . Setting ;
5
7
using GameFrameX . SuperSocket . Server . Abstractions . Session ;
6
8
using GameFrameX . SuperSocket . WebSocket . Server ;
7
9
using GameFrameX . Utility ;
@@ -38,6 +40,11 @@ public class BaseNetWorkChannel : INetWorkChannel
38
40
/// </summary>
39
41
public bool IsWebSocket { get ; }
40
42
43
+ /// <summary>
44
+ /// 设置
45
+ /// </summary>
46
+ public AppSetting Setting { get ; }
47
+
41
48
/// <summary>
42
49
/// WebSocket会话
43
50
/// </summary>
@@ -47,13 +54,17 @@ public class BaseNetWorkChannel : INetWorkChannel
47
54
/// 初始化
48
55
/// </summary>
49
56
/// <param name="session"></param>
57
+ /// <param name="setting"></param>
50
58
/// <param name="messageEncoder"></param>
51
59
/// <param name="rpcSession"></param>
52
60
/// <param name="isWebSocket"></param>
53
- public BaseNetWorkChannel ( IGameAppSession session , IMessageEncoderHandler messageEncoder , IRpcSession rpcSession , bool isWebSocket )
61
+ public BaseNetWorkChannel ( IGameAppSession session , AppSetting setting , IMessageEncoderHandler messageEncoder , IRpcSession rpcSession , bool isWebSocket )
54
62
{
63
+ setting . CheckNotNull ( nameof ( setting ) ) ;
64
+ messageEncoder . CheckNotNull ( nameof ( messageEncoder ) ) ;
55
65
Session = session ;
56
66
IsWebSocket = isWebSocket ;
67
+ Setting = setting ;
57
68
_messageEncoder = messageEncoder ;
58
69
RpcSession = rpcSession ;
59
70
if ( isWebSocket )
@@ -83,6 +94,10 @@ public virtual async Task WriteAsync(IMessage messageObject, int uniId = 0, int
83
94
messageObject . CheckNotNull ( nameof ( messageObject ) ) ;
84
95
85
96
var messageData = _messageEncoder . Handler ( messageObject ) ;
97
+ if ( Setting . IsDebug && Setting . IsDebugSend )
98
+ {
99
+ LogHelper . Debug ( $ "---发送{ messageObject . ToFormatMessageString ( ) } ") ;
100
+ }
86
101
87
102
if ( IsWebSocket )
88
103
{
0 commit comments