Amalan pengaturcaraan rangkaian pekerja: kes yang berjaya membina sistem penyegerakan data masa nyata

Amalan Pengaturcaraan Rangkaian Pekerja: Kes yang berjaya membina sistem penyegerakan data masa nyata

Pengenalan:
Dengan pembangunan Internet dan pertumbuhan volum data yang berterusan, sistem penyegerakan data masa nyata menjadi lebih banyak dan lebih penting dalam semua bidang kehidupan. Sistem ini boleh memperoleh, memproses dan menghantar data dalam masa nyata, membolehkan peranti terminal yang berbeza memperoleh data terkini dan tepat tepat pada masanya. Artikel ini akan memperkenalkan kes kejayaan sistem penyegerakan data masa nyata berdasarkan rangka kerja pengaturcaraan rangkaian Workerman dan menyediakan contoh kod untuk rujukan pembaca.

1. Apakah itu Pekerja?

Workerman ialah rangka kerja pengaturcaraan rangkaian berprestasi tinggi yang ditulis dalam PHP Ia boleh mengendalikan senario aplikasi rangkaian dengan keperluan bersamaan yang tinggi dan masa nyata. Oleh kerana sifat PHP yang ditafsirkan, ia sentiasa dianggap tidak sesuai untuk membangunkan aplikasi rangkaian berprestasi tinggi. Walau bagaimanapun, Workerman berjaya menyelesaikan masalah ini dengan menggunakan pustaka rangkaian yang ditulis dalam PHP tulen dan menggunakan model dipacu peristiwa tidak menyekat tak segerak.

2. Analisis keperluan sistem penyegerakan data masa nyata

Dalam sistem penyegerakan data masa nyata, terdapat keperluan penting berikut:

1. Masa nyata: Sistem boleh menerima dan memproses sejumlah besar real- data masa tepat pada masanya.
2. Skalabiliti: Sistem boleh berkembang apabila jumlah data bertambah, mengekalkan prestasi tinggi sambil menyokong lebih ramai pengguna dan peranti.
3. Kebolehpercayaan: Sistem boleh mengendalikan pelbagai situasi tidak normal, seperti kegagalan rangkaian, gangguan bekalan elektrik, dsb., untuk memastikan data tidak akan hilang.
4. Keselamatan: Sistem boleh memastikan keselamatan data melalui pengesahan identiti dan penyulitan data.

Berdasarkan keperluan di atas, kami memilih untuk menggunakan Workerman untuk membina sistem penyegerakan data masa nyata.

3. Reka bentuk seni bina sistem

Sistem penyegerakan data masa nyata kami merangkumi komponen teras berikut:

1. Tamat penghantaran data: bertanggungjawab untuk mengumpul dan menghantar data masa nyata kepada sistem.
2. Tamat penerimaan data: Bertanggungjawab untuk menerima dan memproses data masa nyata yang diterima.
3. Terminal storan data: Bertanggungjawab untuk menyimpan data masa nyata yang diterima.
4. Terminal penyegerakan data: Bertanggungjawab untuk menyegerakkan data masa nyata yang diterima ke peranti lain.

Komponen ini berkomunikasi melalui sambungan rangkaian untuk membolehkan penghantaran masa nyata dan penyegerakan data.

4. Contoh Pelaksanaan Sistem

Berikut ialah contoh kod ringkas yang menunjukkan cara menggunakan Workerman untuk membina penghantar dan penerima sistem penyegerakan data masa nyata.

// 文件：sender.php

require_once 'Workerman/Autoloader.php';

use WorkermanWorker;

$sender = new Worker("websocket://0.0.0.0:8000");

$sender->onConnect = function($connection) {
    echo "New connection
";
};

$sender->onMessage = function($connection, $data) {
   echo "Received: " . $data . "
";
   
   // 处理接收到的数据，并发送给接收端
   $receiver = new Client("tcp://127.0.0.1:9000");
   $receiver->send($data);
   $receiver->onMessage = function($receiver, $data) {
       echo "Received by receiver: " . $data . "
";
   };
};

$sender->onClose = function($connection) {
    echo "Connection closed
";
};

Worker::runAll();

// 文件：receiver.php

require_once 'Workerman/Autoloader.php';

use WorkermanWorker;

$receiver = new Worker("websocket://0.0.0.0:9000");

$receiver->onConnect = function($connection) {
    echo "New connection
";
};

$receiver->onMessage = function($connection, $data) {
    echo "Received: " . $data . "
";
   
   // 处理接收到的数据，并持久化存储
   // ...
};

$receiver->onClose = function($connection) {
    echo "Connection closed
";
};

Worker::runAll();

Dalam contoh di atas, sender.php ialah kod di sebelah penghantaran, yang mendengar pada port 8000 dan menyediakan perkhidmatan soket web. Apabila sambungan baharu diwujudkan, fungsi panggil balik onConnect dicetuskan. Apabila data masa nyata diterima, fungsi panggil balik onMessage akan dicetuskan Kami boleh memproses data dalam fungsi ini dan menghantarnya ke bahagian penerima.

receiver.php ialah kod pada bahagian penerima, yang mendengar port 9000 dan menyediakan perkhidmatan soket web. Apabila sambungan baharu diwujudkan, fungsi panggil balik onConnect dicetuskan. Apabila data masa nyata diterima, fungsi panggil balik onMessage akan dicetuskan Kami boleh memproses data dalam fungsi ini dan melakukan operasi seperti storan berterusan.

5. Ringkasan

Menggunakan rangka kerja pengaturcaraan rangkaian Workerman, anda boleh membina sistem penyegerakan data masa nyata dengan mudah. Melalui model dipacu peristiwa tidak menyekat tak segerak, Workerman boleh mengendalikan sejumlah besar sambungan serentak dan memastikan masa nyata dan kebolehpercayaan data. Artikel ini memperkenalkan kes kejayaan sistem penyegerakan data masa nyata berdasarkan Workerman dan menyediakan contoh kod untuk rujukan pembaca. Saya harap pembaca boleh belajar cara menggunakan Workerman untuk membina aplikasi rangkaian berprestasi tinggi dengan membaca artikel ini.

Pautan rujukan:

1. https://www.workerman.net/
2. https://github.com/walkor/Workerman

Atas ialah kandungan terperinci Amalan pengaturcaraan rangkaian pekerja: kes yang berjaya membina sistem penyegerakan data masa nyata. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!