Rumah >rangka kerja php >Workerman >Amalan pengaturcaraan rangkaian pekerja: membina sistem penyegerakan data masa nyata
Amalan pengaturcaraan rangkaian pekerja: membina sistem penyegerakan data masa nyata
Pengenalan:
Kini, dengan perkembangan pesat Internet dan populariti peranti pintar, sistem penyegerakan data masa nyata telah menjadi bahagian yang amat diperlukan dalam pelbagai industri. Sistem penyegerakan data masa nyata boleh segera menyegerakkan data daripada satu sumber kepada berbilang sasaran, memastikan ketepatan dan ketepatan masa data. Artikel ini akan memperkenalkan cara menggunakan pustaka sambungan PHP Workerman untuk membina sistem penyegerakan data masa nyata yang cekap. Berbanding dengan model pengaturcaraan rangkaian tradisional, Workerman disukai secara meluas oleh pembangun kerana prestasi tinggi dan kemudahan penggunaannya.
1. Pengenalan kepada Workerman
Workerman ialah rangka kerja pengaturcaraan rangkaian berbilang proses yang dibangunkan berdasarkan PHP. Ia menggunakan model dipacu peristiwa untuk mengendalikan komunikasi rangkaian konkurensi tinggi, dan menyokong berbilang protokol seperti TCP, UDP dan WebSocket. Sebagai rangka kerja rangkaian tak segerak sepenuhnya, Workerman dapat mengendalikan berbilang sambungan secara serentak dalam setiap proses untuk mencapai penghantaran data masa nyata yang cekap.
2. Prinsip penyegerakan data masa nyata
Prinsip teras sistem penyegerakan data masa nyata ialah model terbitkan/langganan. Sumber data bertindak sebagai penerbit dan menerbitkan data ke baris gilir mesej atau perisian tengah mesej. Pelanggan menerima data daripada baris gilir mesej atau perisian tengah mesej dengan melanggan topik yang sepadan dan memprosesnya dengan sewajarnya. Dengan cara ini, saluran data masa nyata yang boleh dipercayai diwujudkan antara sumber data dan pelanggan.
3. Bina sistem penyegerakan data masa nyata
Pasang Workerman
composer require workerman/workerman
Buat pelayan sumber data
<?php use WorkermanWorker; // 创建一个Worker监听端口2345,使用TCP协议 $worker = new Worker('tcp://0.0.0.0:2345'); // 启动4个进程对外提供服务 $worker->count = 4; // 当客户端有新的连接时 $worker->onConnect = function($connection) { // 向新连接的客户端发送一条欢迎消息 $connection->send('Welcome to Data Source Server'); }; // 当客户端发送消息过来时 $worker->onMessage = function($connection, $data) { // 发布消息到"topic1"这个主题 $topic1 = new Topic('topic1'); $topic1->publish($data); }; // 运行Worker Worker::runAll();
Cipta pelanggan pelanggan
<?php use WorkermanWorker; use WorkermanLibTimer; // 创建一个Worker监听端口5678,使用TCP协议 $worker = new Worker("tcp://0.0.0.0:5678"); // 启动1个进程对外提供服务 $worker->count = 1; // 当客户端有新的连接时 $worker->onConnect = function($connection) { // 向新连接的客户端发送一条欢迎消息 $connection->send('Welcome to Subscriber Server'); }; // 当客户端发送消息过来时 $worker->onMessage = function($connection, $data) { // 订阅"topic1"这个主题,并设置收到消息的回调 $topic1 = new Topic('topic1'); $topic1->subscribe($connection, function($data) use ($connection) { // 将消息发送给订阅者 $connection->send('Received: '.$data); }); }; // 运行Worker Worker::runAll();
<?php use WorkermanChannelClient; class Topic { private $channel; public function __construct($topic) { $this->channel = new Client(); // 建立连接 $this->channel->connect('127.0.0.1', 2206); } public function publish($data) { // 发布消息 $this->channel->publish($data); } public function subscribe($connection, $callback) { // 订阅主题 $this->channel->subscribe($connection->id, function($data) use ($connection, $callback) { $callback($data); }); } }
php data_source.php start
php subscriber.php start
kepada
Pub langganan Mesej yang diterima oleh pelangganAtas ialah kandungan terperinci Amalan pengaturcaraan rangkaian pekerja: membina sistem penyegerakan data masa nyata. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!