简单的流程以下:php
1, 添加队列信息git
2, 队列信息储存在redis里面,我设置的是 10库为队列动做信息,9库为队列详细的信息github
3, 服务端守护进程不断接收队列,再处理队列,目前代码的逻辑是,先循环接收10库的队列动做信息,再分段多进程处理9库的队列详细信息redis
代码调用范例:spa
1, 添加队列(好比添加发送邮件):队列
$q->add_queue('send_mail', $i, ‘hello world');
进程
2, 服务端处理队列逻辑,先读取队列动做信息,再多进程处理,目前的版本是不能同时处理多个队列动做信息,只能多进程处理完一条队列动做信息里面的每条队列信息以后,再处理另一条队列动做信息。(服务端的版本有单进程,多进程两个版本)ci
感谢Signfork.class类的做者,这里用了这个多进程的类get
github地址: https://github.com/r00tjimmy/queue-php-redisit