???? ??? ??? ??? ????? ?? ??? ???? ?? ? ??? ??? ???? ???? ?? ? ????? ????. ? ???? Workerman? ???? ??? ???? ???? ???? ??? ?????. ???? ??? ?? ??, ?? ??, ?? ?? ? ??? ??? ??? ????? ? ????. ?? ????? ??? ?? ??? ?? ??? ?????. ??? ??? ?? ??? ??????.

Workerman? ?? PHP? ??? ??? TCP/UDP ?? ?????? ?? ???, ?? ?? ?? ? ?? ??? ?????. Workerman? ???? ? ?? ???, ???, ??? ?? ?? ?? ?? ?? ???, ?? ??? ?????? ????? ?? ??? ? ????. ????? Workerman? ???? ??? ???? ???? ???? ??? ?????.

1. Workerman ?????? ???

Workerman? ???? ?? ?????? ?????? ???? ???. ???? Linux ??? ?? ?? Composer? ???? ?????. Workerman? ????? ???? ?? ??? ?????.

composer require Workerman/workerman

??? ??? ? PHP ??? ???? ? ?? Workerman ??????? ??? ? ????.

require_once DIR . '/vendor/autoload.php';

// ?? 2345? ???? websocket ????? ???? ???? ???? ????.
$ws_worker = new WorkermanWorker("websocket:/ /0.0.0.0:2345");

// ?? ??? ??? ?? 4? ???? ??
$ws_worker->count = 4;

// ?????? ????? ???? ?? ???
$ws_worker-> onConnect = function ($connection) {

$connection->send('Welcome to workerman!');

};

// ?????? ???? ??? ?????
$ws_worker->onMessage = function ($connection, $data) {

// 把收到的消息回顯給客戶端
$connection->send($data);

};

/ / ????? ??? ???? ??
$ws_worker->onClose = function ($connection) {

echo "Connection closed

";
};

// ?? Worker
WorkermanWorker::run();

? ?????. ????? ?? 2345? ???? websocket ????? ???? ???? ???? ??????. ?????? ????? ???? ?????? ???? ?? ? ??? ???? ?????? ?????. ????? ??? ??? ??? ????? ???? ?????. ????? Worker? ???? ?????.

2. ??? ???? ?? ??

?? Workerman ??????? ????? ?????? ???? ????. ??? ???? ?? ?? ???? Workerman? ???? ??? ???? ??? ???? ??? ?????. ?? ??? ???? ????? ?????? ?? ???? ???? ??? ?? ???.

??? ???? ???. ???? ????? ??? ??? ?????? ?? ?????? ???? ????? ???? ???. Worker? onMessage ???? ???? ???? ?? ????? ????? ? ????. ??? ??? ?? ????? ?? ???? ??? ??? ????:

require_once

DIR

. '/vendor/autoload.php';use WorkermanLibTimer;use WorkermanWorker;

$ws_worker = new Worker("websocket ://0.0.0.0:2345");

$ws_worker-> count = 4;

$log_dir = '/path/to/log-dir/';

$monitor_interval = 1; // ?? ?? ?? ?? ????, ??: ?

$ws_worker->onMessage = ??( $connection, $data) use($log_dir) {

// do something

};

$ws_worker->onClose = ??($connection) {

echo "Connection closed

";

};

// ?? ?? ????

Timer: :add($monitor_interval, function () use($ws_worker, $log_dir) {

if (!is_dir($log_dir)) {
    return;
}
$files = scandir($log_dir);
foreach ($files as $file) {
    if ($file == "." || $file == "..") {
        continue;
    }
    $filename = $log_dir . '/' . $file;
    if (is_file($filename)) {
        $fp = fopen($filename, 'r');
        $lastpos = $ws_worker->lastpos[$filename] ?? 0;
        fseek($fp, $lastpos);
        $data = fread($fp, filesize($filename) - $lastpos);
        fclose($fp);
        if (!empty($data)) {
            // 實(shí)時(shí)推送日志信息到前端
            foreach($ws_worker->connections as $con){
                if ($con->websocket) {
                    $con->send(json_encode(array(
                        'type' => 'log',
                        'data' => $data,
                        'filename' => $filename
                    )));
                }
            }
            // 更新上次讀取位置
            $ws_worker->lastpos[$filename] = ftell($fp);
        }
    }
}

});

Workerman? Timer ???? ?????. ?? ??? ????? ???? ? ????. ?? ???? ?? ????? ????? ????? ? ????. ?? ??? ?? ? ?? ??? ??? ???? ?? ??? ????? ?? ??? ???? ???. ?? ??? ?? ? ??? ??? ???? ????? ?????.

2.2 ??? ?? ?? ??

??? ???? ????? ??? ?? ?? ?? ???? ?????. ????? ?? ??? ?? ???? ???? ????? ?????? ?? ??? ??? ? ????. ??? ?? ??? ?? ?? ?????.

require_once

DIR

. '/vendor/autoload.php';use WorkermanLibTimer;use WorkermanWorker;

$ws_worker = new Worker("websocket://0.0. 0.0:2345 ");

$ws_worker->count = 4;

$alarm_interval = 1; // ?? ??? ???? ?? ??, ??: ?

$ws_worker->onMessage = function ($connection, $data) {

// do something

};

$ws_worker->onClose = function ($connection) {

echo "Connection closed

";

};

// ?? ??? ????

Timer::add($alarm_interval, function ( ) use( $ws_worker) {

// 監(jiān)控邏輯
$alarm_type = 'warning'; // 告警類型
$alarm_data = 'alarm data'; // 告警數(shù)據(jù)
if ($alarm_type && $alarm_data) {
    // 實(shí)時(shí)推送告警信息到前端
    foreach($ws_worker->connections as $con){
        if ($con->websocket) {
            $con->send(json_encode(array(
                'type' => 'alarm',
                'data' => $alarm_data,
                'alarm_type' => $alarm_type
            )));
        }
    }
}

});

?? ???? ????? ??????, ?? ???? ??? ?? ???? ??? ?????. ?? ???? ???? ?? ??? ????? ??? ??? ?????. .

3. ??

Workerman? ???? ??? ???? ???? ???? ???? ?? ??? ????? ???? ??? ?? ? ?? ??? ???? ???? ?? ? ????. ? ???? Workerman? ???? ???? ????? ?? ???? ? ??? ?? ??? ???? ??? ????, ?? ?? ??? ?????. ??? ??? ???? ?? ???? ??? ?? ???? ?? ??? ??? ???? ???? ??? ? ????.

? ??? Workerman? ???? ??? ???? ???? ???? ??? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!