workerman 如何实现实时的Api

$worker = new Worker('websocket://0.0.0.0:1234');
$worker->onWorkerStart = function(){
    $wss = new AsyncTcpConnection('ws://域名.com:443/xx/xx/?x=x&x=x');
    $wss->transport = 'ssl'; // ws+ssl 为 wss
    $wss->onClose = function($wss){
        $wss->connect(1); // 断开1秒后重连
    };
    $wss->onMessage = function($wss, $data) {
        global $worker;
        // 给worker的所有websocket连接转发数据
        foreach($worker->connections as $connection) {
            $connection->send($data);
        }
    };
};
Worker::runAll();

ws = new WebSocket('ws://workerman服务器的域名.com:1234');
ws.onmessage = function(e.data){
    console.log(e.data);
};