CHECKOK

app/websocket.py

@@ -8,6 +8,7 @@ Created: 2024-01-28
 Modified: 2024-01-28
 """
 
+import os
 from flask_socketio import SocketIO, emit, join_room, leave_room, disconnect
 from flask_jwt_extended import decode_token, get_jwt
 from flask import request
@@ -17,7 +18,9 @@ import logging
 # 初始化 SocketIO
 socketio = SocketIO(
     cors_allowed_origins="*",
-    async_mode='threading',
+    # Use eventlet for production and enable Redis message queue for multi-process/replica support
+    async_mode='eventlet',
+    message_queue=os.getenv('REDIS_URL'),
     logger=True,
     engineio_logger=False
 )
@@ -227,4 +230,4 @@ def init_websocket(app):
     """
     socketio.init_app(app)
     logger.info("WebSocket initialized")
-    return socketio
+    return socketio