This is an old version of this page. You can view the most recent version or browse the history.

php job queue

php多任务并发处理队列

首先在php下编写job，在app-job\bin\目录下实现对应的job类，然后在需要使用的地方将任务依次加入队列。python脚本会依次从队列里面取出任务去执行。

参考Bin_Wiki_UpdateCertWebsiteExpire.注意这里它即实现了生产者也实现了消费者逻辑，start_general_queue函数将需要执行的任务依次加入队列，add_queue则依次消费完成任务。

python队列脚本在

任务加入队列，就是加入redis的一个list队列，此处可以使用GlobalFun::add_python_job($job_class, $args=[], $queue_name='default', $is_urgent=false).

参数	类型	说明
$job_class	string	任务执行类名称，如`Bin_Wiki_UpdateCertWebsiteExpire`
$args	string或array	传入参数，可以是字符串或者一维数组，一维数组
$queue_name	string	队列名称，默认为default，队列前缀为`pingan:python:queue`
$is_urgent	bool	是否紧急，为`true`的时候为从队列头部插入，防止队列过长而延后执行。