Thinkphp_queue_Elin

部分边角功能尚未开发完成, 请自行选择是否在生产环境使用

描述

---

本项目是基于redis自带的队列结构而进行封装，暂时封装了listen模式，以及快捷创建队列业务文件功能，

queue:listen 命令

listen 命令：该命令将会创建一个listen父进程,然后父进程通过 php artisan /Home/queue make:queue name 的方式来创建一个子进程来处理消息队列，且限制该进程的执行时间。 php artisan /Home/queue listen:name

项目代码

例子:

addJoe::Joe(new SendMail($data['user_id'],$data['email'],$data['content']))->push();

执行监听:

php artisan /Home/queue listen:email;

延迟执行:

addJoe::Joe(new SendMail($data['user_id'],$data['email'],$data['content']))->delay(3)->push();

指定队列执行:

addJoe::Joe(new SendMail($data['user_id'],$data['email'],$data['content']))->delay(3)->onQueue('email')->push();

队列业务流程

本队列默认设置

• redis密码为:password
• 端口为:6379
• 地址为:127.0.0.1

如果修改可通过 php artisan /Home/queue make:queue name 创建的队列业务文件头部加入属性

public $host = '127.0.0.1';
public $port = '6379';
public $password = 'password';

后期待完善功能

后期再说