提交

src/main/java/com/fjhx/MyMain.java

@@ -7,7 +7,10 @@ import com.fjhx.service.impl.ServiceImpl;
 import com.fjhx.utils.BaseWebSocketClient;
 import com.fjhx.utils.MyUtil;
 
-import java.io.*;
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStreamReader;
 import java.net.URISyntaxException;
 import java.nio.charset.StandardCharsets;
 import java.nio.file.Files;
@@ -21,7 +24,7 @@ public class MyMain {
 
     public static void main(String[] args) throws IOException {
 
-        System.out.println("Version： 22-11-15-16-06");
+        System.out.println("Version： 2023-01-17 13:41");
 
         MyUtil.infoLog("程序启动中...");
 

src/main/java/com/fjhx/entity/ConnectConfig.java

@@ -2,8 +2,12 @@ package com.fjhx.entity;
 
 import lombok.Data;
 
+import java.io.Serializable;
+
 @Data
-public class ConnectConfig {
+public class ConnectConfig implements Serializable {
+
+    private static final long serialVersionUID = 1L;
 
     /**
      * ip

src/main/java/com/fjhx/service/impl/ServiceImpl.java

@@ -45,7 +45,7 @@ public class ServiceImpl implements Service {
                 String instructions = data.getString("instructions");
                 // ip配置集合
                 List<ConnectConfig> connectConfigList = MyMain.config.getInstructionsMap().get(instructions);
-                distinctRead(forwardUserId, forwardSessionId, new ArrayList<>(connectConfigList), data);
+                distinctRead(forwardUserId, forwardSessionId, ObjectUtil.clone(connectConfigList), data);
                 break;
             case CLOSE:
                 close(forwardSessionId);