Try EMQX Platform on Azure, Enjoy AI Integration and Simplified Billing →

PHPでのMQTT使用法

Guowei Li
Dec 28, 2023
MQTTプログラミング
PHPでのMQTT使用法

目次

PHPは、広く使われているオープンソースの多目的スクリプト言語で、HTMLに埋め込むことができ、特にWeb開発に適しています。

この記事では、PHPプロジェクトでphp-mqtt/clientクライアントライブラリを使って、MQTTクライアントとMQTTブローカー間の接続、サブスクライブ、サブスクライブ解除、メッセージの受信と送信の機能を実装する方法について主に紹介します。

MQTTクライアントライブラリの選択

この記事では、Composerで最もダウンロードされているphp-mqtt/clientライブラリを選択しています。他のPHP-MQTTクライアントライブラリについては、Packagist-Search MQTTでご覧ください。

php-mqtt/clientの詳細なドキュメントについては、Packagist php-mqtt/clientを参照してください。

MQTT通信はHTTPシステム外のネットワーク通信シナリオに属します。PHPの特性の制限のため、Swoole/Workermanなどのネットワーク通信用の拡張機能をPHPシステムで使用すると、より良い体験が得られます。この記事ではその使用については繰り返しません。関連するMQTTクライアントライブラリは以下の通りです：

プロジェクトの初期化

PHPバージョンの確認

このプロジェクトは開発とテストに7.4.21を使用しています。次のコマンドでPHPバージョンを確認できます。

php --version

PHP 7.4.21 (cli) (built: Jul 12 2021 11:52:30) ( NTS )
Copyright (c) The PHP Group
Zend Engine v3.4.0, Copyright (c) Zend Technologies
    with Zend OPcache v7.4.21, Copyright (c), by Zend Technologies

Composerを使ってphp-mqtt/clientをインストール

ComposerはPHPの依存関係管理ツールで、PHPプロジェクトが必要とするすべての依存関係を管理することができます。

composer require php-mqtt/client

PHP MQTTの使用

MQTTブローカーに接続

この記事では、EMQXが提供する無料の公開MQTTブローカーを使用します。これはEMQXのMQTTクラウドサービス上で作成されています。サーバーのアクセス情報は以下の通りです：

  • ブローカー: broker.emqx.io
  • TCPポート: 1883
  • SSL/TLSポート: 8883

Composerのオートロードファイルとphp-mqtt/clientをインポート

require('vendor/autoload.php');

use \PhpMqtt\Client\MqttClient;

MQTTブローカー接続パラメータの設定

MQTTブローカー接続アドレス、ポート、トピックを設定します。同時に、PHPのrand関数を呼び出して、MQTTクライアントIDをランダムに生成します。

$server   = 'broker.emqx.io';
$port     = 1883;
$clientId = rand(5, 15);
$username = 'emqx_user';
$password = 'public';
$clean_session = false;
$mqtt_version = MqttClient::MQTT_3_1_1;

MQTT接続機能の記述

上記のパラメータを使用して接続し、ConnectionSettingsを通じて接続パラメータを設定します。例えば：

$connectionSettings = (new ConnectionSettings)
  ->setUsername($username)
  ->setPassword($password)
  ->setKeepAliveInterval(60)
  ->setLastWillTopic('emqx/test/last-will')
  ->setLastWillMessage('client disconnect')
  ->setLastWillQualityOfService(1);

サブスクライブ

emqx/testトピックをサブスクライブするプログラムを作成し、サブスクライブに対するコールバック関数を設定して、受信したメッセージを処理します。ここではサブスクライブから得られたトピックとメッセージを出力します：

$mqtt->subscribe('emqx/test', function ($topic, $message) {
    printf("Received message on topic [%s]: %s\n", $topic, $message);
}, 0);

パブリッシュ

ペイロードを構築し、publish関数を呼び出してメッセージをemqx/testトピックにパブリッシュします。パブリッシュ後、クライアントは受信メッセージと再送信キューを処理するためにポーリング状態に入る必要があります：

for ($i = 0; $i< 10; $i++) {
  $payload = array(
    'protocol' => 'tcp',
    'date' => date('Y-m-d H:i:s'),
    'url' => 'https://github.com/emqx/MQTT-Client-Examples'
  );
  $mqtt->publish(
    // topic
    'emqx/test',
    // payload
    json_encode($payload),
    // qos
    0,
    // retain
    true
  );
  printf("msg $i send\n");
  sleep(1);
}

// The client loop to process incoming messages and retransmission queues
$mqtt->loop(true);

全体のソースコード

サーバー接続、メッセージのパブリッシュ、受信のコード。

<?php

require('vendor/autoload.php');

use \PhpMqtt\Client\MqttClient;
use \PhpMqtt\Client\ConnectionSettings;

$server   = 'broker.emqx.io';
$port     = 1883;
$clientId = rand(5, 15);
$username = 'emqx_user';
$password = 'public';
$clean_session = false;
$mqtt_version = MqttClient::MQTT_3_1_1;

$connectionSettings = (new ConnectionSettings)
  ->setUsername($username)
  ->setPassword($password)
  ->setKeepAliveInterval(60)
  ->setLastWillTopic('emqx/test/last-will')
  ->setLastWillMessage('client disconnect')
  ->setLastWillQualityOfService(1);


$mqtt = new MqttClient($server, $port, $clientId, $mqtt_version);

$mqtt->connect($connectionSettings, $clean_session);
printf("client connected\n");

$mqtt->subscribe('emqx/test', function ($topic, $message) {
    printf("Received message on topic [%s]: %s\n", $topic, $message);
}, 0);

for ($i = 0; $i< 10; $i++) {
  $payload = array(
    'protocol' => 'tcp',
    'date' => date('Y-m-d H:i:s'),
    'url' => 'https://github.com/emqx/MQTT-Client-Examples'
  );
  $mqtt->publish(
    // topic
    'emqx/test',
    // payload
    json_encode($payload),
    // qos
    0,
    // retain
    true
  );
  printf("msg $i send\n");
  sleep(1);
}

$mqtt->loop(true);

テスト

MQTTメッセージパブリッシュコードを実行すると、クライアントが正常に接続され、メッセージが順番にパブリッシュされ、正常に受信されたことが確認できます：

php pubsub_tcp.php

PHP MQTT テスト)

まとめ

これまでに、php-mqtt/clientを使って無料の公開MQTTブローカーに接続し、テストクライアントとMQTTサーバー間の接続、メッセージのパブリッシュ、サブスクライブを実装しました。

次に、EMQが提供するMQTTプロトコル入門ガイドシリーズの記事をチェックし、MQTTプロトコルの機能を学び、MQTTのより高度な応用を探求し、MQTTアプリケーションおよびサービス開発をスムーズに始めます。

無料トライアルEMQX Cloud
IoT向けフルマネージド型MQTTサービス
無料トライアル →
編集
Guowei Li

Guowei Li

EMQX product manager, develop EMQX with user experience and integration capabilities.

ブログの購読

お問い合わせ