我这里只运行了一个服务，订阅了一个消息队列
生产者会不断的往队列里写入消息
我这里读取到消息后，还有一个处理消息的过程
如果是单线程的话，那么效率很低，如果前一条消息处理堵塞了，那么整个都会堵塞
我能想到的就是创建一个线程池,每个消息都用一个线程单独处理
这方面有没有比较好的处理方式，或者处理框架呢？
请大佬指点一下，谢谢
• 请不要在回答技术问题时复制粘贴 AI 生成的内容
This topic created in 2070 days ago, the information mentioned may be changed or developed.
 |
1
dangge Feb 16, 2021
先看是什么消息队列
然后找对应的封装好的框架 ---------------- 如果前一条消息处理堵塞了，那么整个都会堵塞 起异步线程处理啊。 |
 |
2
ferock Feb 16, 2021 via iPhone
master 加 worker 模式啊
|
 |
3
Jooooooooo Feb 16, 2021
消费线程也多来几个, 异步处理也是个办法
|
|
4
ferock Feb 16, 2021 via iPhone
标准队列模式应该是同一个 group 消费是原子的，消费过程中不要继续监听，让其他 worker 监听不就好了
|
 |
8
jenlors Feb 18, 2021
最好的方式就是尽量压榨所有的 CPU，看语言使用多进程，多线程，协程。
|
Select Language