PHP异步任务队列管理器asyntask介绍
PHP异步任务队列管理器asyntask
asyntask是一个轻量级异步任务队列管理器,支持实时,定时,长时和周期任务。
项目由来
本项目最初用于通知推送。例如用户发布评论,需要推送一条push给原作者。而到苹果的服务器的请求时间较长,如果等待苹果服务器的返回结果,则整个发布评论的接口的响应时间就太长了。因为推送push早1秒晚1秒对用户基本没影响,所以当用户发布评论时,只要数据到数据库,即可返回。与此同时创建一条异步任务,在1秒内给用户推送push。这样既保证了接口的响应速度,又不影响用户体验。该项目已经在线上环境运行1年多,执行了累计8千万条命令,运行稳定。
优点
- 异步执行
- 集成管理后台,可视化操作
- 代码集成,可编程
缺点
并非真正实时,秒级误差。
安装
下载源码
直接使用:
1 | git clone https://github.com/spetacular/asyntask.git |
命令下载到本地。
也可以点击 https://github.com/spetacular/asyntask/archive/master.zip 下载最新内容的压缩包,然后解压。
通过 composer 来安装
在你的 composer 项目中的 composer.json 文件中,添加这部分:
1 | { |
然后执行composer install
。调用示例如下:
1 | include './vendor/autoload.php'; |
配置
1.asyntask的数据默认存储在Mysql数据库里,因此需要更改config.php里的配置:
1 | 'DB_HOST'=>'127.0.0.1', |
2.导入数据表
将resource文件夹里的db.sql导入数据库中。
3.配置健康检查脚本
run.sh定期检查异步任务的运行状况,如果挂了,cron_asyn_task.php脚本。
1 | chmod +x run.sh |
然后配置CronTab。运行crontab -e
,然后添加一行:
1 | * * * * * path-to/run.sh > /dev/null 2>&1 |
使用方式
管理后台
自带管理后台,可以轻松添加、编辑、删除、搜索任务。代码在https://github.com/spetacular/asynadmin,请自行部署。
编程方式
可以集成到项目中,完整使用示例见test.php
。
例如添加周期任务:
1 | $name = '周期任务'; |
周期任务示例
每天执行:day 1 hour 0 minute 0 每天零点执行
每小时执行:day 0 hour 1 minute 5 每小时的5分执行
每隔若干分钟执行:day 0 hour 0 minute 5 每隔5分钟执行
PHP异步任务队列管理器asyntask介绍