Workerman을 사용하여 실시간 모니터링 시스템을 구현하는 방법

인터넷의 급속한 발전과 실시간 모니터링에 대한 수요가 증가함에 따라 웹 기반의 실시간 모니터링 시스템이 점점 더 대중화되고 있습니다. 이 글에서는 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)) {
            // 实时推送日志信息到前端
            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) {

// 监控逻辑
$alarm_type = 'warning'; // 告警类型
$alarm_data = 'alarm data'; // 告警数据
if ($alarm_type && $alarm_data) {
    // 实时推送告警信息到前端
    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 중국어 웹사이트의 기타 관련 기사를 참조하세요!