PHP und MQTT: Aufbau eines ereignisgesteuerten Echtzeit-Datenanalysesystems

PHP und MQTT: Erstellen Sie ein ereignisgesteuertes Echtzeit-Datenanalysesystem

Im heutigen digitalen Zeitalter ist die Echtzeit-Datenanalyse zum Schlüssel für Unternehmensentscheidungen und Geschäftsoptimierung geworden. Um eine effiziente Datenanalyse in Echtzeit zu erreichen, ist ein zuverlässiges und flexibles System zum Sammeln, Verarbeiten und Speichern von Daten erforderlich. In diesem Artikel stellen wir vor, wie man PHP und MQTT (Message Queuing Telemetry Transport) verwendet, um ein ereignisgesteuertes Echtzeit-Datenanalysesystem aufzubauen.

1. Was ist MQTT? MQTT ist ein leichtgewichtiges Messaging-Protokoll, das auf dem Publish/Subscribe-Modell basiert und für geringe Bandbreite und instabile Netzwerkumgebungen geeignet ist. MQTT verwendet ein verbindungsorientiertes Protokoll, das es ermöglicht, Nachrichten an ein oder mehrere Themen zu senden, die dann selektiv von Abonnenten empfangen werden können. Aufgrund einer solchen Architektur eignet sich MQTT sehr gut für Echtzeit-Datenanalysesysteme.
   
Architektur zum Aufbau eines Echtzeit-Datenanalysesystems
2. Wir werden die folgenden Komponenten verwenden, um unser Echtzeit-Datenanalysesystem aufzubauen:
   
MQTT-Proxyserver: Ein MQTT-Proxyserver zum Empfangen und Weiterleiten von Nachrichten, Sie können die Open verwenden Quellsoftware Mosquito.
3. Datenquelle: Es kann sich um eine Vielzahl verschiedener Sensoren, Geräte oder anderer Datengenerierungstools handeln.
4. Datenverarbeitung: Serverseitige Anwendung, die für den Empfang und die Verarbeitung von Daten zuständig ist, implementiert mit PHP.
5. Datenspeicherung: Eine Datenbank zum Speichern und Abrufen von Daten. Sie können MySQL oder andere für Sie geeignete Datenbanken verwenden.
6. MQTT-Proxyserver installieren und konfigurieren
7. Zuerst müssen Sie den Mosquitto-Proxyserver installieren. Sie können es von der offiziellen Mosquitto-Website herunterladen und den Anweisungen zur Installation folgen. Nach Abschluss der Installation müssen Sie die Verbindungseinstellungen des Proxyservers konfigurieren, z. B. Portnummer und Authentifizierungsinformationen.
   
Themen veröffentlichen und abonnieren
8. In PHP können Sie die Eclipse Paho MQTT-Clientbibliothek verwenden, um MQTT-Verbindungen zu implementieren. Zuerst müssen Sie Composer verwenden, um die Bibliothek zu installieren. Anschließend können Sie den folgenden Code verwenden, um eine Verbindung zum angegebenen Thema herzustellen und Nachrichten zu veröffentlichen:
   

<?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();

?>

Nach dem Login kopieren

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事件回调中，您可以处理接收到的消息。最后，同样使用connectUm ein Thema zu abonnieren, können Sie den folgenden Code verwenden:

<?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();

?>

Der obige Code ähnelt dem Veröffentlichungscode. Führen Sie zunächst die erforderlichen Bibliotheken ein, erstellen Sie eine Client-Instanz und legen Sie die Authentifizierungsinformationen fest. Verwenden Sie im onConnect-Ereignisrückruf die Methode subscribe, um das angegebene Thema zu abonnieren. Im onMessage-Ereignisrückruf können Sie die empfangene Nachricht verarbeiten. Verwenden Sie abschließend auch die Methode connect, um eine Verbindung zum MQTT-Proxyserver herzustellen und die Verbindung aktiv zu halten.
5. 
   
Datenverarbeitung und -speicherung

Der obige Code erstellt zunächst eine MySQL-Verbindung und prüft, ob die Verbindung erfolgreich ist. Bereiten Sie dann eine SQL-Anweisung vor, die die einzufügenden Daten enthält, und führen Sie sie aus. Schließen Sie abschließend die Verbindung.

In diesem Artikel haben wir vorgestellt, wie man mit PHP und MQTT ein ereignisgesteuertes Echtzeit-Datenanalysesystem aufbaut. Zuerst haben wir den MQTT-Proxyserver installiert und konfiguriert und dann mit PHP eine Verbindung zum Proxyserver hergestellt und Nachrichten zu einem bestimmten Thema veröffentlicht oder abonniert. Schließlich haben wir den Datenverarbeitungs- und Speicherlogikcode mit PHP geschrieben, um zu demonstrieren, wie Daten in einer MySQL-Datenbank gespeichert werden. Durch den Einsatz eines solchen Systems können Unternehmen Daten in Echtzeit überwachen und analysieren, um zeitnahe Entscheidungen zu treffen und ihr Geschäft zu optimieren.

Referenzen:
• Eclipse Paho MQTT-Client-Bibliothek: https://www.eclipse.org/paho/

Das obige ist der detaillierte Inhalt vonPHP und MQTT: Aufbau eines ereignisgesteuerten Echtzeit-Datenanalysesystems. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!