PHP と MQTT: イベント駆動型のリアルタイムデータ分析システムの構築-PHPチュートリアル-php.cn

PHP と MQTT: イベント駆動型のリアルタイムデータ分析システムの構築

WBOY

リリース： 2023-07-07 21:38:01

オリジナル

1108 人が閲覧しました

PHP と MQTT: イベント駆動型のリアルタイムデータ分析システムの構築

今日のデジタル時代では、リアルタイムデータ分析が企業の意思決定とビジネスの最適化の鍵となっています。効率的なリアルタイムデータ分析を実現するには、データを収集、処理、保存するための信頼性と柔軟性に優れたシステムが必要です。この記事では、PHP と MQTT (Message Queuing Telemetry Transport) を使用して、イベント駆動型のリアルタイムデータ分析システムを構築する方法を紹介します。

MQTT とは
MQTT は、パブリッシュ/サブスクライブモデルに基づく軽量のメッセージングプロトコルで、低帯域幅で不安定なネットワーク環境に適しています。 MQTT は、メッセージを 1 つ以上のトピックに送信できる接続指向プロトコルを使用し、サブスクライバーがメッセージを選択的に受信できるようにします。このようなアーキテクチャにより、MQTT はリアルタイムデータ分析システムに非常に適しています。
リアルタイムデータ分析システムを構築するためのアーキテクチャ
次のコンポーネントを使用してリアルタイムデータ分析システムを構築します。
MQTT プロキシサーバー: 受信用の MQTT プロキシサーバーおよびメッセージの転送には、オープンソースソフトウェア Mosquitto を使用できます。
データソース: さまざまなセンサー、デバイス、その他のデータ生成ツールが考えられます。
データ処理: データの受信と処理を担当するサーバー側アプリケーション。PHP を使用して実装されます。
データストレージ: データの保存と取得に使用されるデータベース。MySQL またはその他の適切なデータベースの使用を選択できます。
MQTT プロキシサーバーのインストールと構成
まず、Mosquitto プロキシサーバーをインストールする必要があります。 Mosquitto 公式 Web サイトからダウンロードし、指示に従ってインストールできます。インストールが完了したら、ポート番号や認証情報など、プロキシサーバーの接続設定を行う必要があります。
トピックのパブリッシュとサブスクライブ
PHP では、Eclipse Paho MQTT クライアントライブラリを使用して MQTT 接続を実装できます。まず、Composer を使用してライブラリをインストールする必要があります。次に、次のコードを使用して、指定されたトピックに接続してメッセージをパブリッシュできます。

<?php

require 'vendor/autoload.php';

use EclipseMosquittoClient as MosquittoClient;

$client = new MosquittoClient();
$client->setCredentials('username', 'password'); // 如果需要认证，添加用户名和密码

$client->onConnect(function () use (&$client) {
    $client->publish('topic', 'Hello from PHP!', 0, false);
    $client->disconnect();
});

$client->onDisconnect(function () {
    echo "Disconnected from MQTT broker.";
});

$client->connect('localhost', 1883, 60);

$client->loopForever();

?>

ログイン後にコピー

上記のコードは、最初に require 'vendor を渡します。 /autoload.php ';Paho MQTT クライアントライブラリを導入し、新しいクライアントインスタンスを作成します。ログイン認証情報は、setCredentials メソッドを使用して設定できます。 onConnect イベントコールバックでは、publish メソッドを使用して、指定されたトピックにメッセージをパブリッシュし、接続を閉じることができます。最後に、connect メソッドを使用して MQTT ブローカーサーバーに接続し、loopForever メソッドを使用して接続を維持します。

トピックをサブスクライブするには、次のコードを使用できます:

<?php

require 'vendor/autoload.php';

use EclipseMosquittoClient as MosquittoClient;

$client = new MosquittoClient();
$client->setCredentials('username', 'password'); // 如果需要认证，添加用户名和密码

$client->onConnect(function () use (&$client) {
    $client->subscribe('topic', 0);
});

$client->onMessage(function ($message) {
    echo "Received message: " . $message->payload . "
";
});

$client->connect('localhost', 1883, 60);

$client->loopForever();

?>

ログイン後にコピー

上記のコードは公開コードに似ています。まず、必要なライブラリを導入し、クライアントインスタンスを作成し、認証情報。 onConnect イベントコールバックで、subscribe メソッドを使用して、指定されたトピックをサブスクライブします。 onMessage イベントコールバックでは、受信したメッセージを処理できます。最後に、connect メソッドを使用して MQTT プロキシサーバーに接続し、接続をアクティブに保ちます。

データの処理とストレージ
サーバー側では、PHP を使用してデータの処理とストレージのためのロジックコードを作成できます。ニーズに応じて、MySQL またはその他のデータベースにデータを保存し、データベースクエリステートメントを作成してデータを取得および分析できます。以下は、PHP を使用して MySQL データベースに接続し、データを挿入する例です。

<?php

$servername = 'localhost';
$username = 'username';
$password = 'password';
$dbname = 'database';

// 创建连接
$conn = new mysqli($servername, $username, $password, $dbname);

// 检查连接是否成功
if ($conn->connect_error) {
    die("Connection failed: " . $conn->connect_error);
}

// 准备SQL语句
$sql = "INSERT INTO data (timestamp, value) VALUES ('" . time() . "', '10.5')";

// 执行SQL语句
if ($conn->query($sql) === TRUE) {
    echo "Data inserted successfully.";
} else {
    echo "Error: " . $sql . "<br>" . $conn->error;
}

// 关闭连接
$conn->close();

?>

ログイン後にコピー

上記のコードは、まず MySQL 接続を作成し、接続が成功したかどうかを確認します。次に、挿入するデータを含む SQL ステートメントを準備し、実行します。最後に接続を閉じます。

結論:
この記事では、PHP と MQTT を使用してイベント駆動型のリアルタイムデータ分析システムを構築する方法を紹介しました。まず、MQTT プロキシサーバーをインストールして構成し、次に PHP を使用してプロキシサーバーに接続し、特定のトピックに関するメッセージをパブリッシュまたはサブスクライブします。最後に、PHP を使用してデータ処理と保存のロジックコードを作成し、MySQL データベースにデータを保存する方法を示しました。このようなシステムを使用することで、企業はデータをリアルタイムで監視および分析し、タイムリーな意思決定を行い、ビジネスを最適化することができます。

参考資料: