所需php扩展
https://github.com/alanxz/rabbitmq-c
amqp 需要先安装rabbitmq-c
swoole
redis
源码难度:
易于理解,便于修改
主要使用知识点:
swoole\process
swoole定时器
信号通信
等
使用难度:
简单， 易于嵌入框架
发现问题:
查看github仓库， 该代码已经半年没有更新，新的swoole版本中，process是无法在swoole\timer中使用，因为swoole\timer中会自动创建coroutine，而process无法在协程中创建
解决方法:
- 在入口文件增加 (已测试)
\swoole_async_set([
'enable_coroutine' => false
]); 修改process为协程 （未测试）
稳定性:
源码中有一段注释:
//黑科技：实践中发现有可能进不到业务代码，造成消息丢失,job执行太快或者太慢(业务出现异常)，worker进程都安全退出
自己测试中， 开启了3个redis队列
https://www.showdoc.cc/server/api/common/visitfile/sign/02b5ec4fb89ffe035a618821cec0df6a?showdoc=.jpg
测试结果: 推送3000条数据
最小进程数符合预期
最大进程数符合预期
结果无丢失
执行效率
受限于redis队列以及job任务
网友评论