@@ -654,46 +654,21 @@ public static async Task<Dictionary<string, bool>> SendAsync(
654654 return new Dictionary < string , bool > ( ) ;
655655 }
656656
657- var results = new Dictionary < string , bool > ( ) ;
658-
659657 // Check if cluster is enabled / 检查是否启用集群
660658 var clusterManager = GlobalClusterCenter . ClusterManager ;
661659 if ( clusterManager != null )
662660 {
663661 // Use cluster routing / 使用集群路由
664662 var connectionIdsList = connectionIds . ToList ( ) ;
665663 var connectionIdsArray = connectionIdsList . ToArray ( ) ;
666- // 使用静态日志记录(如果可用)
667- try
668- {
669- var loggerFactory = GlobalClusterCenter . ClusterContext ? . ServiceProvider ? . GetService ( typeof ( ILoggerFactory ) ) as ILoggerFactory ;
670- var logger = loggerFactory ? . CreateLogger ( "WebSocketManager" ) ;
671- logger ? . LogInformation ( $ "[WebSocketManager] 使用集群路由发送消息 - ConnectionCount: { connectionIdsArray . Length } , MessageSize: { data . Length } bytes, MessageType: { messageType } , ConnectionIds: { string . Join ( ", " , connectionIdsArray ) } ") ;
672- }
673- catch { }
674664
675665 var results = await clusterManager . RouteMessagesAsync ( connectionIdsArray , data , ( int ) messageType ) ;
676- var successCount = results . Values . Count ( r => r ) ;
677- var failCount = results . Values . Count ( r => ! r ) ;
678-
679- try
680- {
681- var loggerFactory = GlobalClusterCenter . ClusterContext ? . ServiceProvider ? . GetService ( typeof ( ILoggerFactory ) ) as ILoggerFactory ;
682- var logger = loggerFactory ? . CreateLogger ( "WebSocketManager" ) ;
683- logger ? . LogInformation ( $ "[WebSocketManager] 集群路由完成 - 成功: { successCount } , 失败: { failCount } , 总计: { results . Count } ") ;
684- if ( failCount > 0 )
685- {
686- var failedIds = results . Where ( r => ! r . Value ) . Select ( r => r . Key ) . ToArray ( ) ;
687- logger ? . LogWarning ( $ "[WebSocketManager] 集群路由失败连接 - FailedConnectionIds: { string . Join ( ", " , failedIds ) } ") ;
688- }
689- }
690- catch { }
691-
692666 return results ;
693667 }
694668 else
695669 {
696670 // Use local WebSocket / 使用本地 WebSocket
671+ var results = new Dictionary < string , bool > ( ) ;
697672 var tasks = new List < Task > ( ) ;
698673 foreach ( var connectionId in connectionIds )
699674 {
0 commit comments