pauseRecv

    1. require_once __DIR__ . '/Workerman/Autoloader.php';
    2. $worker->onConnect = function($connection)
    3. {
    4. $connection->messageCount = 0;
    5. };
    6. $worker->onMessage = function($connection, $data)
    7. {
    8. if(++$connection->messageCount > $limit)
    9. {
    10. $connection->pauseRecv();
    11. }
    12. };