PHP と MQTT を使用して、リアルタイムのユーザーチャット機能を Web サイトに追加する方法-PHPチュートリアル-php.cn

PHP と MQTT を使用して、リアルタイムのユーザーチャット機能を Web サイトに追加する方法

WBOY

リリース： 2023-07-08 19:48:01

オリジナル

1492 人が閲覧しました

PHP と MQTT を使用して、Web サイトにリアルタイムユーザーチャット機能を追加する方法

インターネット時代の今日、Web サイトユーザーはリアルタイムのコミュニケーションとコミュニケーションの必要性がますます高まっています。 PHP と MQTT を使用して、リアルタイムのユーザーチャット機能を Web サイトに追加できます。この記事では、PHP と MQTT を使用して Web サイトのリアルタイムユーザーチャット機能を実装する方法とコード例を紹介します。

環境の準備を確認する
始める前に、PHP と MQTT の実行環境がインストールされ、構成されていることを確認してください。 XAMPP などの統合開発環境を使用することも、PHP と MQTT の実行環境を個別に構成することもできます。同時に、MQTT ブローカーも必要です。Mosquitto などのオープンソースの MQTT ブローカーを使用できます。
MQTT PHP 拡張機能をインストールする
PHP で MQTT プロトコルを使用するには、MQTT PHP 拡張機能をインストールする必要があります。 MQTT PHP 拡張機能を GitHub からダウンロードしてコンパイルしてインストールすることも、Composer を使用してインストールすることもできます。
MQTT ブローカーの接続
PHP コードでは、メッセージを送受信するために、まず MQTT ブローカーに接続する必要があります。以下は MQTT ブローカーへの接続の例です:

<?php
require("phpMQTT.php");

$mqtt = new phpMQTT("mqtt.example.com", 1883, "phpMQTT Chat Client");
if (!$mqtt->connect()) {
    exit("连接MQTT Broker失败");
}

ログイン後にコピー

上記のコードでは、phpMQTT クラスを使用して MQTT ブローカーに接続します。「Mqtt.example.com」を独自の MQTT ブローカーのアドレスに置き換える必要があることに注意してください。

メッセージの送受信
MQTT ブローカーに正常に接続したら、トピックをパブリッシュおよびサブスクライブすることでメッセージを送受信できます。以下はメッセージ送信の例です。

<?php
$topic = "chat";
$message = "Hello, World!";
$mqtt->publish($topic, $message);

ログイン後にコピー

上記のコードでは、「chat」という名前のトピックを公開し、メッセージを送信しました。

以下はメッセージ受信の例です:

<?php
$topic = "chat";
$mqtt->subscribe($topic);
while($mqtt->proc()){
    $message = $mqtt->message;
    echo "收到消息：".$message;
}

ログイン後にコピー

上記のコードでは、トピック「チャット」をサブスクライブし、ループを使用してメッセージを継続的に受信し、出力します。

Web サイトにチャットインターフェイスを追加する
Web サイトにチャット機能を追加するには、フロントエンドインターフェイスにチャットウィンドウを埋め込み、JavaScript を介して MQTT ブローカーからメッセージを受信して表示する必要があります。チャットウィンドウの中央にあります。

以下は、単純なチャットウィンドウの HTML コードです:

<!DOCTYPE html>
<html>
<head>
    <title>实时用户聊天</title>
</head>
<body>
    <div id="chat-window">
        <ul id="chat-messages"></ul>
        <input type="text" id="message-input" placeholder="输入消息">
        <button id="send-button">发送</button>
    </div>
    
    <script src="https://code.jquery.com/jquery-3.5.1.min.js"></script>
    <script src="mqttws31.js"></script>
    <script>
        var mqtt = new Paho.MQTT.Client("mqtt.example.com", Number(1883), "jsMQTT Chat Client");
        mqtt.onMessageArrived = function(message) {
            $("#chat-messages").append("<li>" + message.payloadString + "</li>");
        };
        mqtt.connect({onSuccess:function() {
            mqtt.subscribe("chat");
        }});
        
        $(document).ready(function() {
            $("#send-button").click(function() {
                var message = $("#message-input").val();
                var message = new Paho.MQTT.Message(message);
                message.destinationName = "chat";
                mqtt.send(message);
                $("#message-input").val("");
            });
        });
    </script>
</body>
</html>

ログイン後にコピー

上記のコードでは、Paho.MQTT.Client クラスを使用して MQTT ブローカーに接続し、サブスクライブします。トピックへ、メッセージの送受信方法はチャット機能を実装します。

上記のコードを HTML ファイルとして保存し、MQTT ブローカーのアドレスを自分のアドレスに置き換えることで、Web サイトでリアルタイムユーザーチャット機能を使用できます。

概要
この記事では、PHP と MQTT を使用してリアルタイムユーザーチャット機能を Web サイトに追加する方法について説明します。 MQTT Broker に接続し、メッセージを送受信し、Web サイトにチャットインターフェイスを追加することで、簡単なリアルタイムユーザーチャット機能を実装できます。この記事がこのタスクの完了に役立つことを願っています。

以上がPHP と MQTT を使用して、リアルタイムのユーザーチャット機能を Web サイトに追加する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。