sxc/Vetti-Service-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

STT流式输入业务逻辑处理

Browse Source
This commit is contained in:
wangxiangshun
2025-10-18 23:46:31 +08:00
parent 6d0a08fcaa
commit d46581e1dc
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
vetti-admin/src/main/java/com/vetti/socket/ChatWebSocketHandler.java
View File

@@ -353,18 +353,18 @@ public class ChatWebSocketHandler {
@Override @Override
public void onFailure(WebSocket webSocket, Throwable t, Response response) { public void onFailure(WebSocket webSocket, Throwable t, Response response) {
System.err.println("❌ 连接失败: " + t.getMessage()); System.err.println("❌ 连接失败: " + t.getMessage());
latch.countDown(); // latch.countDown();
} }
@Override @Override
public void onClosing(WebSocket webSocket, int code, String reason) { public void onClosing(WebSocket webSocket, int code, String reason) {
System.out.println("⚠️ 连接即将关闭: " + reason); System.out.println("⚠️ 连接即将关闭: " + reason);
webSocket.close(1000, null); webSocket.close(1000, null);
latch.countDown(); // latch.countDown();
} }
}); });
// 等待 WebSocket 关闭 // 等待 WebSocket 关闭
latch.await(); // latch.await();
}catch (Exception e){ }catch (Exception e){
e.printStackTrace(); e.printStackTrace();
} }