PHP 및 MQTT를 사용하여 실시간 메시지 푸시 기능을 개발하는 방법-PHP 튜토리얼-php.cn

PHP 및 MQTT를 사용하여 실시간 메시지 푸시 기능을 개발하는 방법

王林

풀어 주다： 2023-07-07 22:10:01

원래의

940명이 탐색했습니다.

PHP와 MQTT를 활용한 실시간 메시지 푸시 기능 개발 방법

개요
인터넷 기술의 급속한 발전으로 인해 실시간 메시지 푸시는 많은 애플리케이션에서 필수적인 기능 중 하나가 되었습니다. 실시간 메시지 푸시를 통해 인스턴트 메시징, 실시간 메시지 업데이트 등의 기능을 실현할 수 있습니다. 이 기사에서는 PHP 및 MQTT(Message Queuing Telemetry Transport) 프로토콜을 사용하여 실시간 메시지 푸시 기능을 개발하는 방법을 소개합니다.

MQTT란 무엇인가요?
MQTT는 낮은 대역폭, 높은 대기 시간 및 신뢰할 수 없는 네트워크 환경에서 IoT 장치에 대한 통신 지원을 제공하도록 설계된 경량 프로토콜입니다. MQTT는 게시자(Publisher)가 특정 주제(Topic)에 메시지를 게시하고, 구독자(Subscriber)가 특정 주제를 구독하고 해당 메시지를 수신할 수 있는 게시/구독 모델을 기반으로 합니다.

준비
개발을 시작하기 전에 다음 준비 사항을 충족해야 합니다.

PHP 설치: PHP가 설치되어 있고 버전 요구 사항이 5.6 이상인지 확인하세요.
Mosquitto 라이브러리 설치: Mosquitto는 MQTT의 오픈 소스 구현입니다. . mosquitto 라이브러리는 다음 명령을 통해 설치할 수 있습니다.
```
sudo apt-get install mosquitto
```
로그인 후 복사
이렇게 하면 mosquitto 런타임 라이브러리와 클라이언트가 설치됩니다.

개발 단계

MQTT 프로토콜을 쉽게 사용하려면, PHP MQTT 확장을 사용할 수 있습니다. 다음 단계를 통해 MQTT PHP 확장을 설치할 수 있습니다.
```
git clone https://github.com/mgdm/Mosquitto-PHP.git
cd Mosquitto-PHP
phpize
./configure
make
sudo make install
```
로그인 후 복사
php.ini 무선 확장에 대한 경로가 설치 디렉터리에 추가되었는지 확인한 다음 Apache/nginx 서버를 다시 시작하세요.

Develop 게시자

<?php
require("phpMQTT.php");

$server = "mqtt服务器IP地址";   // MQTT服务器地址
$port = 1883;                   // MQTT服务器端口号
$username = "用户名";           // MQTT服务器用户名
$password = "密码";             // MQTT服务器密码
$client_id = "发布者ID";        // 发布者ID

$mqtt = new phpMQTT($server, $port, $client_id);

if ($mqtt->connect(true, NULL, $username, $password)) {
    $topic = "发布的主题";      // 发布的主题
    $message = "你好，这是一条实时消息。"; // 要发布的消息
    $mqtt->publish($topic, $message, 0);
    $mqtt->close();
} else {
    echo "连接失败！";
}

로그인 후 복사

위 코드는 지정된 MQTT 서버에 연결하고 지정된 주제에 메시지를 게시하여 MQTT 게시자의 인스턴스를 생성합니다.

구독자 개발

<?php
require("phpMQTT.php");

$server = "mqtt服务器IP地址";   // MQTT服务器地址
$port = 1883;                   // MQTT服务器端口号
$username = "用户名";           // MQTT服务器用户名
$password = "密码";             // MQTT服务器密码
$client_id = "订阅者ID";        // 订阅者ID

$mqtt = new phpMQTT($server, $port, $client_id);

if ($mqtt->connect(true, NULL, $username, $password)) {
    $topic = "订阅的主题";      // 订阅的主题
    $mqtt->subscribe($topic, 0);
    while ($mqtt->proc()) {
        // 在这里编写自己的业务逻辑
    }
    $mqtt->close();
} else {
    echo "连接失败！";
}

로그인 후 복사

위 코드는 MQTT 구독자의 인스턴스를 생성하고 지정된 MQTT 서버에 연결하고 특정 주제를 구독하여 해당 메시지를 얻습니다.

서버에서 게시자측(Publisher) 코드를 실행하면 브라우저를 통해 해당 페이지에 접속하여 실시간 메시지 푸시를 실행할 수 있습니다. 페이지의 콘텐츠를 실시간으로 업데이트하는 등 구독자측(구독자) 코드에 자신만의 비즈니스 로직을 추가할 수 있습니다.

요약

PHP와 MQTT 프로토콜을 함께 사용하면 실시간 메시지 푸시 기능을 쉽게 구현할 수 있습니다. 위의 예에서는 게시/구독 패턴을 사용하여 메시지를 게시하고 수신했습니다. 실제 개발 과정에서 필요에 따라 더 많은 확장과 사용자 정의를 수행할 수 있습니다. 이 기사가 도움이 되기를 바랍니다!

위 내용은 PHP 및 MQTT를 사용하여 실시간 메시지 푸시 기능을 개발하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!