PHP用redis实现多进程队列

简单的流程以下: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

相关文章
相关标签/搜索