phpmqtt

本文地址：http://tongxinmao.com/Article/Detail/id/158

1
2
3
4
5
6
7
8
9
10
11
12
13
14
<?php
 
require("phpMQTT.php");
 
     
$mqtt = new phpMQTT("xxx.com", 1883, "phpMQTT Pub Example"); //Change client name to something unique
 
if ($mqtt->connect()) {
    $mqtt->publish("gpio","Hello World! at ".date("r"),0);
    $mqtt->publish("gpio",pack("C", 0xe1).pack("C", 0xff),0);
    $mqtt->close();
}
 
?>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
<?php
 
require("phpMQTT.php");
 
$mqtt = new phpMQTT("xxx.com", 1883, "phpMQTT Sub Example"); //Change client name to something unique
 
if(!$mqtt->connect()){
exit(1);
}
 
$topics['gpio'] = 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";
for($i=0;$i<strlen(msg);$i++)
      echo '0x'.bin2hex(msg[$i]).' ';
}
 
 
?>


上一篇：tanyu wenben
下一篇：swoole知识点 常见问题