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>