非常感謝,每個(gè)客戶端連接到a后都需要與b建立連接

我用的是這個(gè)http://www.wtbis.cn/doc/workerman/tcp-connection/pipe.html
其中有個(gè)代碼是$connection->pipe($connection_to_80);
下面是我的代碼
class Events
{

public static function onWorkerStart($businessWorker){

    Log::info('啟動(dòng)服務(wù)');
}
public static function onConnect($client_id){
    $connection_to_three = new AsyncTcpConnection('tcp://0.0.0.0:3000');
    // 設(shè)置將當(dāng)前客戶端連接的數(shù)據(jù)導(dǎo)向第三方的連接

    /*
    1 public static function onConnect($client_id,TcpConnection $connection) 在這里引入報(bào)錯(cuò),多了參數(shù)
    2 $connection = new TcpConnection(); 這樣寫報(bào)錯(cuò):需要參數(shù)
    3 $connection = new TcpConnection(connection_to_three); 這樣寫報(bào)錯(cuò):需要的是resource,不是obj
    如何在這個(gè)方法里使用 TcpConnection $connection
    */ 

    $connection->pipe($connection_to_three);

    // 設(shè)置80端口連接返回的數(shù)據(jù)導(dǎo)向客戶端連接
    $connection_to_three->pipe($connection);
    // 執(zhí)行異步連接
    $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);
}

}