PHP의 MQTT 확장 라이브러리 소개 및 사용 튜토리얼-PHP 튜토리얼-php.cn

PHP의 MQTT 확장 라이브러리 소개 및 사용 튜토리얼

王林

풀어 주다： 2023-07-08 11:34:02

원래의

1954명이 탐색했습니다.

PHP의 MQTT 확장 라이브러리 소개 및 사용 튜토리얼

소개:
사물 인터넷의 급속한 발전과 함께 경량 통신 프로토콜인 MQTT(Message Queuing Telemetry Transport)가 광범위한 관심과 적용을 받아왔습니다. PHP 개발 시 MQTT 확장 라이브러리를 사용하면 MQTT 서버와 쉽게 통신할 수 있습니다. 이 기사에서는 MQTT 확장 라이브러리의 기본 개념과 사용법을 소개하고 코드를 통해 메시지 게시 및 구독에 MQTT를 사용하는 방법을 보여줍니다. 예.

1. MQTT 확장 라이브러리 소개
MQTT 확장 라이브러리는 MQTT 서버와 통신하는 데 사용되는 PHP 확장으로, MQTT 기능을 쉽게 구현할 수 있도록 해주는 일련의 함수와 클래스를 제공합니다. 시작하기 전에 확장 라이브러리를 설치해야 합니다. 사용 중인 PHP 버전과 운영 체제 유형에 따라 다양한 방법으로 설치할 수 있습니다.

2. MQTT 확장 라이브러리 사용

MQTT 서버에 연결
MQTT 확장 라이브러리를 사용하는 첫 번째 단계는 MQTT 클라이언트를 생성하고 MQTT 서버와 연결을 설정하는 것입니다. 연결 프로세스 중에 서버의 호스트 이름, 포트 번호 및 클라이언트 ID를 지정해야 합니다.

<?php
$host = 'mqtt.example.com';
$port = 1883;
$clientID = 'php-mqtt-client';

$mqtt = new MosquittoClient($clientID);
$mqtt->connect($host, $port);

로그인 후 복사

메시지 게시
MQTT 서버에 메시지를 게시하려면 메시지의 주제(Topic)와 내용을 지정해야 합니다. publish 함수를 호출하면 해당 주제로 메시지를 보낼 수 있습니다. publish函数即可将消息发送到相应的主题上。

<?php
$topic = 'example/topic';
$message = 'Hello, MQTT!';

$mqtt->publish($topic, $message, 0, false);

로그인 후 복사

其中，第三个参数指定了QoS级别，0表示最多一次的传输，1表示至少一次的传输，2表示仅有一次的传输。第四个参数用于指定是否在消息中保留自己的Client ID。

订阅消息
订阅消息是MQTT中最重要的功能之一。通过调用subscribe函数，可以让客户端订阅一个或多个主题，并指定相应的回调函数来处理收到的消息。

<?php
$topic = 'example/topic';

// 定义回调函数
$mqtt->onMessage(function($message) {
    echo 'Received message: ' . $message->payload . PHP_EOL;
});

$mqtt->subscribe($topic, 0);
$mqtt->loopForever();

로그인 후 복사

在上面的例子中，我们定义了一个匿名回调函数用于处理收到的消息。回调函数将会在收到相应的消息时被调用，并输出收到的消息内容。