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는 메시지를 하나 이상의 주제로 전송한 후 구독자가 이를 선택적으로 수신할 수 있도록 하는 연결 지향 프로토콜을 사용합니다. 이러한 아키텍처 덕분에 MQTT는 실시간 데이터 분석 시스템에 매우 적합합니다.
실시간 데이터 분석 시스템 구축을 위한 아키텍처
실시간 데이터 분석 시스템 구축을 위해 다음 구성요소를 사용합니다.
MQTT 프록시 서버: 메시지 수신 및 전달을 위한 MQTT 프록시 서버입니다. 소스 소프트웨어 Mosquitto.
데이터 소스: 다양한 센서, 장치 또는 기타 데이터 생성 도구일 수 있습니다.
데이터 처리: PHP를 사용하여 구현된 데이터 수신 및 처리를 담당하는 서버측 애플리케이션입니다.
데이터 저장소: 데이터를 저장하고 검색하는 데 사용되는 데이터베이스입니다. MySQL 또는 귀하에게 적합한 다른 데이터베이스를 사용하도록 선택할 수 있습니다.
MQTT 프록시 서버 설치 및 구성
먼저 Mosquitto 프록시 서버를 설치해야 합니다. Mosquitto 공식 웹사이트에서 다운로드하고 지침에 따라 설치할 수 있습니다. 설치가 완료되면 포트 번호, 인증 정보 등 프록시 서버의 연결 설정을 구성해야 합니다.
주제 게시 및 구독
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 메서드를 사용하여 연결을 유지합니다. 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 문을 준비하고 실행합니다. 마지막으로 연결을 닫습니다.

결론: