作者:mobiledu2502860983 | 来源:互联网 | 2023-08-15 19:13
我这里只运行了一个服务,订阅了一个消息队列
生产者会不断的往队列里写入消息
我这里读取到消息后,还有一个处理消息的过程
如果是单线程的话,那么效率很低,如果前一条消息处理堵塞了,那么整个都会堵塞
我能想到的就是创建一个线程池,每个消息都用一个线程单独处理
这方面有没有比较好的处理方式,或者处理框架呢?
请大佬指点一下,谢谢
先看是什么消息队列
然后找对应的封装好的框架
----------------
如果前一条消息处理堵塞了,那么整个都会堵塞
起异步线程处理啊。