From c484d3aa2399d32093978a77ca220ff3c48aa3c5 Mon Sep 17 00:00:00 2001
From: root <295172551@qq.com>
Date: Tue, 3 Jun 2025 22:16:47 +0800
Subject: [PATCH] =?UTF-8?q?html=20=E5=8F=AF=E4=BB=A5=E6=98=BE=E7=A4=BA?=
 =?UTF-8?q?=E6=94=B6=E5=88=B0=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/CellularManagement.WebAPI/wwwroot/websocket.html       | 6 +++++-
 .../Models/WebSocketOptions.cs                             | 7 +++++++
 2 files changed, 12 insertions(+), 1 deletion(-)

diff --git a/src/CellularManagement.WebAPI/wwwroot/websocket.html b/src/CellularManagement.WebAPI/wwwroot/websocket.html
index fdfab67..0031b7d 100644
--- a/src/CellularManagement.WebAPI/wwwroot/websocket.html
+++ b/src/CellularManagement.WebAPI/wwwroot/websocket.html
@@ -546,7 +546,11 @@
                 socket.onmessage = function(event) {
                     try {
                         const data = JSON.parse(event.data);
-                        addMessage(data.content, true, data.type || 'message');
+                        if (data.payload && data.payload.message) {
+                            addMessage(data.payload.message, true, data.type || 'message');
+                        } else {
+                            addMessage(JSON.stringify(data), true);
+                        }
                     } catch (e) {
                         addMessage(event.data, true);
                     }
diff --git a/src/CellularManagement.WebSocket/Models/WebSocketOptions.cs b/src/CellularManagement.WebSocket/Models/WebSocketOptions.cs
index 99fe0da..09e932c 100644
--- a/src/CellularManagement.WebSocket/Models/WebSocketOptions.cs
+++ b/src/CellularManagement.WebSocket/Models/WebSocketOptions.cs
@@ -26,6 +26,13 @@ namespace CellularManagement.WebSocket.Models
         /// </summary>
         public int MaxMessageSize { get; set; } = 1024*1024;
 
+        /// <summary>
+        /// 最大并发处理数
+        /// 控制同时处理的消息数量，建议设置为 CPU 核心数的 2-4 倍
+        /// 例如：8核CPU建议设置为16-32
+        /// </summary>
+        public int MaxConcurrentProcessing { get; set; } = Environment.ProcessorCount * 2;
+
         /// <summary>
         /// 心跳检测间隔
         /// </summary>