fix: MVC响应通过集群,release version

Author: Cyaim

Cyaim.WebSocketServer/Cyaim.WebSocketServer/Infrastructure/Handlers/MvcHandler/MvcChannelHandler.cs

@@ -601,14 +601,15 @@ private async Task MvcForwardSendData(WebSocket webSocket, HttpContext context,
                 object invokeResult = await MvcDistributeAsync(webSocketOption, context, webSocket, request, requestBody, logger, appLifetime);
 
                 // 发送结果给客户端
-                //string serialJson = JsonSerializer.Serialize(invokeResult, webSocketOption.DefaultResponseJsonSerializerOptions);
-                //await webSocket.SendAsync(new ArraySegment<byte>(Encoding.UTF8.GetBytes(serialJson)), result.MessageType, result.EndOfMessage, CancellationToken.None);
-
-                // 序列化响应以获取大小
+                // 使用统一的SendAsync方法，自动适配单机和集群模式
+                // Use unified SendAsync method, automatically adapts to single machine or cluster mode
+                var connectionId = context.Connection.Id;
+                
+                // 序列化响应以获取大小（用于统计）
                 string serialJson = JsonSerializer.Serialize(invokeResult, webSocketOption.DefaultResponseJsonSerializerOptions);
                 var responseBytes = Encoding.UTF8.GetBytes(serialJson);
-
-                await invokeResult.SendLocalAsync(webSocketOption.DefaultResponseJsonSerializerOptions, result.MessageType, timeout: ResponseSendTimeout, encoding: Encoding.UTF8, sendBufferSize: SendTextBufferSize, socket: webSocket).ConfigureAwait(false);
+                
+                await WebSocketManager.SendAsync(connectionId, invokeResult, webSocketOption.DefaultResponseJsonSerializerOptions, Encoding.UTF8).ConfigureAwait(false);
 
                 // 记录消息发送指标
                 var currentNodeId = Infrastructure.Cluster.GlobalClusterCenter.ClusterContext?.NodeId;
@@ -668,10 +669,22 @@ private async Task MvcForwardSendData(WebSocket webSocket, HttpContext context,
                 object invokeResult = await MvcDistributeAsync(webSocketOption, context, webSocket, request, requestBody, logger, appLifetime);
 
                 // 发送结果给客户端
-                //string serialJson = JsonSerializer.Serialize(invokeResult, webSocketOption.DefaultResponseJsonSerializerOptions);
-                //await webSocket.SendAsync(new ArraySegment<byte>(Encoding.UTF8.GetBytes(serialJson)), result.MessageType, result.EndOfMessage, CancellationToken.None);
+                // 使用统一的SendAsync方法，自动适配单机和集群模式
+                // Use unified SendAsync method, automatically adapts to single machine or cluster mode
+                var connectionId = context.Connection.Id;
+                
+                // 序列化响应以获取大小（用于统计）
+                string serialJson = JsonSerializer.Serialize(invokeResult, webSocketOption.DefaultResponseJsonSerializerOptions);
+                var responseBytes = Encoding.UTF8.GetBytes(serialJson);
+                
+                await WebSocketManager.SendAsync(connectionId, invokeResult, webSocketOption.DefaultResponseJsonSerializerOptions, Encoding.UTF8).ConfigureAwait(false);
+
+                // 记录消息发送指标
+                var currentNodeId = Infrastructure.Cluster.GlobalClusterCenter.ClusterContext?.NodeId;
+                _metricsCollector?.RecordMessageSent(responseBytes.Length, currentNodeId, context.Request.Path);
 
-                await invokeResult.SendLocalAsync(webSocketOption.DefaultResponseJsonSerializerOptions, result.MessageType, timeout: ResponseSendTimeout, encoding: Encoding.UTF8, sendBufferSize: SendTextBufferSize, socket: webSocket).ConfigureAwait(false);
+                // 记录统计信息（如果统计记录器可用）
+                Infrastructure.Cluster.GlobalClusterCenter.StatisticsRecorder?.RecordBytesSent(context.Connection.Id, responseBytes.Length);
             }
             catch (JsonException ex)
             {