*）修改socket逻辑

amos-boot-module/amos-boot-module-api/amos-boot-module-kgd-api/src/main/java/com/yeejoin/amos/kgd/config/ClientHandler.java

+package com.yeejoin.amos.kgd.config;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.*;
+import java.net.Socket;
+
+/**
+ * @Author: xl
+ * @Description:
+ * @Date: 2023/10/10 16:21
+ */
+public class ClientHandler implements Runnable {
+
+    private static final Logger log = LoggerFactory.getLogger(ClientHandler.class);
+
+    private Socket socket;
+
+    public ClientHandler(Socket socket) {
+        this.socket = socket;
+    }
+
+    @Override
+    public void run() {
+        try {
+            log.info("Received message from client: ");
+            // 获取输入流和输出流
+            InputStream inputStream = socket.getInputStream();
+            // 处理客户端请求,逻辑写到这⬇⬇⬇⬇⬇⬇⬇
+
+
+            log.info("Received message from client: ");
+            // 关闭连接
+            socket.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}
\ No newline at end of file

amos-boot-module/amos-boot-module-api/amos-boot-module-kgd-api/src/main/java/com/yeejoin/amos/kgd/config/SocketConfig.java

@@ -3,6 +3,9 @@ package com.yeejoin.amos.kgd.config;
 import org.springframework.context.annotation.Configuration;
 
 import javax.annotation.PostConstruct;
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
 
 /**
  * @Author: xl
@@ -14,6 +17,17 @@ public class SocketConfig {
 
     @PostConstruct
     public void init() {
-
+        ServerSocket ss = null;
+        try {
+            ss = new ServerSocket(7777);
+            while (true) {
+                Socket socket = ss.accept();
+                // 创建新线程处理连接
+                Thread thread = new Thread(new ClientHandler(socket));
+                thread.start();
+            }
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
     }
 }