Merge branch 'develop' of http://47.244.231.31:8099/zhl/globalso-v6 into develop

@@ -11,24 +11,26 @@ namespace App\Helper;
 
 
 class socket
 class socket
 {
 {
-    public function socket(){
-        // 创建一个Socket
+    public function socket($data){
+        // Socket 服务器的 IP 和端口
+        $socketServerIp = '43.154.15.250';
+        $socketServerPort = 9555; // 替换为实际端口
+        // 创建一个 TCP Socket 客户端
         $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
         $socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
-        // 绑定IP地址和端口
-        socket_bind($socket, '127.0.0.1', 1213);
-        // 开始监听连接请求
-        socket_listen($socket);
-        // 接受客户端连接
-        $clientSocket = socket_accept($socket);
-        // 读取客户端发送的数据
-        $data = socket_read($clientSocket, 1024);
-        // 处理数据
-        $response = "Hello, Client!";
-        $responseLength = strlen($response);
-        // 发送响应给客户端
-        socket_write($clientSocket, $response, $responseLength);
-        // 关闭Socket连接
-        socket_close($clientSocket);
+        if ($socket === false) {
+            return response()->json(['error' => 'Socket creation failed']);
+        }
+        // 连接到 Socket 服务器
+        $result = socket_connect($socket, $socketServerIp, $socketServerPort);
+        if ($result === false) {
+            return response()->json(['error' => 'Socket connection failed']);
+        }
+        // 发送数据到 Socket 服务器
+        socket_write($socket, $data, strlen($data));
+        // 从服务器接收数据
+        $response = socket_read($socket, 1024);
+        // 关闭 Socket 连接
         socket_close($socket);
         socket_close($socket);
+        return response()->json(['response' => $response]);
     }
     }
 }
 }