@@ -95,7 +95,7 @@ protected override async ValueTask OnConnected(IAppSession appSession)
9595 /// <param name="message"></param>
9696 protected override async ValueTask PackageHandler ( IAppSession appSession , IMessage message )
9797 {
98- if ( message is OuterNetworkMessage outerNetworkMessage )
98+ if ( message is NetworkMessagePackage messagePackage )
9999 {
100100 var netWorkChannel = SessionManager . GetChannel ( appSession . SessionID ) ;
101101
@@ -105,34 +105,34 @@ protected override async ValueTask PackageHandler(IAppSession appSession, IMessa
105105 }
106106
107107 var actorId = netWorkChannel . GetData < long > ( GlobalConst . ActorIdKey ) ;
108- if ( outerNetworkMessage . Header . OperationType == ( byte ) MessageOperationType . HeartBeat )
108+ if ( messagePackage . Header . OperationType == ( byte ) MessageOperationType . HeartBeat )
109109 {
110110 if ( Setting . IsDebug && Setting . IsDebugReceive && Setting . IsDebugReceiveHeartBeat )
111111 {
112- LogHelper . Debug ( $ "---收到{ outerNetworkMessage . ToFormatMessageString ( actorId ) } ") ;
112+ LogHelper . Debug ( $ "---收到{ messagePackage . ToFormatMessageString ( actorId ) } ") ;
113113 }
114114
115115 // 心跳消息回复
116- ReplyHeartBeat ( netWorkChannel , ( MessageObject ) outerNetworkMessage . DeserializeMessageObject ( ) ) ;
116+ ReplyHeartBeat ( netWorkChannel , ( MessageObject ) messagePackage . DeserializeMessageObject ( ) ) ;
117117 return ;
118118 }
119119
120120 if ( Setting . IsDebug && Setting . IsDebugReceive )
121121 {
122- LogHelper . Debug ( $ "---收到{ outerNetworkMessage . ToFormatMessageString ( actorId ) } ") ;
122+ LogHelper . Debug ( $ "---收到{ messagePackage . ToFormatMessageString ( actorId ) } ") ;
123123 }
124124
125- var handler = HotfixManager . GetTcpHandler ( outerNetworkMessage . Header . MessageId ) ;
125+ var handler = HotfixManager . GetTcpHandler ( messagePackage . Header . MessageId ) ;
126126 if ( handler == null )
127127 {
128- LogHelper . Error ( $ "找不到[{ outerNetworkMessage . Header . MessageId } ][{ message . GetType ( ) } ]对应的handler") ;
128+ LogHelper . Error ( $ "找不到[{ messagePackage . Header . MessageId } ][{ message . GetType ( ) } ]对应的handler") ;
129129 return ;
130130 }
131131
132132 // 执行消息分发处理
133133 try
134134 {
135- await InvokeMessageHandler ( handler , outerNetworkMessage . DeserializeMessageObject ( ) , netWorkChannel ) ;
135+ await InvokeMessageHandler ( handler , messagePackage . DeserializeMessageObject ( ) , netWorkChannel ) ;
136136 }
137137 catch ( Exception exception )
138138 {
0 commit comments