Mosquitto-PHP(MQTTクライアント)にて、通信相手に送信(Publish)したら通信相手からのデータを受ける(subscribe/onMessage)プログラムを作ってます。
送信した後に相手から受信が10秒間なかったらタイムアウトして切断(disconnect)したいですが、どのように記載すべきでしょうか?
以下の動作は
(1)connectで接続
(2)subscribeでTopicを受信状態(onConnect内で接続されたらsubscribeしています。)
(3)publishでメッセージ送信(onSubscribe内でsubscribe完了したら送信(publish)しています。)
(4)subscribeしているTopicのメッセージを受信(onMessage内)
という感じで進めています。
(3)のpublishで通信相手(subscribe)に通信が送信しています。
(4)で通信相手がpublishしてくれたものをsubscribeで受ける処理を想定しています。
ただ、通信相手が確実に送信(Publish)してくれるかはわかりませんので10秒程度
onMessage(subscribeしているTopic)で待っているけど何も届かない場合にタイムアウトして切断(disconnect)したいと考えています。
ご教授をお願いします。
php
1<?php 2 3$jobType = 0; 4$cliId = 'client1'; 5 6$c = new Mosquitto\Client($cliId); 7$c->onConnect(function($r) use ($c) { 8 echo "I got code {$r}\n"; 9 if ( $r == 0 ) { 10 $c->subscribe('recv1', 0); // (2) 11 } else { 12 echo "connectErr {$r}\n"; 13 $c->disconnect(); 14 return; 15 } 16}); 17$c->onSubscribe(function() use ($c) { 18 echo "Subscribed to a topic\n"; 19 $jobType = 1; 20 $mid = $c->publish('send1', "Hello job1", 0, false); // (3) 21 echo "Sent1 message ID: {$mid}\n"; 22}); 23$c->onMessage(function($message) use ($c) { // (4) 24 printf("Got a message ID %d on topic %s with payload:\n%s\n\n", $message->mid, $message->topic, $message->payload); 25 // jobType1 26 if ( $jobType == 1 && $message->payload=='OK' ) { 27 $jobType = 2; 28 $mid = $c->publish('send1', "Hello job2", 0, false); 29 echo "Sent2 message ID: {$mid}\n"; 30 // jobType2 31 } else if ( $jobType == 2 && $message->payload=="OK" ) { 32 echo "job2 Complete!\n"; 33 $c->disconnect(); 34 // Error 35 } else { 36 echo "job Error [$jobType]\n"; 37 $c->disconnect(); 38 return; 39 } 40}); 41 42$c->connect("a.mosq.net", 1883, 60); // (1) 60:KeepAlive 43$c->loopForever(); 44 45echo "Finished\n"; 46
回答1件
あなたの回答
tips
プレビュー