EMQ X HTTP API

EMQ X 管理组件资源开放接口 PHP 的实现版

安装

composer require kain/emqx-management-api

快速开始

创建客户端

$emqx = EMQXAPIEMQXClient::create( 'http://localhost:8081/api/v4/', '<your appid>', '<your appsecret>' ); $response = $emqx->endpoints(); if ($response->isError()) { echo $response->getMsg(); return; } var_dump($response->result());

或者自定义 GuzzleHttpClient

$client = new GuzzleHttpClient([ 'base_uri' => 'http://localhost:8081/api/v4/', 'auth' => ['<your appid>', '<your appsecret>'], 'timeout' => 30.0, 'debug' => false, 'verify' => false, 'version' => 1.1 ]); $emqx = new EMQXAPIEMQXClient($client); $response = $emqx->endpoints(); if ($response->isError()) { echo $response->getMsg(); return; } var_dump($response->result());

发布消息

$option = new EMQXAPICommonMqttPublishOption( ['notification'], 'hello' ); $option->setEncoding('plain'); $option->setQos(0); $option->setRetain(false); $response = $emqx->mqtt()->publish($option); if ($response->isError()) { echo $response->getMsg(); return; } var_dump($response->result());

SDK 遵循官网文档开发，https://docs.emqx.cn/broker/latest/advanced/http-api.html

重大变更