在自己的tcp服务和第三方tcp服务器建立长连接

非常感谢,每个客户端连接到a后都需要与b建立连接

我用的是这个https://www.workerman.net/doc/workerman/tcp-connection/pipe.html
其中有个代码是$connection->pipe($connection_to_80);
下面是我的代码
class Events
{

public static function onWorkerStart($businessWorker){

    Log::info('启动服务');
}
public static function onConnect($client_id){
    $connection_to_three = new AsyncTcpConnection('tcp://0.0.0.0:3000');
    // 设置将当前客户端连接的数据导向第三方的连接

    /*
    1 public static function onConnect($client_id,TcpConnection $connection) 在这里引入报错,多了参数
    2 $connection = new TcpConnection(); 这样写报错:需要参数
    3 $connection = new TcpConnection(connection_to_three); 这样写报错:需要的是resource,不是obj
    如何在这个方法里使用 TcpConnection $connection
    */ 

    $connection->pipe($connection_to_three);

    // 设置80端口连接返回的数据导向客户端连接
    $connection_to_three->pipe($connection);
    // 执行异步连接
    $connection_to_three->connect();
    Log::info('连接成功-' . $client_id);

}
public static function onWebSocketConnect($client_id, $data){
    Log::info('onWebSocketConnect' . $client_id);
}
public static function onMessage($client_id, $message){

    Log::info('收到消息-' .$message.'-'. $client_id);
    Gateway::sendToClient($client_id,$message.'3000');
}

public static function onClose($client_id){
    Log::info('断开连接-' . $client_id);
}

}