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

[NoKey]

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

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

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

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

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

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

请大佬指点一下，谢谢

[dangge]

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

[ferock]

master 加 worker 模式啊

[Jooooooooo]

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

[ferock]

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

[NoKey]

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

[NoKey]

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

[ferock]

@NoKey #5

你开心就好

[jenlors]

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