diff --git a/src/main/java/com/newyetai/sdk/xf/service/RtasrClientApp.java b/src/main/java/com/newyetai/sdk/xf/service/RtasrClientApp.java
index aeeb9d6..6bbd500 100644
--- a/src/main/java/com/newyetai/sdk/xf/service/RtasrClientApp.java
+++ b/src/main/java/com/newyetai/sdk/xf/service/RtasrClientApp.java
@@ -62,6 +62,7 @@ public class RtasrClientApp extends AbstractRtasrWebSocketListener{
   public void onFail(WebSocket webSocket, Throwable t, Response response) {
     result = AlitaResult.bizError(t.getMessage());
     latch.countDown();
+    webSocket.close(1000, "");
   }
 
   @Override
@@ -69,11 +70,13 @@ public class RtasrClientApp extends AbstractRtasrWebSocketListener{
     logger.error("业务异常，返回信息为：{}", text);
     result = AlitaResult.bizError(text);
     latch.countDown();
+    webSocket.close(1000, "");
   }
 
   @Override
   public void onClosing(WebSocket webSocket, int code, String reason) {
     latch.countDown();
+    webSocket.close(1000, "");
   }
 
   @Override
diff --git a/src/main/java/com/newyetai/sdk/xf/util/WebIATWS.java b/src/main/java/com/newyetai/sdk/xf/util/WebIATWS.java
index 5714fcc..0051ac5 100644
--- a/src/main/java/com/newyetai/sdk/xf/util/WebIATWS.java
+++ b/src/main/java/com/newyetai/sdk/xf/util/WebIATWS.java
@@ -216,6 +216,7 @@ public class WebIATWS extends WebSocketListener {
         log.info("onFailure body:" + response.body().string());
         if (101 != code) {
           log.info("connection failed");
+          webSocket.close(1000, "");
         }
       }
     } catch (IOException e) {
diff --git a/src/main/java/com/newyetai/sdk/xf/util/WebTtsWS.java b/src/main/java/com/newyetai/sdk/xf/util/WebTtsWS.java
index f039229..560c416 100644
--- a/src/main/java/com/newyetai/sdk/xf/util/WebTtsWS.java
+++ b/src/main/java/com/newyetai/sdk/xf/util/WebTtsWS.java
@@ -137,6 +137,7 @@ public class WebTtsWS extends WebSocketListener {
         log.info("onFailure body:" + response.body().string());
         if (101 != code) {
           log.info("connection failed");
+          webSocket.close(1000, "");
         }
       }
     } catch (IOException e) {