xmCenter/tapi
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

up. 添加worker的admin:worker

Browse Source
This commit is contained in:
u2nyakim 2025-08-28 17:51:45 +08:00
parent cafb7ee07d
commit 3e94fbf4c0
2 changed files with 9 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
app/command/admin/Worker.php
View File

@ -3,7 +3,6 @@
namespace app\command\admin;
use app\http\worker\AdminWorkerHandle;
use think\console\Command;
use think\console\Input;
use think\console\input\Argument;
@ -39,14 +38,19 @@ class Worker extends Command
} else if ($mode == 'g') {
$argv[] = '-g';
}
$handle = new AdminWorkerHandle();
/*
* 创建后台ws链接
*/
$adminWorker = new WmWorker('ws://0.0.0.0:19980');
$adminWorker->onMessage = [$handle, 'onMessage'];
$adminWorker->onClose = [$handle, 'onClose'];
$adminWorker = new WmWorker('websocket://0.0.0.0:19980');
$adminWorker->onMessage = function ($connection, $message) {
var_dump($message);
$this->app->event->trigger('admin.websocket.Open', $connection, $message);
};
$adminWorker->onClose = function ($connection, $message) {
var_dump($message);
$this->app->event->trigger('admin.websocket.Close', $connection, $message);
};
WmWorker::runAll();
}

15
app/http/worker/AdminWorkerHandle.php
View File

@ -1,15 +0,0 @@
<?php
namespace app\http\worker;
class AdminWorkerHandle
{
public function onMessage($connection,$data)
{
$connection->send(json_encode($data));
}
public function onClose()
{
}
}