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

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

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

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

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

1. PHP 설치: PHP가 설치되어 있고 버전 요구 사항이 5.6 이상인지 확인하세요.

2. Mosquitto 라이브러리 설치: Mosquitto는 MQTT의 오픈 소스 구현입니다. . mosquitto 라이브러리는 다음 명령을 통해 설치할 수 있습니다.

   sudo apt-get install mosquitto

   로그인 후 복사

   이렇게 하면 mosquitto 런타임 라이브러리와 클라이언트가 설치됩니다.

개발 단계

1. 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 서버를 다시 시작하세요.

2. 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 게시자의 인스턴스를 생성합니다.

3. 구독자 개발

   <?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 서버에 연결하고 특정 주제를 구독하여 해당 메시지를 얻습니다.

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

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

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