thinkphp-queue的执行流程

4、调用$job的fire()方法

2、获取新消息Queue::pop()

font color=\"#323232\

消费者

REDIS

3、返回一个可执行的$job实例

POP

PUSH/POP

delete()release()

生产者

REDIS-job

6、读取消息内容($data)处理业务逻辑删除或重发该消息$job->delete()$job->release()

8、返回消息处理业务

命令行

7、消息删除/重发

PUSH

DB-job

1、推送消息Queue::push()

消息队列(queue)

消息(job)

1、监听队列queue:work

DB

执行work

驱动(connetor)

redis-connetor

2、返回成功失败

db-connetor