补充
感谢各位吴彦祖的回答,我现在实现方法类似:
Task.php
```php
<?->get();
foreach ($rs as $row){
/*防止上一轮任务没跑完又重新添加进来了
*/
$key = 'apiName_'.response($httpCode,$response);
}
}
```
实现过程:
通过Timer设定30分钟,全量查一次需要拉取的产品,丢入redis队列中,其中防止重复入列,所以增加了个判断任务是否存在于队列中但是现在实际出现情况是:
开5个redis消费,设定查询间隔是1000毫秒,实际产生QPS会达到10~20,理论应该QPS是3~8吧?毕竟usleep并不是那么精准。