MQTT For Yii2 Base On Swoole 4
MQTT server for Yii2 base on swoole 4, Resolve topic as a route reflect into controller/action/param, And support redis pub/sub to trigger async task from your web application
Installation
Install Yii2: Yii2.
Install swoole: swoole, recommend version 4+.
Other dependency: php-redis extension.
The preferred way to install this extension is through composer.
Either run
php composer.phar require --prefer-dist immusen/yii2-swoole-mqtt "~1.0"
or add
"immusen/yii2-swoole-mqtt": "~1.0"
to the require section of your composer.json file.
Test or Usage
# after installation, cd project root path, e.g. cd yii2-advanced-project/
mv vendor/immusen/yii2-swoole-mqtt/example/mqtt ./
mv vendor/immusen/yii2-swoole-mqtt/example/mqtt-server ./
chmod a+x ./mqtt-server
# run:
./mqtt-server
# config :
cat ./mqtt/config/params.php
<?php
return [
'listen' => 8721,
'daemonize' => 0,
'auth' => 1, // config auth class in ./main.php
];
# or coding in ./mqtt/controllers/
Test client: MQTTLens, MQTT.fx
Example:
Case A: Subscribe/Publish
1, mqtt client subscribe topic: room/count/100011
2.1, mqtt client publish: every time publish topic: room/join/100011, the subscribe side will get count+1, or publish topic: room/leave/100011 get count -1.
2.2, redis client pulish: every time $redis->publish('async', 'room/join/100011'), the subscribe side will get count+1, or $redis->publish('async', 'room/leave/100011') get count -1.
Case B: Publish(Notification Or Report)
mqtt client publish topic: report/coord/100111 and payload: e.g. 110.12345678,30.12345678,0,85
Coding:
MQTT subscribe topic: "channel/count/100001" will handle at:
class ChannelController{
public function actionCount($channel_id){
echo "client {$this->fd} subscribed the count change of channel {$channel_id}";
}
}
//client 1 subscribed the count change of channel 100001
MQTT Publish Topic: "channel/join/100001" with payload: "Foo" will handle at:
class ChannelController{
public function actionJoin($channel_id, $who){
echo "{$who} join in channel {$channel_id}";
#then broadcast update to all client who subscribed channel 100001
#$this->publish($fds, $sub_topic, $count);
}
}
// Foo join in channel 100001
MQTT
About MQTT: MQTT Version 3.1.1 Plus Errata 01
Non-complete implementation of MQTT 3.1.1 in this project, Upgrading...
版权声明：
1、该文章(资料)来源于互联网公开信息，我方只是对该内容做点评，所分享的下载地址为原作者公开地址。2、网站不提供资料下载，如需下载请到原作者页面进行下载。
3、本站所有内容均由合作方或网友上传，本站不对文档的完整性、权威性及其观点立场正确性做任何保证或承诺！文档内容仅供研究参考学习用！
4、如文档内容存在违规，或者侵犯商业秘密、侵犯著作权等，请点击“违规举报”。
