ActiveMQ中消费者的onMessage消息处理问题

Question

@夏夜流星 你好，想跟你请教个问题：

对于您当初存在的这个问题，如今我也存在，请问您这个问题该怎么解决？

在ActiveMQ中，我使用onMessage来消费消息，如果此时收到一条消息，开一个线程执行此条消息的业务逻辑，需要耗时5分钟，在此期间，客户端又发来一条消息，但是onMessage方法此时没有进行消费，而是等待第一个消息执行完才接收消费第二个消息，请问大家，如何让这两条消息并行执行而不阻塞onMessage方法呢？

Answer 1

一般情况下都可以考虑使用java.util.concurrent.ThreadPoolExecutor，你想同时有多少消息可以执行就设定多少条线程，只要有足够的线程处理，onMessage方法 都不会阻塞。

不过，如果消息增加的速度大于处理速度，这个就不是单纯增加多少数量的线程可以解决了。