Swoole は信頼性の高いパブリッシュおよびサブスクライブシステムを実装しています-Swoole-php.cn

Swoole は信頼性の高いパブリッシュおよびサブスクライブシステムを実装しています

王林

リリース： 2023-06-13 20:32:28

オリジナル

1604 人が閲覧しました

インターネットの発展に伴い、メッセージのリアルタイムのプッシュとサブスクリプションを実現する必要があるアプリケーションがますます増えています。この要件をサポートするには、信頼性の高いパブリッシュおよびサブスクライブシステムが必要です。 Swoole は、高性能ネットワーク通信フレームワークとして、この需要に十分対応できます。

Swoole は PHP 言語の拡張モジュールであり、非同期、並列、高性能ネットワーク通信およびマルチプロセス同時処理機能を提供します。 Swoole に基づいて開発されたアプリケーションは、より高い同時実行性とより短い応答時間をサポートできます。この記事では、Swooleを使って信頼性の高いパブリッシュ＆サブスクライブシステムを実現する方法を紹介します。

1. パブリッシュ/サブスクライブシステムの基本概念

パブリッシュ/サブスクライブシステムは、1 対多のメッセージのパブリッシュとサブスクリプションをサポートするメッセージングモデルです。パブリッシャーは 1 つ以上のトピックにメッセージをパブリッシュし、サブスクライバーは自分の興味に応じてこれらのトピックをサブスクライブして、対応するメッセージを受信できます。

パブリッシュおよびサブスクライブシステムは、通常、パブリッシャー、サブスクライバー、メッセージブローカー (メッセージブローカー) の 3 つの部分で構成されます。パブリッシャーはメッセージブローカーにメッセージを送信し、サブスクライバーはメッセージブローカーからのメッセージをサブスクライブします。パブリッシャーとサブスクライバーは直接通信しません。メッセージブローカーは、対応するサブスクライバーにメッセージをルーティングする役割を果たします。

2. Swoole の基本概念

Swoole を理解してパブリッシュおよびサブスクライブシステムを実装する前に、Swoole のいくつかの基本概念を理解する必要があります。

プロセス

Swoole では、プロセスとは独立した実行環境を指します。 Swoole はマルチプロセスをサポートしており、複数のプロセスを作成することで同時処理を実現できます。

サーバー

サーバーは Swoole フレームワークのコアモジュールであり、TCP サーバーまたは UDP サーバーを作成できます。サーバーが起動すると、メインプロセスと複数のサブプロセスが作成されます。メインプロセスはポートでのリッスンを担当し、サブプロセスは特定のリクエストを処理します。

タイマー

Swoole は、指定された時間間隔内でコードを実行できるタイマー関数を提供します。タイマーは、スケジュールされたタスクやスケジュールされたチェックなどのシナリオで使用できます。

Coroutine

Coroutine は、1 つのスレッドで複数のコルーチンを同時に実行できる軽量のスレッドです。コルーチンは非同期プログラミングを実装し、従来のマルチスレッドプログラミングにおけるスレッド切り替えのオーバーヘッドを回避できます。 Swoole は、同時実行性の高いネットワークプログラミングの実装に使用できるコルーチンのサポートを提供します。

3. Swoole でパブリッシュアンドサブスクライブシステムを実装する手順

次に、Swoole を使用してパブリッシュアンドサブスクライブシステムを実装する方法を紹介します。コードの複雑さを軽減するために、サブスクライバによるアクティブポーリングを使用してサブスクリプション機能を実装します。

メッセージエージェントの作成

まず、メッセージを受信し、対応するサブスクライバーにルーティングする役割を担うメッセージエージェントを作成する必要があります。 Swoole が提供する TCP サーバーとプロセス管理機能を使用して、メッセージブローカーを実装できます。

$server = new SwooleServer('0.0.0.0', 8080, SWOOLE_PROCESS);
$server->set([
    'worker_num' => 2,
    'daemonize' => false,
]);
$server->on('WorkerStart', function($serv, $worker_id) {
    // 创建消息队列
    $queue_key = ftok(__FILE__, 'a');
    $queue = msg_get_queue($queue_key, 0666 | IPC_CREAT);
    // 将消息队列作为全局变量存放起来
    global $message_queue;
    $message_queue = $queue;
    // 启动消息处理进程
    if ($worker_id == 0) {
        $process = new SwooleProcess(function($process) {
            global $message_queue;
            while (true) {
                // 从消息队列中获取消息
                if (msg_receive($message_queue, 0, $msg_type, 1024, $msg, true, MSG_IPC_NOWAIT)) {
                    // 将消息发送给对应的订阅者
                    // TODO:实现发送消息的逻辑
                }
                // 隔一段时间循环一次
                usleep(100);
            }
        }, false, false);
        $process->start();
    }
});
$server->on('Connect', function($serv, $fd) {
    echo "Client[$fd]: Connect.
";
});
$server->on('Receive', function($serv, $fd, $from_id, $data) {
    global $message_queue;
    // 接收到消息，将消息存放到消息队列
    if (msg_send($message_queue, 1, $data, true, true)) {
        echo "Received message: $data
";
    } else {
        echo "Failed to send message to message queue.
";
    }
});
$server->on('Close', function($serv, $fd) {
    echo "Client[$fd]: Close.
";
});
$server->start();

ログイン後にコピー

上記のコードでは、TCP サーバーを作成し、2 つの子プロセスを設定しました。各子プロセスが開始されると、メッセージキューを作成し、それをグローバル変数 $message_queue に保存します。最初のサブプロセスでは、メッセージキューからメッセージを取得し、対応するサブスクライバーにメッセージを送信するメッセージ処理プロセスを作成します。メッセージを受信すると、msg_send 関数を通じてメッセージをメッセージキューに保存します。

サブスクリプション機能の実装

サブスクリプション機能とは、サブスクライバーが自分の興味に応じてサブスクライブする必要があるトピックを選択し、それによって関連するメッセージを受信できることを意味します。 Swoole のコルーチンを通じてサブスクリプション機能を実装できます。

$client = new SwooleClient(SWOOLE_SOCK_TCP);
if (!$client->connect('127.0.0.1', 8080)) {
    echo "Failed to connect to server.
";
    exit(1);
}
// 订阅主题
if (!$client->send("subscribe:topic1")) {
    echo "Failed to send subscribe message.
";
    exit(1);
}
// 接收消息
while (true) {
    $data = $client->recv();
    if ($data === false) {
        echo "Failed to receive message.
";
        break;
    }
    if (empty($data)) {
        continue;
    }
    echo "Received message: $data
";
}
$client->close();

ログイン後にコピー

上記のコードでは、TCP クライアントを作成し、メッセージブローカーのポートに接続します。サブスクリプションメッセージは send 関数を通じて送信され、サブスクリプショントピックは topic1 です。メッセージを受信するときは、ループを使用して新しいメッセージがあるかどうかを確認し、recv 関数を使用してブロックして新しいメッセージを待ちます。

パブリッシング関数の実装

パブリッシュ関数とは、パブリッシャーが指定されたトピックにメッセージをパブリッシュできることを意味します。 Swoole の TCP クライアントを使用して公開機能を実装できます。

$client = new SwooleClient(SWOOLE_SOCK_TCP);
if (!$client->connect('127.0.0.1', 8080)) {
    echo "Failed to connect to server.
";
    exit(1);
}
// 发布消息
if (!$client->send("publish:topic1:message1")) {
    echo "Failed to send publish message.
";
    exit(1);
}
$client->close();

ログイン後にコピー

上記のコードでは、TCP クライアントを作成し、メッセージブローカーのポートに接続します。 send 関数を使用してメッセージを公開します。公開トピックは topic1 で、メッセージの内容は message1 です。

4. 概要

Swoole は、高性能で同時実行性の高いネットワークアプリケーションの実装に役立つ強力なネットワークプログラミングフレームワークです。この記事では、Swooleを使って信頼性の高いパブリッシュ＆サブスクライブシステムを実装する方法を紹介します。主に、メッセージエージェントの作成、サブスクリプション機能の実装、パブリッシング機能などです。 Swoole を使用してパブリッシュおよびサブスクライブシステムを実装すると、システムのパフォーマンスと信頼性が向上し、メッセージング機能を必要とするさまざまなアプリケーションシナリオに適しています。

以上がSwoole は信頼性の高いパブリッシュおよびサブスクライブシステムを実装していますの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。