1.0.8

main_app/build.gradle

@@ -18,8 +18,8 @@ android {
         applicationId "com.ihaoin.hooloo.device"
         minSdkVersion 26
         targetSdkVersion 30
-        versionCode 7
-        versionName "1.0.7"
+        versionCode 8
+        versionName "1.0.8"
 
         ndk {
             //选择要添加的对应 cpu 类型的 .so 库。

main_app/src/main/java/com/ihaoin/hooloo/device/base/MachineInfoSocket.java

@@ -40,9 +40,22 @@ public class MachineInfoSocket extends Thread {
         }
     }
 
+    private void reconnect() {
+        try {
+            mSocket = IO.socket(Base.NSP_MACHINE);
+            mSocket.connect();
+        } catch (Exception e) {
+            Utils.i("连接server失败，错误原因：" + e.getMessage());
+            e.printStackTrace();
+        }
+    }
+
     private Emitter.Listener onConnect = args -> Utils.i("machine socket connected");
 
-    private Emitter.Listener onDisconnect = args -> Utils.i("machine socket disconnected");
+    private Emitter.Listener onDisconnect = args -> {
+        Utils.i("machine socket disconnected");
+        reconnect();
+    };
 
     public void close() {
         try {

main_app/src/main/java/com/ihaoin/hooloo/device/interaction/InteractionSocket.java

@@ -41,12 +41,26 @@ public class InteractionSocket extends Thread {
         }
     }
 
+    private void reconnect() {
+        try {
+            mSocket = IO.socket(Base.NSP_INTERACTION);
+            mSocket.connect();
+        } catch (Exception e) {
+            Utils.i("连接server失败，错误原因：" + e.getMessage());
+            e.printStackTrace();
+        }
+
+    }
+
     private Emitter.Listener onConnect = args -> {
         Utils.i("interaction socket connected");
         mSocket.emit("notice", "test", (Ack) ack -> process("notice", ack));
     };
 
-    private Emitter.Listener onDisconnect = args -> Utils.i("interaction socket disconnected");
+    private Emitter.Listener onDisconnect = args -> {
+        Utils.i("interaction socket disconnected");
+        reconnect();
+    };
 
     private Emitter.Listener onReply = args -> {
         Utils.i("interaction socket reply");

main_app/src/main/java/com/ihaoin/hooloo/device/kds/KDSSocket.java

@@ -41,12 +41,25 @@ public class KDSSocket extends Thread {
         }
     }
 
+    private void reconnect() {
+        try {
+            mSocket = IO.socket(Base.NSP_KDS);
+            mSocket.connect();
+        } catch (Exception e) {
+            Utils.i("连接server失败，错误原因：" + e.getMessage());
+            e.printStackTrace();
+        }
+    }
+
     private Emitter.Listener onConnect = args -> {
         Utils.i("kds socket connected");
         mSocket.emit("notice", "test", (Ack) ack -> Utils.i("notice: " + JsonUtils.toString(ack)));
     };
 
-    private Emitter.Listener onDisconnect = args -> Utils.i("kds socket disconnected");
+    private Emitter.Listener onDisconnect = args -> {
+        Utils.i("kds socket disconnected");
+        reconnect();
+    };
 
     private Emitter.Listener onReply = args -> {
         Utils.i("kds socket reply");

main_app/src/main/java/com/ihaoin/hooloo/device/update/UpdateSocket.java

@@ -53,6 +53,19 @@ public class UpdateSocket extends Thread {
         }
     }
 
+    private void reconnect() {
+        try {
+            mSocket = IO.socket(Base.NSP_UPGRADE);
+            mSocket.connect();
+        } catch (Exception e) {
+            Utils.i(AppConfig.TAG_UPDATE, "连接server失败，错误原因：" + e.getMessage());
+            if (AppConfig.DEBUG) {
+                Utils.showToast(mContext, "连接server失败，错误原因：" + e.getMessage(), Toast.LENGTH_LONG);
+            }
+            e.printStackTrace();
+        }
+    }
+
     private Emitter.Listener onConnect = args -> {
         Utils.i(AppConfig.TAG_UPDATE, "update socket connected");
         if (AppConfig.DEBUG) {
@@ -62,7 +75,8 @@ public class UpdateSocket extends Thread {
     };
 
     private Emitter.Listener onDisconnect = args -> {
-        Utils.i(AppConfig.TAG_UPDATE, "update socket disconnected");
+        Utils.i(AppConfig.TAG_UPDATE, "update socket disconnected");;
+        reconnect();
         if (AppConfig.DEBUG) {
             Utils.showToast(mContext, "update socket, 断开连接", Toast.LENGTH_LONG);
         }