最近业务需要,研究使用基于mqtt协议的mosquitto开发消息推送系统。环境:ubuntu14.04,php7.1,mosquitto安装mosquittosudoapt-getinstallmosquittoinstallPHPmosquittoextensionsudopeclinstallMosquitto-alpha并在“php.ini”中添加“extension=mosquitto.so”重启PHP编写PHP代码,vimMqttMessage.phpclassMqttMessage{publicfunctionMessage(){$client=newMosquitto\Client();$client->onConnect(function($code,$message)use($client){var_dump($code);var_dump($message);$client->subscribe('testing',0);//订阅消息其主题是测试});$client->onMessage(function($message)use($client){echo$message->topic,"\n",$message->payload,"\n\n";$client->publish('testing2','testing2',0);//如果主题是testing2,发布消息"testing2"});$client->connect('127.0.0.1',1883);$client->loopForever();}}$mqtt=newMqttMessage();$mqtt->消息();运行PHP脚本phpMqttMessage.php发布消息mosquitto_pub-ttesting-mtesting-messgaephp脚本接收消息并将其打印出来。在PHP脚本中,收到消息后,会发布消息到主题testing2,后台接收消息
