连接gateway发送消息报错

$ip = 'text://127.0.0.1:12345';

$task_connection = new AsyncTcpConnection( $ip );
// 任务及参数数据
$task_data = array(
    'function' => $funcName ,
    'args'     => $args ,
);
// 发送数据
$task_connection->onConnect = function( AsyncTcpConnection $task_connection ) use ( $task_data ) {
    $task_connection->send( json_encode( $task_data ) );
};