AsyncTcpConnection作为客户端的问题

$con = new AsyncTcpConnection('ws://106.52.xx.xx:9001');
$con->connect();
$con->onConnect = function($con) use($objJob){
    $strcontent = json_encode($objJob);
    worker::log('contents:'.$strcontent);
    $con->send($strcontent);
};
$con->onMessage = function($con, $data) {
    worker::log($data);
};
$con->onError = function ($con, $code, $msg){
    worker::log($msg);
};