137 lines
4.2 KiB
PHP
137 lines
4.2 KiB
PHP
<?php
|
|
/**
|
|
* @link http://www.yiiframework.com/
|
|
* @copyright Copyright (c) 2008 Yii Software LLC
|
|
* @license http://www.yiiframework.com/license/
|
|
*/
|
|
|
|
namespace app\commands;
|
|
ini_set('default_socket_timeout', -1);
|
|
|
|
use yii\console\Controller;
|
|
use yii\console\ExitCode;
|
|
use \PhpMqtt\Client\MQTTClient;
|
|
use \PhpMqtt\Client\ConnectionSettings;
|
|
|
|
/**
|
|
* This command echoes the first argument that you have entered.
|
|
*
|
|
* This command is provided as an example for you to learn how to create console commands.
|
|
*
|
|
* @author Qiang Xue <qiang.xue@gmail.com>
|
|
* @since 2.0
|
|
*/
|
|
class MqttController extends Controller
|
|
{
|
|
/**
|
|
* @var string 使用此队列入库到数据库
|
|
*/
|
|
public $redis_name_mqtt_sub_list = "console:cxaibc:mqtt:sub:list";
|
|
|
|
|
|
/**
|
|
* @var string 球车数据键
|
|
*/
|
|
public $redis_name_mqtt_qc_data = "api:cxaibc:mqtt:data:";
|
|
public $mqtt;
|
|
|
|
/**
|
|
* This command echoes what you have entered as the message.
|
|
* @param string $message the message to be echoed.
|
|
* @return int Exit code
|
|
*/
|
|
public function actionIndex()
|
|
{
|
|
global $argv;
|
|
if(empty($argv[2])){
|
|
var_dump("启动失败，参数错误");
|
|
exit();
|
|
}
|
|
if($argv[2] == 'sub_mqtt'){
|
|
$this->subMqttData();
|
|
return ExitCode::OK;
|
|
}
|
|
/*if($argv[2] == 'pub_mqtt'){
|
|
$this->pubMqttData();
|
|
return ExitCode::OK;
|
|
}*/
|
|
return ExitCode::OK;
|
|
}
|
|
|
|
/**
|
|
* @ Author : Lw
|
|
* @ CreateTime : 2022-10-31
|
|
* @ Info : 连接mqtt
|
|
*/
|
|
public function connectMqtt(){
|
|
try{
|
|
if(!empty($this->mqtt)){
|
|
$this->mqtt->publish('test/ping',json_encode(['msg'=>'test','time'=>time()]),0,true);
|
|
return true;
|
|
}
|
|
var_dump("连接mqtt");
|
|
$server = 'k676f641.cn-shenzhen.emqx.cloud';
|
|
$port = 11732;
|
|
$clientId = md5(microtime(true));
|
|
$username = '123456';
|
|
$password = '123456';
|
|
$this->mqtt = new MqttClient($server, $port, $clientId);
|
|
$this->mqtt->connect($username,$password);
|
|
var_dump("连接mqtt成功");
|
|
}catch (\Exception $e){
|
|
$this->mqtt = null;
|
|
var_dump($e->getMessage());
|
|
var_dump($e->getFile());
|
|
var_dump($e->getLine());
|
|
}catch (\Error $e){
|
|
$this->mqtt = null;
|
|
var_dump($e->getMessage());
|
|
var_dump($e->getFile());
|
|
var_dump($e->getLine());
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @ Author : Lw
|
|
* @ CreateTime : 2022-10-31
|
|
* @ Info : 订阅mqtt消息
|
|
*/
|
|
public function subMqttData(){
|
|
var_dump("订阅mqtt消息");
|
|
while (True){
|
|
try{
|
|
var_dump("订阅mqtt消息");
|
|
$this->connectMqtt();
|
|
$this->mqtt->subscribe("+/Detail", function ($topic, $message) {
|
|
var_dump($topic,$message,$this->getBytes($message));
|
|
/*$explode = explode('/',$topic);
|
|
if(!in_array($explode[1],['Detail','Warn'])){
|
|
return false;
|
|
}
|
|
var_dump($explode,$message);
|
|
\Yii::$app->redis->lpush($this->redis_name_mqtt_list,json_encode([
|
|
'id' => $explode[0],
|
|
'data' => $message,
|
|
]));
|
|
\Yii::$app->redis->set($this->redis_name_mqtt_qc_data.$explode[0],json_encode([
|
|
'data' => $message,
|
|
'time' => time(),
|
|
]));*/
|
|
},0);
|
|
$this->mqtt->loop(true);
|
|
}catch (\Exception $e){
|
|
$this->mqtt = null;
|
|
var_dump($e->getMessage());
|
|
var_dump($e->getFile());
|
|
var_dump($e->getLine());
|
|
}catch (\Error $e){
|
|
$this->mqtt = null;
|
|
var_dump($e->getMessage());
|
|
var_dump($e->getFile());
|
|
var_dump($e->getLine());
|
|
}
|
|
sleep(1);
|
|
}
|
|
}
|
|
}
|