PHP と MQTT を使用して可用性の高いリアルタイムアラームシステムを構築するためのヒント-PHPチュートリアル-php.cn

PHP と MQTT を使用して可用性の高いリアルタイムアラームシステムを構築するためのヒント

WBOY

リリース： 2023-07-10 08:06:01

オリジナル

1181 人が閲覧しました

PHP と MQTT を使用して可用性の高いリアルタイムアラームシステムを構築するためのヒント

以前に書いた:
今日の情報化時代では、リアルタイムアラームシステムは重要な役割を果たしています。異常な状況を適時に検知してアラートを送信できるため、財産と安全を保護するためにタイムリーな措置を講じることができます。この記事では、PHP と MQTT を使用して可用性の高いリアルタイムアラームシステムを構築する方法を紹介し、参考となるコード例を示します。

ステップ 1: MQTT サーバーを構築する
MQTT は軽量のパブリッシュ/サブスクライブプロトコルであり、リアルタイムアラームシステムの構築に非常に適しています。まず、サーバー上に MQTT サーバーを構築する必要があります。 Mosquitto や EMQ などの MQTT サーバーの使用を選択できます。 Mosquitto MQTT サーバーを構築する手順は次のとおりです:

Mosquitto のインストール
まず、次のコマンドを使用して Mosquitto MQTT サーバーをインストールします:
```
sudo apt-get install mosquitto mosquitto-clients
```
ログイン後にコピー
Mosquitto の起動
次のコマンドを入力して Mosquitto MQTT サーバーを起動します:
```
mosquitto -c /etc/mosquitto/mosquitto.conf
```
ログイン後にコピー
Mosquitto が適切に動作していることを確認します
ターミナルウィンドウを開いて、次のコマンドを入力します。次のコマンドを使用してトピックを購読します:
```
mosquitto_sub -h localhost -t test
```
ログイン後にコピー
次に、別のターミナルウィンドウで次のコマンドを入力してトピックにメッセージを公開します:
```
mosquitto_pub -h localhost -t test -m "Hello, world!"
```
ログイン後にコピー
メッセージ「Hello, world」が表示された場合!" がサブスクライブ済み端末ウィンドウに表示され、Mosquitto サーバーが正常にセットアップされたことを示します。

ステップ 2: PHP コードを作成する
次に、リアルタイムアラームシステムを実装するための PHP コードの作成を開始します。

MQTT 拡張機能のインストール
まず、PHP が MQTT と通信するためのインターフェイスである php-mosquitto 拡張機能をインストールする必要があります。次のコマンドを使用してインストールします。
```
sudo apt-get install php-mosquitto
```
ログイン後にコピー
PHP コードの例
次は、PHP ベースの MQTT パブリッシャーのサンプルコードです。

<?php
$mqtt = new MosquittoClient();
$mqtt->connect('localhost', 1883, 60);

$topic = 'test';
$message = 'Hello, world!';

$mqtt->publish($topic, $message, 2);

$mqtt->disconnect();
unset($mqtt);
?>

ログイン後にコピー

上記のコードトピック「test」にレポートし、メッセージ「Hello, world!」を発行します。 $topic 変数と $message 変数は必要に応じて変更できます。さらに、認証や SSL などのセキュリティ設定を追加できます。

ステップ 3: MQTT メッセージを受信して処理する
メッセージの送信に加えて、MQTT メッセージを受信して処理するコードも記述する必要があります。以下は、PHP の MQTT サブスクライバーのサンプルコードです。

<?php
require('path/to/mqtt/php/protocol.php');
require('path/to/mqtt/php/client.php');

function processMessage($message) {
    // 处理接收到的消息
    echo 'Received message: ' . $message . PHP_EOL;
}

$mqtt = new BluerhinosphpMQTT('localhost', 1883, 'ClientID');
if ($mqtt->connect(true, null, null, null, 'Will Message')) {
    $mqtt->subscribe(array('test' => array('qos' => 2, 'function' => 'processMessage')));
    $mqtt->proc();
    $mqtt->close();
} else {
    echo 'Failed to connect to MQTT server';
}
?>

ログイン後にコピー

上記のコードは、MQTT サーバーに接続し、トピック「test」のメッセージをサブスクライブし、受信したメッセージを processMessage 関数を通じて処理します。実際のニーズに応じてテーマや処理機能を変更できます。

概要:
PHP と MQTT を使用すると、可用性の高いリアルタイムアラームシステムを簡単に構築できます。この記事では、MQTT サーバーを構築する手順を紹介し、参考用の PHP コード例を示します。この記事がリアルタイムアラームシステムの構築に役立つことを願っています。

以上がPHP と MQTT を使用して可用性の高いリアルタイムアラームシステムを構築するためのヒントの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。