MQTT 订阅问题

fastammo

我是参考 https://github.com/bluerhinos/phpMQTT
收MQTT没问题，但改用CI去接收就不行
请问要怎么改才能运作?

1. <?php
   
2. defined('BASEPATH') OR exit('No direct script access allowed');
   
3. 
   
4. //include_once(__DIR__ . '/../phpMQTT.php');
   
5. 
   
6. class MQTT_subscribe extends CI_Controller {
   
7. 
   
8.         public function __construct()
   
9.         {
   
10.                 parent::__construct();
    
11.         }
    
12. 
    
13.         public function MQTTSubscribe()
    
14.         {
    
15.                 $server = "IP";     // change if necessary
    
16.                 $port = 1883;                     // change if necessary
    
17.                 $username = "XXX";                   // set your username
    
18.                 $password = "XXX";                   // set your password
    
19.                 $client_id = "phpMQTT-subscriber"; // make sure this is unique for connecting to sever - you could use uniqid()
    
20. 
    
21.                 $mqtt = new phpMQTT($server, $port, $client_id);
    
22. 
    
23.                 if(!$mqtt->connect(true, NULL, $username, $password)) {
    
24.                        
    
25.                         goto err_out;
    
26.                 }
    
27. 
    
28.                 $topics['bluerhinos/phpMQTT/examples/publishtest'] = array("qos" => 0, "function" => "procmsg");
    
29. 
    
30.                 $mqtt->subscribe($topics, 0);
    
31. 
    
32.                 while($mqtt->proc()){
    
33.                                
    
34.                 }
    
35.                
    
36.                 $mqtt->close();
    
37. 
    
38.         err_out:
    
39.                 return ;               
    
40.         }       
    
41.        
    
42.         function procmsg($topic, $msg){
    
43.                 //echo "Msg Recieved: " . date("r") . "\n";
    
44.                 //echo "Topic: {$topic}\n\n";
    
45.                 //echo "\t$msg\n\n";
    
46. 
    
47.         err_out:
    
48.                 return $msg;                       
    
49.         }       
    
50. }

复制代码

Hex

报什么错呢？

fastammo

Hex 发表于 2019-5-29 23:35
报什么错呢？

并没有提示错误，看起来是没有呼叫function procmsg

kiufei

您是怎么解决的？

widelia

解决了吗？