$ws_worker->onMessage = function($connection, $data)
{
    // 假設需要轉發(fā)給所有的設備
    global $ws_worker;
    foreach($ws_worker->socketWorker->connections as $socket_con)
    {
         $socket_con->send($data);
    }
};