ホームページ > 記事 > バックエンド開発 > PHP と ZMQ を使用したリアルタイムメッセージプッシュ

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

王林オリジナル: 2023-06-28 08:22:31996ブラウズ

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

リアルタイムメッセージプッシュを実装するにはさまざまな方法がありますが、より一般的な方法の 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 サイトの他の関連記事を参照してください。

php JavaScript jquery 循环并发事件异步 websocket

声明：

この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

前の記事：PHPリアルタイムデータ可視化技術の実装次の記事：PHPリアルタイムデータ可視化技術の実装

続きを見る

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

関連記事

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