fix(stt.aliyun): do not reuse recognizer

Author: vritser

src/main/java/com/xiaozhi/dialogue/stt/providers/AliyunSttService.java

@@ -23,37 +23,10 @@ public class AliyunSttService implements SttService {
     private static final String PROVIDER_NAME = "aliyun";
     private static final String DEFAULT_MODEL = "paraformer-realtime-v2"; // 默认模型
 
-    // 识别器实例
     private final String apiKey;
-    private Recognition recognizer;
-    private final Object recognizerLock = new Object(); // 用于同步访问recognizer
 
     public AliyunSttService(SysConfig config) {
         this.apiKey = config.getApiKey();
-        // 初始化recognizer
-        createNewRecognizer();
-    }
-
-    /**
-     * 创建新的Recognition实例
-     */
-    private void createNewRecognizer() {
-        synchronized (recognizerLock) {
-            // 如果存在旧的实例，尝试关闭它
-            if (recognizer != null) {
-                try {
-                    if (recognizer.getDuplexApi() != null) {
-                        recognizer.getDuplexApi().close(1000, "创建新实例");
-                    }
-                } catch (Exception e) {
-                    logger.warn("关闭旧的Recognition实例时出错", e);
-                }
-            }
-
-            // 创建新实例
-            recognizer = new Recognition();
-            logger.info("创建了新的Recognition实例");
-        }
     }
 
     @Override
@@ -75,11 +48,7 @@ public String recognition(byte[] audioData) {
 
     @Override
     public String streamRecognition(Sinks.Many<byte[]> audioSink) {
-        // 获取当前的recognizer实例
-        Recognition currentRecognizer;
-        synchronized (recognizerLock) {
-            currentRecognizer = this.recognizer;
-        }
+        var recognizer = new Recognition();
 
         // 创建识别参数
         var param = RecognitionParam.builder()
@@ -92,7 +61,7 @@ public String streamRecognition(Sinks.Many<byte[]> audioSink) {
         // 使用 Reactor 执行流式识别
         var recognition = Flux.<String>create(sink -> {
             try {
-                currentRecognizer.streamCall(param, Flowable.create(emitter -> {
+                recognizer.streamCall(param, Flowable.create(emitter -> {
                             audioSink.asFlux().subscribe(
                                     chunk -> emitter.onNext(ByteBuffer.wrap(chunk)),
                                     emitter::onError,
@@ -109,7 +78,6 @@ public String streamRecognition(Sinks.Many<byte[]> audioSink) {
                                 Throwable::printStackTrace,
                                 sink::complete
                         );
-
             } catch (Exception e) {
                 sink.error(e);
                 logger.info("语音识别失败: {}", e);