跟随最新javaim，加入心跳包系统

Author: AlexLiuDev233

app/src/main/java/org/yuezhikong/JavaIMAndroid/ConfigFile.java

@@ -3,4 +3,6 @@
 public class ConfigFile {
     //协议版本
     public static final int ProtocolVersion = 4;
+    //心跳包时间间隔，单位为：毫秒
+    public static int HeartbeatInterval = 30000;
 }

app/src/main/java/org/yuezhikong/JavaIMAndroid/JavaIM/ClientMain.java

@@ -21,6 +21,7 @@
 import com.google.gson.Gson;
 
 import org.jetbrains.annotations.NotNull;
+import org.yuezhikong.JavaIMAndroid.Client;
 import org.yuezhikong.JavaIMAndroid.ConfigFile;
 import org.yuezhikong.JavaIMAndroid.Encryption.KeyData;
 import org.yuezhikong.JavaIMAndroid.Encryption.RSA;
@@ -38,6 +39,8 @@
 import java.net.Socket;
 import java.nio.charset.StandardCharsets;
 import java.util.Scanner;
+import java.util.Timer;
+import java.util.TimerTask;
 import java.util.UUID;
 
 import javax.crypto.SecretKey;
@@ -82,6 +85,21 @@ private void RequestRSA(@NotNull String key, @NotNull Socket client,@NotNull Log
         do {
             json = reader.readLine();
         } while (json == null);
+        if ("Decryption Error".equals(json))
+        {
+            logger.info("你的服务端公钥疑似不正确");
+            logger.info("服务端返回：Decryption Error");
+            logger.info("服务端无法解密");
+            logger.info("客户端正在退出");
+            if (this instanceof Client)
+            {
+                ((Client) this).TerminateClient();
+            }
+            else
+            {
+                System.exit(0);
+            }
+        }
         json = unicodeToString(json);
         protocol = getClient().protocolRequest(json);
         if (protocol.getMessageHead().getVersion() != ConfigFile.ProtocolVersion || !("Test".equals(protocol.getMessageHead().getType())))
@@ -161,6 +179,7 @@ public void start(String ServerAddress,int ServerPort)
     {
         Instance = this;
         Logger logger = LoggerInit();
+        Timer timer = new Timer(true);
         logger.info("正在连接主机：" + ServerAddress + " ，端口号：" + ServerPort);
         try {
             Socket client = new Socket(ServerAddress, ServerPort);
@@ -177,6 +196,20 @@ public void start(String ServerAddress,int ServerPort)
             writer.write("你好，服务端");
             writer.newLine();
             writer.flush();
+            TimerTask task = new TimerTask()
+            {
+                @Override
+                public void run() {
+                    try {
+                        writer.write("Alive");
+                        writer.newLine();
+                        writer.flush();
+                    } catch (IOException e) {
+                        e.printStackTrace();
+                    }
+                }
+            };
+            timer.schedule(task,0,ConfigFile.HeartbeatInterval);
             //测试通讯协议
             NormalProtocol protocol = protocolRequest(unicodeToString(reader.readLine()));
             if (protocol.getMessageHead().getVersion() != ConfigFile.ProtocolVersion || !("Test".equals(protocol.getMessageHead().getType())))
@@ -337,6 +370,11 @@ else if ("Fail".equals(protocol.getMessageBody().getMessage()))
             SendMessage(logger,client,aes);
         } catch (IOException ignored) {
         }
+        timer.cancel();
+        if (this instanceof Client)
+        {
+            ((Client) this).TerminateClient();
+        }
     }
 
     protected void SendMessageToServer(String UserInput, BufferedWriter writer, AES aes) throws IOException