无限重连问题

$worker = new Worker();

$worker->onWorkerStart = function ($worker) {

    //a客户端
    $con = new AsyncTcpConnection('ws:/aaa.com');
    $con->onConnect = function ($con) {
        echo '=连接=';
        $con->lastMessageTime = time();

        //心跳
        $time_interval = 5;
        $con->timer_id = Timer::add($time_interval, function () use ($con) {
            $stamp = time();
            //断线重连
            if (($stamp - $con->lastMessageTime) > 7) {
                echo '=断线重连=';
                Timer::del($con->timer_id);
                $con->close();
            } else {
                $con->send('{"ping": '. $stamp .'}');
            }
        });
    };

    $con->onMessage = function ($con, $data) {
        $data = json_decode($data, true);
        if (isset($data)) {
            $con->lastMessageTime = $data;
            return;
        }
    };

    $con->onClose = function ($con) {
        echo '=关闭=';
        if (isset($con->timer_id)) {
            Timer::del($con->timer_id);
        }
        $con->reConnect(2);
    };

    $con->connect();

    //b客户端
    $cons = new AsyncTcpConnection('ws:/bbb.com');
    $cons->onConnect = function ($cons) {
        echo '=连接s=';
        $cons->lastMessageTime = time();

        //心跳
        $time_interval = 5;
        $cons->timer_id = Timer::add($time_interval, function () use ($cons) {
            $stamp = time();
            //断线重连
            if (($stamp - $cons->lastMessageTime) > 7) {
                echo '=断线重连s=';
                Timer::del($cons->timer_id);
                $cons->close();
            } else {
                $cons->send('{"ping": '. $stamp .'}');
            }
        });
    };

    $cons->onMessage = function ($cons, $data) {
        $data = json_decode($data, true);
        if (isset($data)) {
            $cons->lastMessageTime = $data;
            return;
        }
    };

    $cons->onClose = function ($cons) {
        echo '=关闭s=';
        if (isset($cons->timer_id)) {
            Timer::del($cons->timer_id);
        }
        $cons->reConnect(2);
    };

    $cons->connect();
};

Worker::runAll();

运行一段时候，会出现下图中的无限断线重连问题，客户端a和b都有出现过这个问题，实在想不通，求助