聊一聊使用多线程处理MQ消息的正确姿势


Q:有这样一个场景,MQ的生产者生产消息能力是消费者的数倍。 如果不能尽快消费完会导致队列中的消息随着时间的推移会越积越多,而且业务也无任何时效性可言, 那么问题来了,在不增加消费节点的前提下如何快速处理完消息以保证吞吐量?

面对以上问题,有人可能会信心满满地脱口而出:用多线程。OK,我只能说思路没错,那么如何落地呢?

Read More>>