在基于Pub的应用程序中,我使用CloudMQTT作为MQTT broker。我正在使用我的publisher通过一个topic向CloudMQTT server发布数据,并且我计划在我的网页上向代理发布数据,以接收所传输的信息。
我正在使用这个过程创建一个Client(订阅者):https://www.cloudmqtt.com/docs-php.html
代码如下:
// subscribe.php
require("phpMQTT.php");
$host = "hostname";
$port = port;
$username = "username";
$password = "password";
$mqtt = new phpMQTT($host, $port, "ClientID".rand());
if(!$mqtt->connect(true,NULL,$username,$password)){
exit(1);
}
//currently subscribed topics
$topics['topic'] = array("qos"=>0, "function"=>"procmsg");
$mqtt->subscribe($topics,0);
while($mqtt->proc()){
}
$mqtt->close();
function procmsg($topic,$msg){
echo "Msg Recieved: $msg";
}下面是phpMQTT.php文件:https://github.com/bluerhinos/phpMQTT/blob/master/phpMQTT.php
但是,这种情况下的问题是,只有当网页打开时,它才会接收数据。我想保持连接的活力,即使网页不开放总是收到已发布的信息,我怎么做呢?
编辑:如果有人可以推荐一些替代方案的话,我可能会在服务器上使用其他一些技术来处理这个订阅过程。
发布于 2016-10-24 15:38:59
PHP通常的操作模式是启动进程,等待HTTP连接,处理请求,然后启动新进程。这与具有长期运行过程的典型MQTT模式不太匹配;因此,当您关闭网页时,关闭MQTT连接。
可以在长期运行的CLI脚本中订阅MQTT主题,但是您必须有一些其他机制来保持进程的运行。根据您的首选项和操作系统,有很多不同的方法可以做到这一点:
搜索堆栈溢出可以找到以下相关问题和几个答案:
https://stackoverflow.com/questions/40221652
复制相似问题