Socket.php
1.4 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
<?php
/**
* @remark :
* @name :Socket.php
* @author :lyh
* @method :post
* @time :2023/8/24 10:43
*/
namespace App\Helper;
class Socket
{
public function socket($data){
@file_put_contents(storage_path('logs/lyh_error.log'), var_export(1111, true) . PHP_EOL, FILE_APPEND);
// Socket 服务器的 IP 和端口
$socketServerIp = '127.0.0.1';
$socketServerPort = 9555; // 替换为实际端口
// 创建一个 TCP Socket 客户端
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
@file_put_contents(storage_path('logs/lyh_error.log'), var_export($socket, true) . PHP_EOL, FILE_APPEND);
if ($socket === false) {
return response()->json(['error' => 'Socket creation failed']);
}
// 连接到 Socket 服务器
$result = socket_connect($socket, $socketServerIp, $socketServerPort);
@file_put_contents(storage_path('logs/lyh_error.log'), var_export($result, true) . PHP_EOL, FILE_APPEND);
if ($result === false) {
return response()->json(['error' => 'Socket connection failed']);
}
// 发送数据到 Socket 服务器
socket_write($socket, 'ceshixiaoxi', strlen('ceshixiaoxi'));
// 从服务器接收数据
$response = socket_read($socket, 1024);
// 关闭 Socket 连接
socket_close($socket);
return response()->json(['response' => $response]);
}
}