


Cara menggunakan Workerman untuk melaksanakan sistem pemantauan masa nyata
Nov 07, 2023 am 11:00 AMDengan 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.
- 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) {
};
// Apabila Apabila pelanggan memutuskan sambungan, proseskannya
$ws_worker->onClose = function ($connection) {
// 把收到的消息回顯給客戶端 $connection->send($data);
";
};
// Run Worker
WorkermanWorker::run();
- memerlukan_sekali DIR
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:
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 .
- 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!

Alat AI Hot

Undress AI Tool
Gambar buka pakaian secara percuma

Undresser.AI Undress
Apl berkuasa AI untuk mencipta foto bogel yang realistik

AI Clothes Remover
Alat AI dalam talian untuk mengeluarkan pakaian daripada foto.

Clothoff.io
Penyingkiran pakaian AI

Video Face Swap
Tukar muka dalam mana-mana video dengan mudah menggunakan alat tukar muka AI percuma kami!

Artikel Panas

Alat panas

Notepad++7.3.1
Editor kod yang mudah digunakan dan percuma

SublimeText3 versi Cina
Versi Cina, sangat mudah digunakan

Hantar Studio 13.0.1
Persekitaran pembangunan bersepadu PHP yang berkuasa

Dreamweaver CS6
Alat pembangunan web visual

SublimeText3 versi Mac
Perisian penyuntingan kod peringkat Tuhan (SublimeText3)

Fail Tetapan.JSON terletak di laluan peringkat pengguna atau ruang kerja dan digunakan untuk menyesuaikan tetapan vscode. 1. Laluan peringkat pengguna: Windows adalah C: \ Users \\ AppData \ Roaming \ code \ user \ settings.json, macOS adalah /users//library/applicationsupport/code/user/settings.json, linux adalah/ 2. Laluan Tahap Ruang Kerja: .VSCODE/Tetapan dalam Direktori Root Projek

Gunakan DateTime.StrpTime () untuk menukar rentetan tarikh ke dalam objek DateTime. 1. Penggunaan Asas: Parse "2023-10-05" sebagai objek DateTime melalui "%y-%m-%d"; 2. Menyokong pelbagai format seperti "%m/%d/%y" untuk menghuraikan tarikh Amerika, "%d/%m/%y" untuk menghuraikan tarikh British, "%b%d,%y%i:%m%p" untuk menghuraikan masa dengan am/pm; 3. Gunakan dateUtil.parser.parse () untuk secara automatik menyimpulkan format yang tidak diketahui; 4. Gunakan .D

Ya, menu drop-down CSS biasa boleh dilaksanakan melalui HTML dan CSS tulen tanpa JavaScript. 1. Gunakan UL dan Li bersarang untuk membina struktur menu; 2. Gunakan: Hover pseudo-Class untuk mengawal paparan dan menyembunyikan kandungan tarik-turun; 3. Tetapkan Kedudukan: Relatif untuk Ibu Bapa Li, dan submenu diletakkan menggunakan kedudukan: mutlak; 4. Submenu mungkir untuk memaparkan: Tiada, yang menjadi paparan: blok apabila melayang; 5. Multi-level pull-down boleh dicapai melalui bersarang, digabungkan dengan peralihan, dan menambah animasi pudar, dan disesuaikan dengan terminal mudah alih dengan pertanyaan media. Penyelesaian keseluruhannya mudah dan tidak memerlukan sokongan JavaScript, yang sesuai untuk besar

@Property Decorator digunakan untuk menukar kaedah ke dalam sifat untuk melaksanakan bacaan, penetapan dan kawalan penghapusan sifat. 1. Penggunaan Asas: Tentukan atribut baca sahaja melalui @property, seperti kawasan yang dikira berdasarkan radius dan diakses secara langsung; 2. Penggunaan Lanjutan: gunakan @name.setter dan @name.deleter untuk melaksanakan pengesahan tugasan atribut dan operasi penghapusan; 3. Aplikasi Praktikal: Melaksanakan pengesahan data dalam setter, seperti BankAccount untuk memastikan bahawa baki tidak negatif; 4. Penamaan Spesifikasi: Pembolehubah dalaman adalah prefixed, nama kaedah harta selaras dengan atribut, dan kawalan akses bersatu digunakan untuk meningkatkan keselamatan kod dan penyelenggaraan.

iTertools.Combinations digunakan untuk menjana semua kombinasi yang tidak berulang (perintah tidak relevan) yang memilih bilangan elemen tertentu dari objek Itable. Penggunaannya termasuk: 1. Pilih 2 kombinasi elemen dari senarai, seperti ('a', 'b'), ('a', 'c'), dan sebagainya, untuk mengelakkan perintah berulang; 2. Ambil 3 kombinasi watak rentetan, seperti "ABC" dan "ABD", yang sesuai untuk penjanaan berikutnya; 3. Cari kombinasi di mana jumlah dua nombor adalah sama dengan nilai sasaran, seperti 1 5 = 6, memudahkan logik gelung berganda; Perbezaan antara kombinasi dan susunan terletak pada sama ada perintah itu penting, kombinasi menganggap Ab dan BA sebagai sama, sementara permutasi dianggap berbeza;

Python adalah alat yang cekap untuk melaksanakan proses ETL. 1. Pengekstrakan data: Data boleh diekstrak dari pangkalan data, API, fail dan sumber lain melalui panda, sqlalchemy, permintaan dan perpustakaan lain; 2. Penukaran Data: Gunakan panda untuk pembersihan, penukaran jenis, persatuan, pengagregatan dan operasi lain untuk memastikan kualiti data dan mengoptimumkan prestasi; 3. Pemuatan Data: Gunakan kaedah Pandas 'TO_SQL atau platform awan SDK untuk menulis data ke sistem sasaran, perhatikan kaedah menulis dan pemprosesan batch; 4. Cadangan Alat: Airflow, Dagster, Prefect digunakan untuk penjadualan dan pengurusan proses, menggabungkan penggera log dan persekitaran maya untuk meningkatkan kestabilan dan mengekalkan.

Perlawanan adalah fungsi yang digunakan untuk menyediakan persekitaran atau data pratetap untuk ujian. 1. Gunakan penghias @pytest.fixture untuk menentukan perlawanan; 2. Suntikan perlawanan dalam bentuk parameter dalam fungsi ujian; 3. Melaksanakan persediaan sebelum hasil, dan kemudian Teardown; 4. Skop kawalan melalui parameter skop, seperti fungsi, modul, dan lain -lain; 5. Letakkan perlawanan bersama dalam conftest.py untuk mencapai perkongsian silang fail, dengan itu meningkatkan kebolehkerjaan dan kebolehgunaan semula ujian.

Gunakan modul UUID untuk mendapatkan alamat MAC kad rangkaian pertama mesin di seluruh platform, tanpa memerlukan perpustakaan pihak ketiga, dan menukarnya menjadi format standard melalui uuid.getNode (); 2. Gunakan subprocess untuk memanggil arahan sistem seperti ipconfig atau ifconfig, dan menggabungkannya dengan pengekstrakan tetap semua alamat kad rangkaian MAC, yang sesuai untuk senario di mana banyak maklumat kad rangkaian perlu diperoleh; 3. Gunakan perpustakaan pihak ketiga getMac, hubungi get_mac_address () selepas pemasangan untuk mendapatkan MAC, yang menyokong pertanyaan melalui antara muka atau IP, tetapi memerlukan ketergantungan tambahan; Ringkasnya, jika tiada perpustakaan luaran diperlukan, kaedah UUID disyorkan. Jika anda perlu fleksibel mendapatkan maklumat kad pelbagai rangkaian, anda boleh menggunakan penyelesaian subprocess untuk membolehkan anda memasang getma ketergantungan.
