Worker('text://0.0.0.0:6161');
$worker->onWorkerStart = function() {
// 以websocket协议连接远程websocket服务器assets=bitcoin,ethereum");
//$con->transport = 'ssl';
// 注册连接上后的事件
$con->onConnect = function$con->onMessage = function($con, $data){
echo "recv: $data\n";
};
// 连接上发生错误时,一般是连接远程websocket服务器失败错误
$con->onError = function($con, $code, $msg){
echo "error: $msg\n";
}n";
$con->reconnect(1);
};
// 设置好以上各种回调后,执行连接操作
$con->connect();
};
Worker::runAll