Refactor session ID handling: replace `current_session_id` with `SessionIdManager` for thread-safe management, update related imports and references.

src/VoiceDialogue/api/routes/system_routes.py

@@ -4,6 +4,7 @@ import time
 
 from fastapi import APIRouter, HTTPException, BackgroundTasks, Request
 
+from core.constants import session_manager
 from ..core.service_factories import get_audio_capture_service_definition
 from ..schemas.system_schemas import (
     SystemStatusResponse, SystemResponse
@@ -77,6 +78,7 @@ async def start_system(
 
         # 更新状态
         _system_status["status"] = "starting"
+        session_manager.reset_id()
 
         # 在后台启动系统
         background_tasks.add_task(
@@ -162,7 +164,7 @@ async def restart_system(
             await stop_system(fastapi_request)
 
         # 再启动
-        return await start_system( fastapi_request, background_tasks)
+        return await start_system(fastapi_request, background_tasks)
 
     except Exception as e:
         logger.error(f"系统重启失败: {e}", exc_info=True)

src/VoiceDialogue/core/constants.py

@@ -1,9 +1,9 @@
 import multiprocessing
 import threading
-import uuid
 from collections import OrderedDict
 
 from utils.cache import LRUCacheDict
+from .session_id_manager import SessionIdManager
 from .state_manager import VoiceStateManager
 
 # ======================= 音频配置常量 =======================
@@ -44,7 +44,7 @@ voice_state_manager = VoiceStateManager()
 
 # 会话缓存
 chat_history_cache: dict[str, OrderedDict] = {}
-current_session_id: str = f'{uuid.uuid4()}'
+session_manager: SessionIdManager = SessionIdManager()
 dropped_audio_cache = LRUCacheDict(maxsize=50)
 
 # ======================= 线程事件对象 =======================

src/VoiceDialogue/core/session_id_manager.py

@@ -0,0 +1,34 @@
+import threading
+import uuid
+
+
+class SessionIdManager:
+    def __init__(self):
+        self._current_id: str = f'{uuid.uuid4()}'
+        self._lock = threading.Lock()  # 为线程安全添加锁
+
+    def get_id(self) -> str:
+        """获取当前的会话ID (线程安全)。"""
+        with self._lock:
+            return self._current_id
+
+    def set_id(self, new_id: str) -> None:
+        """设置新的会话ID (线程安全)。"""
+        with self._lock:
+            self._current_id = new_id
+
+    def reset_id(self) -> str:
+        """生成一个新的UUID作为会话ID，并更新当前ID，然后返回新的ID (线程安全)。"""
+        with self._lock:
+            self._current_id = f'{uuid.uuid4()}'
+            return self._current_id
+
+    @property
+    def current_id(self) -> str:
+        """通过属性方式获取当前的会话ID (线程安全)。"""
+        return self.get_id()
+
+    @current_id.setter
+    def current_id(self, value: str) -> None:
+        """通过属性方式设置新的会话ID (线程安全)。"""
+        self.set_id(value)

src/VoiceDialogue/services/speech/monitor.py

@@ -13,12 +13,12 @@ from queue import Empty
 import librosa
 import numpy as np
 
-from models.voice_task import VoiceTask
 from core.base import BaseThread
 from core.constants import (
-    voice_state_manager, silence_over_threshold_event, user_still_speaking_event, current_session_id
+    voice_state_manager, silence_over_threshold_event, user_still_speaking_event, session_manager
 )
 from core.enums import AudioState
+from models.voice_task import VoiceTask
 
 
 class SpeechMonitorConfig:
@@ -185,7 +185,7 @@ class SpeechStateMonitor(BaseThread):
         Returns:
             VoiceTask: 创建的语音任务
         """
-        voice_task = VoiceTask(id=self.task_id, session_id=current_session_id)
+        voice_task = VoiceTask(id=self.task_id, session_id=session_manager.current_id)
         voice_task.answer_id = f'{uuid.uuid4()}'
         voice_task.user_voice = audio_frames.copy()
         voice_task.send_time = time.time()