PHP 및 MQTT: 이벤트 기반 실시간 데이터 분석 시스템 구축
오늘날 디지털 시대에 실시간 데이터 분석은 기업 의사결정 및 비즈니스 최적화의 핵심이 되었습니다. 효율적인 실시간 데이터 분석을 위해서는 데이터를 수집, 처리 및 저장하는 안정적이고 유연한 시스템이 필요합니다. 이 기사에서는 PHP와 MQTT(Message Queuing Telemetry Transport)를 사용하여 이벤트 기반 실시간 데이터 분석 시스템을 구축하는 방법을 소개합니다.
<?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 메서드를 사용하여 연결을 유지합니다. 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
<?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();
?>onConnect 이벤트 콜백에서 subscribe 메서드를 사용하여 지정된 주제를 구독합니다. onMessage 이벤트 콜백에서 수신된 메시지를 처리할 수 있습니다. 마지막으로 connect 메서드를 사용하여 MQTT 프록시 서버에 연결하고 연결을 활성 상태로 유지하세요. 서버 측에서는 PHP를 사용하여 데이터 처리 및 저장을 위한 논리 코드를 작성할 수 있습니다. 필요에 따라 MySQL이나 다른 데이터베이스에 데이터를 저장하고 데이터베이스 쿼리문을 작성하여 데이터를 검색하고 분석할 수 있습니다. 다음은 PHP를 사용하여 MySQL 데이터베이스에 연결하고 데이터를 삽입하는 예제입니다.
rrreee
위 코드는 먼저 MySQL 연결을 생성하고 연결 성공 여부를 확인합니다. 그런 다음 삽입할 데이터가 포함된 SQL 문을 준비하고 실행합니다. 마지막으로 연결을 닫습니다.
결론:
이 기사에서는 PHP와 MQTT를 사용하여 이벤트 기반 실시간 데이터 분석 시스템을 구축하는 방법을 소개했습니다. 먼저 MQTT 프록시 서버를 설치 및 구성한 다음 PHP를 사용하여 프록시 서버에 연결하고 특정 주제에 대한 메시지를 게시하거나 구독했습니다. 마지막으로, MySQL 데이터베이스에 데이터를 저장하는 방법을 보여주기 위해 PHP를 사용하여 데이터 처리 및 저장 논리 코드를 작성했습니다. 이러한 시스템을 사용하면 기업은 데이터를 실시간으로 모니터링하고 분석하여 적시에 의사결정을 내리고 비즈니스를 최적화할 수 있습니다.Mosquitto MQTT 프록시 서버: https://mosquitto.org/documentation/
🎜🎜참고: 위 코드 이는 단지 참고용이므로 실제 상황에 따라 구성하고 수정하십시오. 🎜위 내용은 PHP 및 MQTT: 이벤트 기반 실시간 데이터 분석 시스템 구축의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!