|
@@ -23,11 +23,13 @@ $app->make(Illuminate\Contracts\Console\Kernel::class)->bootstrap(); |
|
@@ -23,11 +23,13 @@ $app->make(Illuminate\Contracts\Console\Kernel::class)->bootstrap(); |
|
23
|
$server = new Server("0.0.0.0", 9555);
|
23
|
$server = new Server("0.0.0.0", 9555);
|
|
24
|
|
24
|
|
|
25
|
$server->on('open', function ($server, $request) {
|
25
|
$server->on('open', function ($server, $request) {
|
|
|
|
26
|
+ @file_put_contents(storage_path('logs/lyh_error.log'), var_export('连接已打开', true) . PHP_EOL, FILE_APPEND);
|
|
26
|
// WebSocket 连接已打开
|
27
|
// WebSocket 连接已打开
|
|
27
|
echo "WebSocket 连接已打开\n";
|
28
|
echo "WebSocket 连接已打开\n";
|
|
28
|
});
|
29
|
});
|
|
29
|
|
30
|
|
|
30
|
$server->on('message', function ($server, $frame) {
|
31
|
$server->on('message', function ($server, $frame) {
|
|
|
|
32
|
+ @file_put_contents(storage_path('logs/lyh_error.log'), var_export('收到消息', true) . PHP_EOL, FILE_APPEND);
|
|
31
|
$message = $frame->data;
|
33
|
$message = $frame->data;
|
|
32
|
echo "收到消息: $message\n";
|
34
|
echo "收到消息: $message\n";
|
|
33
|
// 获取客户端连接的文件描述符
|
35
|
// 获取客户端连接的文件描述符
|
|
@@ -47,6 +49,7 @@ $server->on('message', function ($server, $frame) { |
|
@@ -47,6 +49,7 @@ $server->on('message', function ($server, $frame) { |
|
47
|
});
|
49
|
});
|
|
48
|
|
50
|
|
|
49
|
$server->on('close', function ($server, $fd) {
|
51
|
$server->on('close', function ($server, $fd) {
|
|
|
|
52
|
+ @file_put_contents(storage_path('logs/lyh_error.log'), var_export('关闭连接', true) . PHP_EOL, FILE_APPEND);
|
|
50
|
// WebSocket 连接已关闭
|
53
|
// WebSocket 连接已关闭
|
|
51
|
echo "WebSocket 连接已关闭\n";
|
54
|
echo "WebSocket 连接已关闭\n";
|
|
52
|
});
|
55
|
});
|