我有一个 Laravel 5.2 工作,我通常希望它不间断地运行。为了说明这一点,假设它生成一些随机数,然后通过事件将其广播到前端。
/**
* Execute the job. Generate a random number.
*/
public function handle()
{
$number = rand();
event(new NumberWasGenerated($number));
}
无论出于何种原因,我希望此作业无限期运行。因此,我做了另一项工作,它循环并不断调度新的GenerateNumber
工作。
/**
* Execute the job. Continuously generate numbers.
*
* @return void
*/
public function handle()
{
while (true) {
$this->dispatch(new GenerateNumber());
}
}
但是,如果我决定,我确实希望能够"关闭"发电机。这就是我遇到麻烦的地方。
理想情况下,我希望能够到达像/abort
这样的路由,然后它会向我的生成器循环发送中断并停止其执行。我该怎么做?
或者,我可以尝试轮询方法。我尝试使用类似的东西:
/**
* Execute the job. Continuously generate numbers.
*
* @return void
*/
public function handle()
{
Config::set('shouldGenerate', true);
while (Config::get('shouldGenerate')) {
$this->dispatch(new GenerateNumber());
}
}
然后,在我的controller
/abort
方法中,我有
public function abort()
{
Config::set('shouldGenerate', false);
}
但是,abort
似乎不起作用。我认为问题似乎是 abort
方法永远没有机会执行,因为生成器循环是一个球猪,但我不确定为什么会这样。
问题:
1(我可以使用中断方法来实现这一点吗?
2( 如果没有,我如何通过轮询实现这一目标?
您可以通过组合这两个选项来实现此目的
- 中断
- 投票
您可以按如下方式重写中止操作
public function abort()
{
Config::set('shouldGenerate', false);
exec('PATH/TO/YOUR/RDIS/SERVER/src/redis-cli FLUSHDB');
}
并更改句柄方法,如下所示:
/**
* Execute the job. Continuously generate numbers.
*
* @return void
*/
public function handle()
{
$shouldGenerate = Config::get('shouldGenerate');
while ($shouldGenerate) {
$this->dispatch(new GenerateNumber());
}
}
您可以在此处阅读有关 Redis 服务器的 FLUSHDB 的更多信息删除当前所选数据库的所有密钥。此命令永不失败
我希望这对你有用。确保您的操作系统用户必须具有通过脚本执行 shell 命令的权限。