TP中利用workman获取实时数据

use Workerman\Worker;
use Workerman\Lib\Timer;

require_once __DIR__.'/../../Workerman/Autoloader.php';

//设置心跳时间 55秒
define('Heartbeat',55);

$ws = new Worker('websocket://0.0.0.0:8012');


// 启动2个进程对外提供服务
$ws->count = 2;

$ws->onWorkerStart = function ($ws){
    //设置一个 间隔 1秒的定时
    Timer::add(1,function ()use($ws){
        $time_now = time();
        foreach($ws->connections as $connection) {
            // 有可能该connection还没收到过消息，则lastMessageTime设置为当前时间
            if (empty($connection->lastMessageTime)) {
                $connection->lastMessageTime = $time_now;
                continue;
            }
            // 上次通讯时间间隔大于心跳间隔，则认为客户端已经下线，关闭连接
            if ($time_now - $connection->lastMessageTime > Heartbeat) {
                $connection->close();
            }
        }
    });

};

//当客户端连接时
$ws->onConnect = function ($connection){
    echo $connection->id."connect \n";
};

// 当收到客户端发来的数据后返回hello $data给客户端
$ws->onMessage = function($connection, $data)
{

    $arr = ['device_id' => $data];
    //$data = json_decode($data,true);

    $row = httpsRequest('http://xxxxxxxxxxxx/api/getData',$arr);
    // 给connection临时设置一个lastMessageTime属性，用来记录上次收到消息的时间
    $connection->lastMessageTime = time();
    // 向客户端发送hello $data
    $connection->send($row);
};

$ws->onClose = function($connection)
{
   echo $connection->id."close \n";
};

//curl
function httpsRequest($url, $data=null) {
    //1.初始化会话
    $ch = curl_init();
    //2.设置URL和相应的选项
    //设置请求的url
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
    //保证返回成功的结果是服务器的结果
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    if(!empty($data)) {
        //发送post请求
        curl_setopt($ch, CURLOPT_POST, 1);
        //设置发送post请求参数数据
        curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
    }
    //3.执行会话,$result 是微信服务器返回的json字符串
    $result = curl_exec($ch);
    //4.关闭cURL资源，并且释放系统资源
    curl_close($ch);
    //5.返回json数组
    return $result;
}

// 运行worker
Worker::runAll();