
1 Aether 2019-11-06 15:49:00 +08:00 你就说一句”业务需求“?你的整个问题最应该详细说明逻辑的,不就是这几个字么…… |
3 locoz 2019-11-06 16:00:55 +08:00 前面业务相关的描述太简单了点... 执行死循环任务是指?消费者消费这个任务的时候会一直处于处理状态而不 ack ?还是说是同一个任务做完一次之后又扔回队列?这两种情况都是:如果生产者一直在发同样的任务,就会导致队列被塞爆。但如果生产者只发一次任务的话,不会怎么样,后者会更好监控状态一些而已。 |
4 littlespider89 2019-11-06 16:02:47 +08:00 上 kafka |
5 GoLand 2019-11-06 16:04:02 +08:00 开个独立进程去拉队列里的消息,拉到消息就直接放进 celery 消费。不用担心进程不稳定,消费速度也没有瓶颈了。celery 不是你这么用的。 |