Workerman ネットワーク プログラミングの実践: リアルタイム データ同期システムの構築

Workerman ネットワーク プログラミングの実践: リアルタイム データ同期システムの構築

はじめに:
現在、インターネットの急速な発展とスマート デバイスの普及により、リアルタイム データ同期システムは様々な産業に欠かせない存在となっております。リアルタイム データ同期システムは、1 つのソースから複数のターゲットにデータを迅速に同期し、データの正確性と適時性を保証します。この記事では、PHP 拡張ライブラリ Workerman を使用して効率的なリアルタイム データ同期システムを構築する方法を紹介します。従来のネットワーク プログラミング モデルと比較して、Workerman はその高いパフォーマンスと使いやすさにより開発者に広く支持されています。

1. Workerman の概要
Workerman は、PHP に基づいて開発されたマルチプロセス ネットワーク プログラミング フレームワークです。イベント駆動型モデルを使用して同時実行性の高いネットワーク通信を処理し、TCP、UDP、WebSocket などの複数のプロトコルをサポートします。 Workerman は完全に非同期のネットワーク フレームワークであるため、各プロセスで複数の接続を同時に処理して、効率的なリアルタイム データ送信を実現できます。

2. リアルタイム データ同期の原理
リアルタイム データ同期システムの中核となる原理は、パブリッシュ/サブスクライブ モデルです。データ ソースはパブリッシャーとして機能し、データをメッセージ キューまたはメッセージ ミドルウェアにパブリッシュします。サブスクライバーは、対応するトピックをサブスクライブすることによってメッセージ キューまたはメッセージ ミドルウェアからデータを受信し、それに応じて処理します。このようにして、データ ソースとサブスクライバの間に信頼性の高いリアルタイム データ チャネルが確立されます。

3. リアルタイム データ同期システムの構築

1. Workerman のインストール

   composer require workerman/workerman

2. データ ソース サーバーの作成

   <?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. サブスクライバ クライアントの作成

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

4. #トピック クラスの作成

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

4. 実行してテスト

1. データ ソース サーバーを開始します

   php data_source.php start

2. サブスクライバ クライアントを開始します

   php subscriber.php start

3. データ ソースに接続しますサーバー

   telnet localhost 2345

4. メッセージをトピック "topic1" にパブリッシュする

   publish your_data

サブスクライバー クライアントが受信したメッセージを表示する

結論:

この記事では、Workerman フレームワークを使用して効率的なリアルタイム データ同期システムを構築する方法について詳しく説明します。パブリッシュ/サブスクライブ モデルを通じて、リアルタイム データの同期送信を簡単に実現できます。 Workerman は、その高いパフォーマンスと使いやすさで開発者に愛されており、さまざまなアプリケーション シナリオで役割を果たし、より高い同時実行性のネットワーク通信要件を実現できます。将来の開発では、実際のニーズに応じてデータ同期システムを拡張し、システムの安定性と信頼性を高めることができます。

以上がWorkerman ネットワーク プログラミングの実践: リアルタイム データ同期システムの構築の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。