require __DIR__ . '/vendor/autoload.php';
use Workerman\Worker;
use Workerman\Lib\Timer;
use Workerman\Connection\AsyncTcpConnection;

$worker = new Worker();
$worker->onWorkerStart = 'connect';
function connect(){
    static $count = 0;
    echo $count . "\n";
    if ($count++ >= 10000) return;
    // 建立異步鏈接
    $con = new AsyncTcpConnection('ws://127.0.0.1:7272');
    $con->onConnect = function($con) {
        // 遞歸調(diào)用connect
        connect();
    };
    $con->onMessage = function($con, $msg) {
        $msgInfo = json_decode($msg, true);
        if(isset($msgInfo['type']) && $msgInfo['type'] == 'ping'){
            $con->send('{"type":"pong"}');
        }
        echo "r $msg\n";
    };
    $con->onClose = function($con) {
        echo "con close\n";
    };

    Timer::add(5, function()use($con){
        $con->send('{"type":"pong"}');
    });
    $con->connect();
    echo $count, " connections complete\n";
}
Worker::runAll();

這個(gè)是如何測試的啊？先在自己服務(wù)器下 start了，發(fā)現(xiàn)就跑一遍啊。。。真是個(gè)小白，求解答