diff --git a/vetti-admin/src/main/java/com/vetti/socket/ChatWebSocketHandler.java b/vetti-admin/src/main/java/com/vetti/socket/ChatWebSocketHandler.java index 477b45d..1477227 100644 --- a/vetti-admin/src/main/java/com/vetti/socket/ChatWebSocketHandler.java +++ b/vetti-admin/src/main/java/com/vetti/socket/ChatWebSocketHandler.java @@ -198,16 +198,16 @@ public class ChatWebSocketHandler { WebSocket webSocket = cacheWebSocket.get(clientId); log.info("获取的socket对象为:{}",webSocket); if(webSocket != null){ - // 1. 启动音频缓冲 - webSocket.send("{\"type\": \"input_audio_buffer.start\"}"); +// 1. 启动音频缓冲 +// webSocket.send("{\"type\": \"input_audio_buffer.start\"}"); log.info("3.1 开始发送数据音频流啦"); // 将音频数据转换为 Base64 编码的字符串 String base64Audio = Base64.getEncoder().encodeToString(bytes); String message = "{ \"type\": \"input_audio_buffer.append\", \"audio\": \"" + base64Audio + "\" }"; webSocket.send(message); // 3. 提交音频并请求转录 - webSocket.send("{\"type\": \"input_audio_buffer.commit\"}"); - webSocket.send("{\"type\": \"response.create\"}"); +// webSocket.send("{\"type\": \"input_audio_buffer.commit\"}"); +// webSocket.send("{\"type\": \"response.create\"}"); } }catch (Exception e){ e.printStackTrace(); @@ -326,6 +326,10 @@ public class ChatWebSocketHandler { config.put("type", "transcription_session.update"); config.put("session", sessionConfig); webSocket.send(config.toString()); + + // 1. 启动音频缓冲 + webSocket.send("{\"type\": \"input_audio_buffer.start\"}"); + //存储客户端webSocket对象,对数据进行隔离处理 cacheWebSocket.put(clientId,webSocket); } diff --git a/vetti-common/src/main/java/com/vetti/common/ai/whisper/RealtimeTranscriptionMicrophone.java b/vetti-common/src/main/java/com/vetti/common/ai/whisper/RealtimeTranscriptionMicrophone.java index 619b96d..d95b76b 100644 --- a/vetti-common/src/main/java/com/vetti/common/ai/whisper/RealtimeTranscriptionMicrophone.java +++ b/vetti-common/src/main/java/com/vetti/common/ai/whisper/RealtimeTranscriptionMicrophone.java @@ -81,8 +81,8 @@ public class RealtimeTranscriptionMicrophone { } // 3. 提交音频并请求转录 - webSocket.send("{\"type\": \"input_audio_buffer.commit\"}"); - webSocket.send("{\"type\": \"response.create\"}"); +// webSocket.send("{\"type\": \"input_audio_buffer.commit\"}"); +// webSocket.send("{\"type\": \"response.create\"}"); } catch (Exception e) { e.printStackTrace(); }