如果我调用以下内容:
return AdventureJob::dispatch($event->character->refresh(), $event->adventure, $event->levelsAtATime)->delay($timeTillFinished);
这将创建一个延迟 x 分钟的作业.我的作业都是通过redis处理的,有没有办法获取这个特定的作业或者从队列中删除这个特定的作业?
This will then create a job thats delayed x minutes. my jobs are all processed through redis, is there a way to then get this specific job or delete this specific job from the queue?
人们谈论 php artisan 命令然后删除所有作业,这不是我想要的我想获取有关此作业的某种信息(作业 ID?或队列 ID?Redis ID?)然后存储在数据库中如果玩家然后取消冒险,我可以使用它在队列中找到这个作业并删除它,假设它没有运行.
People talk about php artisan commands to then delete all jobs, thats not what I want I want to get some kind of information (Job ID? or queue ID? Redis ID?) about this job to then store in the database so that if the player then cancels the adventure, I can use that to find this job on the queue and delete it, assuming it's not running.
没有直接或简单的方法来做到这一点.延迟的作业保存在 sorted set
中作为待处理时间作为 score
和作业负载作为 value
.
There is no direct or easy way to do it. The delayed jobs are kept in sorted sets
as to-be-processed time as score
and job payload as the value
.
有几种方法可以从已排序的集合中移除元素(其中大多数需要一些努力,具体取决于延迟队列的大小),例如
There are several ways to remove an element from the sorted sets(most of them require some efforts depending on the size of the delayed queue) such as
WITHSCORES
获取它的列表.它将为您提供带有分数的工作列表.您可以使用分数来识别被延迟的工作.获取值(序列化的有效负载)然后使用 ZREM
.ZREMRANGEBYSCORE
需要时间间隔.handle
方法的开头放置一个取消条件.这个需要应用层开发.每当您将作业推送到队列时,您都会向作业发送一个标识符,在 Redis 中也放置相同的标识符(您可以理解)(EXPIRE
大于延迟时间).当你想取消它时,然后从Redis中删除它.在 handle 方法内部检查给定的标识符是否存在于 Redis 中,如果不存在则从代码块提前返回.WITHSCORES
. It will give you the list of jobs with their scores. You can use score to identify to be delayed job. Get the value(serialized payload) then use ZREM
.ZREMRANGEBYSCORE
takes time interval.handle
method. This one requires application layer development. Whenever you push a job to the queue you send an identifier to the job, put same identifier(that you can understand) in Redis too(with EXPIRE
greater than the delayed time). When you want to cancel it, then delete it from the Redis. Inside the handle method check whether the given identifier exists in Redis, if not early return from the code block.这篇关于在 Laravel 中取消作业的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持跟版网!