PHP 使用mosquiito_php教程

上一篇: 记一次PHP扩展-ZipArchive安装下一篇:PHP一键安装扩展的程序

PHP 使用mosquiito

发布时间：2019-08-07 发布网站：脚本宝典

脚本宝典收集整理的这篇文章主要介绍了PHP 使用mosquiito，脚本宝典觉得挺不错的，现在分享给大家，也给大家做个参考。

近期业务需要，调研和使用基于mqtt协议的mosquITto，开发一个消息推送系统。
环境：ubuntu 14.04,php7.1,mosquitto
安装mosquitto
sudo apt-get install mosquitto
安装PHP的mosquitto扩展

sudo PEcl install Mosquitto-alpha
然后把"extension=mosquitto.so "加到" php.ini"
重启PHP

编写PHP代码，vim MqttMessage.php

      
      
      var_dump($code);
            VAR_dump($message);
            $client->subscribe('testing', 0);//订阅topic为testing的消息
        });
        $client->onMessage(function($message) use($client){
            echo $message->topic, "n", $message->payload, "nn";
            $client->publish('testing2','testing2',0);//想topic为testing2，发布消息“testing2”
        });

        $client->connect('127.0.0.1', 1883);
        $client->loopForever();

    }
}
$mqtt =new MqttMessage();

 
$mqtt->Message();" title="" data-original-title="复制">
      
      
class MqttMessage{
    public function Message(){
        $client = new MosquittoClient();
        $client->onConnect(function($code, $message) use ($client) {
            var_dump($code);
            var_dump($message);
            $client->subscribe('testing', 0);//订阅topic为testing的消息
        });
        $client->onMessage(function($message) use($client){
            echo $message->topic, "n", $message->payload, "nn";
            $client->publish('testing2','testing2',0);//想topic为testing2，发布消息“testing2”
        });

        $client->connect('127.0.0.1', 1883);
        $client->loopForever();

    }
}
$mqtt =new MqttMessage();

 
$mqtt->;message();
运行PHP脚本
php MqttMessage.php

发布消息
mosquitto_pub -t testing -m testing-messgae
php脚本接受到消息并且打印出来

PHP脚本中，在收到消息后，会发布一个消息到topic为testing2中，后台会接收消息