From 0723478ec96dc23627a1585334b7cba0999575e7 Mon Sep 17 00:00:00 2001 From: martsforever Date: Sun, 2 Nov 2025 15:40:54 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20add=5Fwebsocket=5Fvoice=5Frecognise=5Fr?= =?UTF-8?q?oute=20=E5=AE=9E=E6=97=B6=E9=9F=B3=E9=A2=91=E8=AF=86=E5=88=ABwe?= =?UTF-8?q?bsocket=E6=8E=A5=E5=8F=A3,=20rename?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/controller/add_websocket_voice_recognise_route.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/app/controller/add_websocket_voice_recognise_route.py b/app/controller/add_websocket_voice_recognise_route.py index 6a2ab17..bd04b6e 100644 --- a/app/controller/add_websocket_voice_recognise_route.py +++ b/app/controller/add_websocket_voice_recognise_route.py @@ -6,21 +6,21 @@ from starlette.websockets import WebSocketState def add_websocket_voice_recognise_route(app: FastAPI): @app.websocket("/ws_voice_recognise") - async def ws_voice_recognise(websocket: WebSocket, user_id: str = Query(..., description="用户ID")): + async def ws_voice_recognise(receive_socket: WebSocket, user_id: str = Query(..., description="用户ID")): print("新用户连接", user_id) # 接收连接 - await websocket.accept() + await receive_socket.accept() try: while True: # 将接收得到消息发送供其他用户 - pcm_data_string = await websocket.receive_text() + pcm_data_string = await receive_socket.receive_text() pcm_data = json.loads(pcm_data_string) print("pcm_data", pcm_data) # await person_socket.send_text(data) except Exception as e: print(f"WebSocket error: {e}") finally: - if websocket.application_state == WebSocketState.CONNECTING: + if receive_socket.application_state == WebSocketState.CONNECTING: print("关闭websocket") - await websocket.close() + await receive_socket.close() print("websocket已经关闭", user_id)