~

src/main/java/com/iflytop/digester/underframework/connection/UfZcancmderWebsocket.java

@@ -184,6 +184,9 @@ public class UfZcancmderWebsocket extends UfConnectionBase {
                 } catch (InterruptedException e) {
                     throw new RuntimeException(e);
                 }
+                if ( this.client.isOpen() ) {
+                    break ;
+                }
                 try {
                     Thread.sleep(1000);
                 } catch (InterruptedException e) {