php|PHPMqtt详解 php|开发语言

参考 Documentation - PHP | CloudMQTTHosted message broker for the Internet of Things. Perfectly configured and optimized message queues for IoT, ready in seconds.https://www.cloudmqtt.com/docs-php.html
下载 GitHub - bluerhinos/phpMQTT: a simple php class to connect/publish/subscribe to a MQTT brokera simple php class to connect/publish/subscribe to a MQTT broker - GitHub - bluerhinos/phpMQTT: a simple php class to connect/publish/subscribe to a MQTT broker
文章图片
https://github.com/bluerhinos/phpMQTT
CloudMQTT 概述 Documentation | CloudMQTTHosted message broker for the Internet of Things. Perfectly configured and optimized message queues for IoT, ready in seconds.https://www.cloudmqtt.com/docs.html
客户端发布 /**
* Created by PhpStorm.
* Time: 16:47
*/

namespace App\Http\Controllers\Mqtt\v1;

use App\Common\Common;
use App\Http\Controllers\Controller;
use App\until\phpMQTT;
use Illuminate\Support\Facades\Config;
use Illuminate\Support\Facades\DB;
use App\Events\Handle;

class Subscript extends Controller
{
/*
手动执行监听 MQTT 订阅；
* php artisan Mqtt
*/
//所有配置放在配置文件config中
public function subscript(){
$server = config('mqtt.host'); // change if necessary 服务器IP
$port = config('mqtt.port'); // change if necessary端口一般是1883
$username = config('mqtt.username'); // set your username mosquitto设置的用户名
$password = config('mqtt.password'); // set your password mosquitto设置的密码
$client_id = config('mqtt.clientId'); //你的连接客户端id
$keepAlive = config('mqtt.keepAlive');
$mqtt = new phpMQTT($server, $port, $client_id,'',$keepAlive); //进行连接

//cleanSession 设为false，客户端掉线后服务器端不会清除session，当重连后可以接收之前订阅主题的消息。
//当客户端上线后会接受到它离线的这段时间的消息
//但是这个只是进行了重连，重连后还需要再次发起订阅
//接收遗嘱消息
if(!$mqtt->connect(true, NULL, $username, $password)) {
exit('error'); //连接失败
} else {
echo "success"; //连接成功
}
//topics["topic"]为接受的主题名需要和发送的主题名一致否则会订阅不到
//订阅信息 Qos为信息登记，需要和发送的等级一致
//可以订阅多个不同类型通知
$topics["SERVER/#"] = array("qos" => 0, "function" =>array($this,"onMessage"));
$topics["IM/#"] = array("qos" => 0, "function" =>array($this,"onImMessage"));
$mqtt->subscribe($topics, 0);
//死循环监听
while($mqtt->proc()){

}
$mqtt->close();
}

/**
* 在此处接MQtt的信息进行业务处理
* @param $topic
* @param $msg
* 设备订阅主题
* device/xxxxx/硬件号
* 设备发布的主题
* server/xxxxx/硬件号
* 设备遗嘱主题
* will/xxxxx/硬件号
* 处理逻辑写到handle文件中
* 处理逻辑写到handle文件中
* 处理逻辑写到handle文件中
*/
function onMessage($topic,$msg){
echo $topic;
echo "Msg Recieved: ".$msg;
//所有逻辑全移到handle
HandleController::business($topic,$msg);
}
/*
* 消息处理
*/
function onImMessage($topic,$msg){
//echo $msg;
echo $topic;
echo "Msg Recieved: ".$msg;
//所有逻辑全移到Im
ImMessageController::business($topic,$msg);
}
}

消息发送

namespace App\Http\Controllers\Mqtt\v1;

use App\Http\Controllers\Controller;
use App\until\phpMQTT;
use Illuminate\Http\Request;

class Publish extends Controller
{
/**
* @return bool
* 发送信息第三个参数为Qos服务质量等级
* Qos0发送者只发送一次消息，不进行重试，Broker不会返回确认消息。在Qos0情况下，Broker可能没有接受到消息
* Qos1发送者最少发送一次消息，确保消息到达Broker，Broker需要返回确认消息PUBACK。在Qos1情况下，Broker可能接受到重复消息
* Qos2Qos2使用两阶段确认来保证消息的不丢失和不重复。在Qos2情况下，Broker肯定会收到消息，且只收到一次
*/
public static function push($topic, $message, $QOS = 0, $will = null)
{
if (!$topic || !$message) {
return false;
}

//默认主题都大写。
//$topic=strtoupper($topic);
$host = config('mqtt.host'); //主机
$port = config('mqtt.port'); //端口
$username = config('mqtt.username'); //如果没有则为空
$password = config('mqtt.password'); //如果没有则为空
//phpMQTT 有四个参数：主机，端口，客户端id，证书。官网这里的案例没写证书，请参考phpMQTT类
//没有证书的时候只能连接1883端口，不能连接8883端口。
$mqtt = new phpMQTT($host, $port, "SERVER" . rand());

//连接
if ($mqtt->connect(true, $will, $username, $password)) {
$mqtt->publish($topic, $message, $QOS);
$mqtt->close(); //关闭
} else {
echo "Fail or time out
";
}

HandleController::logMqtt($topic, json_decode($message, true));
}

public function publish(Request $request)
{
$topic = $request->input('theme'); //发送的主题
$message = $request->input('content'); //要发送的消息
$QOS = $request->input('qos', 0); //要发送的消息服务质量等级
//print_r($topic); die;
//$willTopic = input('willTopic');
//$willMessage = input('willMessage');
//$willQos = input('willQos',0);
//$willRetain = input('willRetain',false); //1true
if (!$topic) {
return returnJson(50000, "主题不能为空");
}

if (!$message) {
return returnJson(50000, "消息不能为空");
}

$will = null;
//if($willMessage && $willTopic){
//$will['topic'] = $willTopic;
//$will['content'] = $willMessage;
//$will['qos'] = $willQos;
//$will['retain'] = $willRetain;
//}
self::push($topic, $message, $QOS, $will);
}
}
Publish::push($theme, json_encode($pushDate,JSON_UNESCAPED_UNICODE), Common::QOS());
【php|PHPMqtt详解】

php|PHPMqtt详解

推荐阅读

减肥期间能吃甜瓜吗

教师资格证可以每个人报考吗

如何包装礼盒驰名商标老包装怎么办，包装袋

出血热症状初期照片图出血热症状初期照片早期

禄口机场|南京禄口机场疫情感染者达65人，病例情况一图读懂

买房时如何解除购房合同

110万的房贷,贷款30年,利率4.165%,已经还了3年了,提前还一部分划得来吗？为什么？

redis界面工具 redis工具封装图片

考建造师证必须要靠安全员B证吗

2023年3月南宁普通话考试时间地点

我的世界手游中式凉亭怎么建我的世界手游中式凉亭建造图文攻略

元素分析怎么做,画面元素分析怎么做

vlog和短视频有什么区别

创投日报|钛媒体Pro创投日报：8月11日收录投融资项目22起

什么是薛定谔的猫薛定谔的猫是什么意思

2020立春是几月几号几点几分出生？2020立春是几月几日是几点几分

尼康P1000相机带尼康p1000旅游

孩子沉迷玩手机如何解决孩子沉迷玩手机怎么解决

测量肺活量的方法是什么？

ecosaver是什么牌子轮胎 ecovision轮胎是什么牌子