185
**MQTT内数据为**
{"code":"LI2701_LS_HH","type":"BOOL","value":false,"timestamp":"1617874140"}
**服务端代码);
};
$mqtt->onMessage = function($topic, $content){
global $db;
// 与远程task服务建立异步连接,ip为远程task服务的ip,如果是本机就是127.0.0.1,如果是集群就是lvs的ip
$task_connection = new AsyncTcpConnection('Text://127.0.0.1:22345');
// 任务及参数数据
// $task_data = array(
// 'function' =>获得结果后记得关闭异步连接
$task_connection->close();
// 通知对应的websocket客户端任务完成