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

1. Pasang Workerman

   composer require workerman/workerman

2. 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();

3. Cipta pelanggan pelanggan

Cipta pelanggan foto

4. <?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();

Empat. Jalankan dan uji

1. Mulakan pelayan sumber data

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

2. Mulakan pelanggan pelanggan

   php data_source.php start

3. Sambungkan pelayan sumber data

   php subscriber.php start

Lihat mesej semula kepada

4. kepada

   Pub langganan Mesej yang diterima oleh pelanggan
5. Kesimpulan:

Artikel ini memperincikan cara menggunakan rangka kerja Workerman untuk membina sistem penyegerakan data masa nyata yang cekap. Melalui model terbitkan/langganan, kami boleh mencapai penghantaran segerak data masa nyata dengan mudah. Workerman disayangi oleh pembangun kerana prestasi tinggi dan kemudahan penggunaannya Ia boleh memainkan peranan dalam pelbagai senario aplikasi dan merealisasikan lebih banyak keperluan komunikasi rangkaian berkonkurensi tinggi. Dalam pembangunan masa depan, kami boleh mengembangkan sistem penyegerakan data mengikut keperluan sebenar untuk menjadikan sistem lebih stabil dan boleh dipercayai.

Atas 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!