diff --git a/Html/apps/extensions.py b/Html/apps/extensions.py index 8770550..d55cc80 100644 --- a/Html/apps/extensions.py +++ b/Html/apps/extensions.py @@ -14,7 +14,7 @@ from typing import Optional mongo = PyMongo() -socketio = SocketIO(cors_allowed_origins="*",max_payload_size=52428800, async_mode="eventlet") # 不直接传 app +socketio = SocketIO(cors_allowed_origins="*",max_payload_size=52428800, async_mode="threading") # 不直接传 app cors = CORS() # ===== 你的全局对象 ===== # Backboard @@ -40,7 +40,7 @@ def init_extensions(app): cors_allowed_origins='*',#app.config["VSCODE_WEB_URL"], ping_timeout=app.config["SOCKETIO_PING_TIMEOUT"], ping_interval=app.config["SOCKETIO_PING_INTERVAL"], - max_payload_size=50000000, async_mode="eventlet" + max_payload_size=50000000, async_mode="threading" ) cors.init_app( app, diff --git a/Html/apps/sockets/namespaces.py b/Html/apps/sockets/namespaces.py index 0bd5e32..c4a0eab 100644 --- a/Html/apps/sockets/namespaces.py +++ b/Html/apps/sockets/namespaces.py @@ -129,7 +129,6 @@ class AgentNamespace(Namespace): def receive_ase_next_chapter(client_entry: HSAEngineClient, namespace_entry: Namespace, data, init_data): print("receive_ase_next_chapter", data) namespace_entry.emit('request_function',data, room=init_data['room'], namespace='/agent') # data 是一个列表 /dict也支持 - # namespace_entry.emit('next_chapter', room=init_data['room'], namespace='/agent') def on_initiative(self,data): print("User active function call") diff --git a/Html/apps/static/js/chatbox.js b/Html/apps/static/js/chatbox.js index 9efc92d..bd42120 100644 --- a/Html/apps/static/js/chatbox.js +++ b/Html/apps/static/js/chatbox.js @@ -20,7 +20,6 @@ document.addEventListener('DOMContentLoaded', function() { const serverMessage = document.createElement('div'); serverMessage.innerHTML = `
华实君: ${marked.parse(data)}
`; document.getElementById('chatbox').appendChild(serverMessage); - // 滚动到最新消息 document.getElementById('chatbox').scrollTop = document.getElementById('chatbox').scrollHeight; });