单个服务拉取大量队列消息有什么好的方法么

資深大佬 : NoKey 7

我这里只运行了一个服务，订阅了一个消息队列

生产者会不断的往队列里写入消息

我这里读取到消息后，还有一个处理消息的过程

如果是单线程的话，那么效率很低，如果前一条消息处理堵塞了，那么整个都会堵塞

我能想到的就是创建一个线程池,每个消息都用一个线程单独处理

这方面有没有比较好的处理方式，或者处理框架呢？

请大佬指点一下，谢谢

大佬有話說 (8)

資深大佬 : dangge

先看是什么消息队列
然后找对应的封装好的框架
—————-
如果前一条消息处理堵塞了，那么整个都会堵塞
起异步线程处理啊。

資深大佬 : ferock

master 加 worker 模式啊

資深大佬 : Jooooooooo

消费线程也多来几个, 异步处理也是个办法

資深大佬 : ferock

标准队列模式应该是同一个 group 消费是原子的，消费过程中不要继续监听，让其他 worker 监听不就好了

主資深大佬 : NoKey

@dangge rabbitMq 的话，有什么好的框架呢？谢谢

主資深大佬 : NoKey

@ferock 我看了一下 master worker 模式，跟用线程池异步处理差不多的吧

資深大佬 : ferock

@NoKey #5

你开心就好

資深大佬 : long2ice

最好的方式就是尽量压榨所有的 CPU，看语言使用多进程，多线程，协程。