Cara menggunakan Workerman untuk melaksanakan sistem pemantauan masa nyata

Dengan perkembangan pesat Internet dan peningkatan permintaan orang ramai untuk pemantauan masa nyata, sistem pemantauan masa nyata berdasarkan Web menjadi semakin popular. Artikel ini akan memperkenalkan cara menggunakan Workerman untuk melaksanakan sistem pemantauan masa nyata Sistem ini boleh memantau berbilang jenis data seperti yang diperlukan, seperti log, penunjuk prestasi, status mesin, dll. Ia juga menyediakan fungsi penggera masa nyata untuk membantu pentadbir. memahami status operasi sistem tepat pada masanya.

Workerman ialah rangka kerja pelayan TCP/UDP berprestasi tinggi yang ditulis dalam PHP tulen, yang mempunyai ciri konkurensi tinggi, kependaman rendah dan pengembangan mudah. Menggunakan Workerman, anda boleh melaksanakan beberapa senario aplikasi berprestasi tinggi dan berkonkurensi tinggi dengan mudah, seperti perkhidmatan pautan panjang, bilik sembang, pelayan permainan dalam talian, dsb. Di bawah ini kami akan memperkenalkan cara menggunakan Workerman untuk melaksanakan sistem pemantauan masa nyata.

1. Buat aplikasi Workerman

Sebelum menggunakan Workerman, anda perlu memuat turun dan memasang rangka kerja. Di sini kami mengambil persekitaran Linux sebagai contoh dan menggunakan komposer untuk memasangnya. Masukkan arahan berikut dalam terminal untuk memasang Workerman:

composer memerlukan workerman/workerman

Selepas pemasangan selesai, kami boleh mencipta aplikasi Workerman pertama kami dengan mencipta fail PHP.

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

// Cipta Pekerja untuk mendengar port 2345 dan berkomunikasi menggunakan protokol websocket
$ws_worker = new WorkermanW /0.0. 0.0:2345");

// Mulakan 4 proses untuk menyediakan perkhidmatan kepada dunia luar
$ws_worker->count = 4;

// Apabila pelanggan berjaya menyambung, hantar mesej alu-aluan
$ws_worker ->onConnect = function ($connection) {

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

};

// Apabila pelanggan menghantar data, proseskannya
$ws_worker->onMessage = function ($connection, $data) {

rreee

};

// Apabila Apabila pelanggan memutuskan sambungan, proseskannya
$ws_worker->onClose = function ($connection) {

// 把收到的消息回显给客户端
$connection->send($data);

";
};

// Run Worker
WorkermanWorker::run();

dalam kod di atas, kami mencipta Worker untuk mendengar port 2345 dan berkomunikasi menggunakan protokol websocket Apabila pelanggan berjaya menyambung, mesej alu-aluan akan dihantar apabila pelanggan menghantar data, data yang diterima akan digemakan ke klien; Apabila pelanggan memutuskan sambungan, mesej bahawa sambungan ditutup akan dikeluarkan. tidak memenuhi keperluan masa nyata kami Seterusnya, kami akan memperkenalkan cara menggunakan Workerman untuk melaksanakan fungsi pemantauan masa nyata Pertama, kami perlu menjelaskan data yang perlu dipantau oleh sistem pemantauan masa nyata log sebagai contoh

Sistem pemantauan masa nyata kami perlu memantau log yang dihasilkan dalam sistem perniagaan dan menolaknya ke bahagian hadapan untuk paparan dalam masa nyata Fungsi panggil balik onMessage Pekerja, dan kemudian hantar kandungan log ke bahagian hadapan dalam masa nyata:

2. memerlukan_sekali
DIR

'/vendor/autoload.php';

use WorkermanLibTimer;

use WorkermanWorker;

_

=$baru. ("websocket://0.0.0.0:2345");

$ws_worker-> count = 4;

$log_dir = '/path/to/log-dir/';$monitor_interval = 1; Selang masa untuk memantau fail log, unit: saat

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

echo "Connection closed

};

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

// do something

";
};

// Pantau fail log

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

echo "Connection closed

});

Workerman menyediakan Kelas pemasa, yang boleh mencetuskan fungsi panggil balik dengan kerap Kami boleh menggunakannya untuk memantau direktori log dengan kerap. Apabila membaca kandungan log, anda perlu memberi perhatian kepada kedudukan bacaan terakhir untuk mengelakkan membaca kandungan pada kedudukan yang sama berulang kali. Selepas membaca kandungan log, tolaknya ke hujung hadapan untuk paparan dalam masa nyata.

2.2 Merealisasikan fungsi penggera masa nyata

Dalam sistem pemantauan masa nyata, fungsi penggera masa nyata juga merupakan bahagian penting. Kami boleh menghantar maklumat penggera ke bahagian hadapan dalam masa nyata apabila peristiwa penggera yang dikesan oleh pemantauan berlaku. Berikut ialah contoh kod untuk fungsi amaran:

require_once

DIR

. '/vendor/autoload.php';

use WorkermanLibTimer;

use WorkermanWorker;

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

$ws_worker->count = 4;

$alarm_interval = 1; // Selang masa untuk memantau peristiwa penggera, unit: saat
$ws_worker->onMessage = fungsi ($sambungan, $data) {

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);
        }
    }
}

};

$ws_worker->onClose = fungsi ($sambungan) {

// do something

";

};

// Pantau peristiwa penggera

Pemasa::tambah($alarm_interval, fungsi ($ ) gunakan( $ws_worker) {

echo "Connection closed

});

Pantau peristiwa penggera dengan kerap, dan logik pemantauan dilaksanakan mengikut keperluan perniagaan tertentu Apabila peristiwa penggera berlaku, maklumat penggera ditolak ke bahagian hadapan dalam masa nyata .

3. Ringkasan

Menggunakan Workerman untuk melaksanakan sistem pemantauan masa nyata boleh membantu kami memahami status berjalan sistem dalam masa nyata dan meningkatkan kecekapan dan ketepatan operasi dan penyelenggaraan sistem. Artikel ini memperkenalkan cara menggunakan Workerman untuk melaksanakan pemantauan log dan fungsi penggera masa nyata dalam sistem pemantauan, dan juga menyediakan contoh kod yang sepadan. Dengan asas ini, kami boleh mengembangkan dengan sewajarnya mengikut keperluan perniagaan tertentu dan melengkapkan sistem pemantauan masa nyata yang lebih lengkap.

Atas ialah kandungan terperinci Cara menggunakan Workerman untuk melaksanakan sistem pemantauan masa nyata. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!