@@ -49,19 +49,19 @@ public async void RunServer(bool reload)
49
49
private async Task StartServer ( )
50
50
{
51
51
webSocketServer = WebSocketHostBuilder . Create ( )
52
- . UseWebSocketMessageHandler ( WebSocketMessageHandler )
53
- . UseSessionHandler ( OnConnected , OnDisconnected )
54
- . ConfigureAppConfiguration ( ( Action < HostBuilderContext , IConfigurationBuilder > ) ( ConfigureWebServer ) ) . Build ( ) ;
52
+ . UseWebSocketMessageHandler ( WebSocketMessageHandler )
53
+ . UseSessionHandler ( OnConnected , OnDisconnected )
54
+ . ConfigureAppConfiguration ( ( Action < HostBuilderContext , IConfigurationBuilder > ) ( ConfigureWebServer ) ) . Build ( ) ;
55
55
await webSocketServer . StartAsync ( ) ;
56
56
LogHelper . Info ( "启动 WebSocket 服务器完成..." ) ;
57
57
tcpService = SuperSocketHostBuilder . Create < INetworkMessage , MessageObjectPipelineFilter > ( )
58
- . ConfigureSuperSocket ( ConfigureSuperSocket )
59
- . UseClearIdleSession ( )
60
- . UsePackageDecoder < BaseMessageDecoderHandler > ( )
61
- . UseSessionHandler ( OnConnected , OnDisconnected )
62
- . UsePackageHandler ( MessagePackageHandler , ClientErrorHandler )
63
- . UseInProcSessionContainer ( )
64
- . BuildAsServer ( ) ;
58
+ . ConfigureSuperSocket ( ConfigureSuperSocket )
59
+ . UseClearIdleSession ( )
60
+ . UsePackageDecoder < BaseMessageDecoderHandler > ( )
61
+ . UseSessionHandler ( OnConnected , OnDisconnected )
62
+ . UsePackageHandler ( MessagePackageHandler , ClientErrorHandler )
63
+ . UseInProcSessionContainer ( )
64
+ . BuildAsServer ( ) ;
65
65
66
66
await tcpService . StartAsync ( ) ;
67
67
LogHelper . Info ( "启动 TCP 服务器完成..." ) ;
@@ -92,7 +92,8 @@ private ValueTask OnDisconnected(IAppSession appSession, CloseEventArgs disconne
92
92
private ValueTask OnConnected ( IAppSession appSession )
93
93
{
94
94
LogHelper . Info ( "有外部客户端网络连接成功!。链接信息:SessionID:" + appSession . SessionID + " RemoteEndPoint:" + appSession . RemoteEndPoint ) ;
95
- var netChannel = new DefaultNetWorkChannel ( appSession , messageEncoderHandler , null , appSession is WebSocketSession ) ;
95
+
96
+ var netChannel = new DefaultNetWorkChannel ( appSession , Setting , messageEncoderHandler , null , appSession is WebSocketSession ) ;
96
97
GameClientSessionManager . SetSession ( appSession . SessionID , netChannel ) ; //移除
97
98
98
99
return ValueTask . CompletedTask ;
@@ -114,8 +115,8 @@ private async ValueTask WebSocketMessageHandler(WebSocketSession session, WebSoc
114
115
return ;
115
116
}
116
117
117
- var bytes = message . Data ;
118
- var buffer = bytes . ToArray ( ) ;
118
+ var bytes = message . Data ;
119
+ var buffer = bytes . ToArray ( ) ;
119
120
var messageObject = messageDecoderHandler . Handler ( buffer ) ;
120
121
await MessagePackageHandler ( session , messageObject ) ;
121
122
}
@@ -129,10 +130,9 @@ private async ValueTask MessagePackageHandler(IAppSession appSession, INetworkMe
129
130
{
130
131
if ( messageObject is MessageObject message )
131
132
{
132
- var messageId = message . MessageId ;
133
133
if ( Setting . IsDebug && Setting . IsDebugReceive )
134
134
{
135
- LogHelper . Debug ( $ "---收到消息:[ { messageId } , { message . GetType ( ) . Name } ] 消息内容:[ { messageObject } ] ") ;
135
+ LogHelper . Debug ( $ "---收到 { messageObject . ToFormatMessageString ( ) } ") ;
136
136
}
137
137
138
138
var handler = HotfixManager . GetTcpHandler ( message . MessageId ) ;
@@ -142,7 +142,7 @@ private async ValueTask MessagePackageHandler(IAppSession appSession, INetworkMe
142
142
return ;
143
143
}
144
144
145
- handler . Message = message ;
145
+ handler . Message = message ;
146
146
handler . NetWorkChannel = GameClientSessionManager . GetSession ( appSession . SessionID ) ;
147
147
await handler . Init ( ) ;
148
148
await handler . InnerAction ( ) ;
@@ -152,7 +152,7 @@ private async ValueTask MessagePackageHandler(IAppSession appSession, INetworkMe
152
152
private void ConfigureWebServer ( HostBuilderContext context , IConfigurationBuilder builder )
153
153
{
154
154
builder . AddInMemoryCollection ( new Dictionary < string , string > ( )
155
- { { "serverOptions:name" , "GameServer" } , { "serverOptions:listeners:0:ip" , "Any" } , { "serverOptions:listeners:0:port" , Setting . WsPort . ToString ( ) } } ) ;
155
+ { { "serverOptions:name" , "GameServer" } , { "serverOptions:listeners:0:ip" , "Any" } , { "serverOptions:listeners:0:port" , Setting . WsPort . ToString ( ) } } ) ;
156
156
}
157
157
158
158
public async Task StopServer ( )
0 commit comments