PHP と ZMQ を使用したリアルタイムメッセージプッシュ-PHPチュートリアル-php.cn

PHP と ZMQ を使用したリアルタイムメッセージプッシュ

王林

リリース： 2023-06-28 08:44:02

オリジナル

1091 人が閲覧しました

インターネット技術の継続的な発展に伴い、リアルタイムのメッセージプッシュの重要性がますます高まっています。多くのアプリケーションシナリオでは、リアルタイムメッセージプッシュによってユーザーエクスペリエンスと効率が大幅に向上します。たとえば、ソーシャルアプリケーションでは、友人のメッセージをリアルタイムにプッシュすることで、ユーザーは友人の最新情報をより迅速に理解できるようになります。オンラインゲームでは、ゲームイベントをリアルタイムにプッシュすることで、ユーザーはよりスムーズにゲームをプレイできるようになります。株式取引では、、株価のリアルタイムの押し上げ変化により、トレーダーはよりタイムリーな意思決定を行うことができます。

リアルタイムメッセージプッシュを実装するにはさまざまな方法がありますが、より一般的な方法の 1 つは、PHP と ZMQ (ZeroMQ) を使用することです。

ZMQ は、リクエスト/レスポンス、パブリッシュ/サブスクライブ、プッシュ/プルなどのさまざまなメッセージングモードを提供する、高性能の非同期メッセージングライブラリです。 PHP で ZMQ を使用すると、リアルタイムのメッセージプッシュを簡単に実装できます。

リアルタイムメッセージプッシュの簡単な例を見てみましょう。

まず、ZMQ コンテキストを作成する必要があります:

$context = new ZMQContext();

ログイン後にコピー

次に、Push タイプの ZMQ ソケットを作成します:

$push_socket = $context->getSocket(ZMQ::SOCKET_PUSH);
$push_socket->bind("tcp://127.0.0.1:5555");

ログイン後にコピー

ここで、Push ソケットを作成します。単語は次のようにバインドされています。ローカルポート 5555 は、クライアントにメッセージを送信するために使用されます。

次に、プルタイプの ZMQ ソケットを作成します。

$pull_socket = $context->getSocket(ZMQ::SOCKET_PULL);
$pull_socket->bind("tcp://127.0.0.1:5556");

ログイン後にコピー

ここでは、クライアントからのサブスクリプションリクエストを受信するために、プルソケットをローカル 5556 ポートにバインドします。

次に、クライアントにメッセージを送信するための PHP スクリプトを作成します。

while (true) {
    $msg = date("Y-m-d H:i:s") . " hello world!";
    $push_socket->send($msg);
    sleep(1);
}

ログイン後にコピー

ここでは、無限ループを使用して、1 秒に 1 回、プッシュソケットにメッセージを継続的に送信します。

最後に、クライアントからサブスクリプションリクエストを受信し、メッセージをサブスクライバーにプッシュするための PHP スクリプトを作成します。

while (true) {
    $msg = $pull_socket->recv();
    foreach ($clients as $client) {
        $client->send($msg);
    }
}

ログイン後にコピー

ここでも、無限ループを使用してクライアントのサブスクリプションリクエストを待機します。、すべての購読者にメッセージを送信します。

クライアントがメッセージをサブスクライブする必要がある場合、プルソケットにバインドされたポートに接続し、サブスクリプション情報を含むメッセージを送信するだけで済みます。

$context = new ZMQContext();
$sub_socket = $context->getSocket(ZMQ::SOCKET_SUB);
$sub_socket->connect("tcp://127.0.0.1:5556");
$sub_socket->setSockOpt(ZMQ::SOCKOPT_SUBSCRIBE, "");

ログイン後にコピー

ここで、 Subscribe タイプの ZMQ ソケットはローカルポート 5556 に接続されます。次に、setSockOpt() 関数を使用してソケットオプションを設定し、すべてのメッセージをサブスクライブします。

最後に、簡単な PHP ページを作成し、JavaScript を使用して、リアルタイムメッセージプッシュの効果を実現できます。ここでは、開発に jQuery ライブラリを使用します。

<!DOCTYPE html>
<html>
<head>
    <title>实时消息推送</title>
    <script src="https://code.jquery.com/jquery-3.1.0.min.js"></script>
    <script>
        $(function() {
            var socket = new WebSocket("ws://127.0.0.1:8080");
            socket.onmessage = function(event) {
                $("#messages").append("<li>" + event.data + "</li>");
            }
        });
    </script>
</head>
<body>
    <h1>实时消息推送</h1>
    <ul id="messages"></ul>
</body>
</html>

ログイン後にコピー

ここでは、ローカル 8080 ポートに接続する WebSocket を作成し、サーバーからのメッセージをリッスンし、ページにメッセージを表示します。

まとめると、PHP と ZMQ を使用すると、非常に便利にリアルタイムのメッセージプッシュを実現できます。もちろん、安全性や信頼性など、実用化に向けて考慮すべき課題は数多くあります。ただし、この記事では参考用の基本的なフレームワークを提供します。

以上がPHP と ZMQ を使用したリアルタイムメッセージプッシュの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。