php多任务并发处理队列
PHP并发队列原理
首先在php下编写job,在app-job\bin\
目录下实现对应的job类,然后在需要使用的地方将任务依次加入队列。python脚本会依次从队列里面取出任务去执行。
Job类
参考Bin_Wiki_UpdateCertWebsiteExpire
.注意这里它即实现了生产者也实现了消费者逻辑,start_general_queue
函数将需要执行的任务依次加入队列,add_queue
则依次消费完成任务。
任务加入队列
任务加入队列,就是加入redis的一个list队列,此处可以使用GlobalFun::add_python_job($job_class, $args=[], $queue_name='default', $is_urgent=false)
.
参数 | 类型 | 说明
--- | --- | ---
$job_class | string | 任务执行类名称,如Bin_Wiki_UpdateCertWebsiteExpire