5

我已经从https://mosquitto.org/download/在我的 Windows 机器上安装了 MQTT 代理。

我正在使用https://github.com/bluerhinos/phpMQTT/tree/master/examples进行发布和订阅。发布按预期工作，但订阅不起作用。

我不明白为什么这不起作用。MQTT 代理需要连接远程 MQTT 服务器吗？我想在 php 中实现发布和订阅方法

发布：

require("../phpMQTT.php");


$mqtt = new phpMQTT("host", 1883, "124464646464/32"); //Change client name to something unique

if ($mqtt->connect()) {
    echo "Connect Sucssfully";
    try
    {
        $mqtt->publish("124464646464/Test","Hello HK123! at ".date("r"),0);
        echo  "<br>publish done";
        $mqtt->close();
    }
    catch(Exception $e)
    {
        echo $e;
    }
}

订阅：

ini_set('output_buffering','on');
require("../phpMQTT.php");


$mqtt = new phpMQTT("host", 1883, "124464646464/27"); //Change client name to something unique

if(!$mqtt->connect()){
    exit(1);
}

$topics['124464646464/Test'] = array("qos"=>0, "function"=>"procmsg");
$mqtt->subscribe($topics,0);

while($mqtt->proc()){

}


$mqtt->close();

function procmsg($topic,$msg){
        echo "Msg Recieved: ".date("r")."\nTopic:{$topic}\n$msg\n";
}

错误： 错误的订阅标头

获取错误表单主机错误日志

编辑：

我已经使用命令行运行了订阅脚本，它总是打印“eof receive going to reconnect for good measure\n”意味着总是从feof函数 中得到真实

代码：

if(feof($this->socket)){
                if($this->debug) echo "eof receive going to reconnect for good measure\n";
                fclose($this->socket);
                $this->connect_auto(false);
                if(count($this->topics))
                    $this->subscribe($this->topics);    
            }

我已经使用 chrome 扩展测试了我的发布页面，这意味着使用 chrome 扩展进行订阅，它工作正常意味着读取套接字中有问题。

4

1 回答 1

1

更新phpMQTT.php文件：

private $socket=8080;           /* holds the socket */
于 2016-12-10T20:03:48.367 回答