kcloze/swoole-jobs源码分析

php基础

浏览数:638

2019-10-14

AD:资源代下载服务

所需php扩展

https://github.com/alanxz/rab…
amqp 需要先安装rabbitmq-c
swoole
redis

源码难度:

易于理解,便于修改

主要使用知识点:

swooleprocess
swoole定时器
信号通信

使用难度:

简单, 易于嵌入框架

发现问题:

查看github仓库, 该代码已经半年没有更新,新的swoole版本中,process是无法在swooletimer中使用,因为swooletimer中会自动创建coroutine,而process无法在协程中创建

解决方法:

  1. 在入口文件增加 (已测试)

swoole_async_set([

'enable_coroutine' => false

]);

  1. 修改process为协程 (未测试)

稳定性:

源码中有一段注释:
//黑科技:实践中发现有可能进不到业务代码,造成消息丢失,job执行太快或者太慢(业务出现异常),worker进程都安全退出
自己测试中, 开启了3个redis队列
https://www.showdoc.cc/server…

测试结果: 推送3000条数据

最小进程数符合预期
最大进程数符合预期
结果无丢失

执行效率

受限于redis队列以及job任务

作者:柠檬味的炮灰