');
$worker->onConnect = function(TcpConnection $connection)
{
// 给connection对象动态添加一个属性,用来保存当前连接发来多少个请求= 0;
};
$worker->onMessage = function(TcpConnection $connection, $data)
{
// 每个连接接收100个请求后就不再接收数据if(++$connection->messageCount > $limit)
{
$connection->pauseRecv();
// 30秒后恢复接收数据resumeRecv();
}, array($connection), false);
}
};
// 运行worker
Worker::runAll();
```
经测发现接受数据100次以后是每间隔30s接收一次数据 问题是出在timer上吗
timer定时器放在onmessages()里是每次接受到数据都启动一个定时器吧 这样是不是有问题?