Windows マシンにhttps://mosquitto.org/download/から MQTT ブローカーをインストールしました。
パブリッシュとサブスクライブにhttps://github.com/bluerhinos/phpMQTT/tree/master/examplesを使用しています。パブリッシュは期待どおりに機能しますが、サブスクライブは機能しませんでした。
なぜこれが機能しないのか理解できませんでした。リモート MQTT サーバーに接続するために MQTT ブローカーが必要ですか? phpでpublishとsubscribeメソッドを実装したい
公開：
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関数 から true を取得することを意味します
コード：
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 拡張機能を使用してサブスクライブすることを意味します。正常に動作しているということは、 read socket に何か問題があることを意味します。