aint-queue
aint-queue copied to clipboard
:rocket: An async-queue library built on top of swoole, flexable multi-consumer, coroutine supported. 基于 Swoole 的一个异步队列库,可弹性伸缩的工作进程池,工作进程协程支持。
如题,这是bug吗?supervisor跑一段时间后会有很多monitor进程
我使用supervisor来保证程序正常执行。 配置里面关键的只有一行 ``` [program:aint-queue] command=sh queue-start.sh ``` 以下是queue-start.sh里面的内容 ``` ./vendor/bin/aint-queue worker:listen --channel=default ``` config就是用的默认配置 目前会出现多个moniter进程的情况,是我的启动脚本有问题吗?
https://github.com/Littlesqx/aint-queue/blob/44cac929ce5e57da9cefcbe843e9ba399d5e950f/src/Console/Command/WorkerReloadCommand.php#L38 https://github.com/Littlesqx/aint-queue/blob/44cac929ce5e57da9cefcbe843e9ba399d5e950f/src/Console/Command/WorkerRunCommand.php#L40 https://github.com/Littlesqx/aint-queue/blob/44cac929ce5e57da9cefcbe843e9ba399d5e950f/src/Console/Command/WorkerRunCommand.php#L51 https://github.com/Littlesqx/aint-queue/blob/44cac929ce5e57da9cefcbe843e9ba399d5e950f/src/Console/Command/WorkerStopCommand.php#L38 这几行需要返回整型才行,不太确定这里返回数字要返回什么数字比较好。有合适的话我可以提pr
随运行时间增长,aint-queue:monitor进程越来越多,占用了大量内存 ``` root 1373 1 0 18:40 ? 00:00:00 aint-queue: monitor#default root 2952 1 0 18:45 ? 00:00:00 aint-queue: monitor#default root 4504 1 0 18:50 ? 00:00:00 aint-queue: monitor#default root...
问题请教
大佬,为什么要用到lua? 为什么有用到hexists、zscore等? `$object->getCompressingThreshold()`这个方法是哪来的? 大佬,这个是咋写出来的?深刻理解swoole? 好多看不懂的,有难度
应该构建镜像的时候进行composer install, 你这边是先install 然后构建镜像,这样就会有一个问题,一般本地环境是没有swoole扩展的,所以第一步就不会成功