Question

ActiveMQ 一次取多条消息 consumer.prefetchSize设置没用,每次还是取到一条消息.

Answer 1

你可试试在创建队列时指定预取条数：如下
.......
//consumer.prefetchSize=10 设置消息预取条数为10
destination = session.createQueue(subject+"?consumer.prefetchSize=10");
consumer = session.createConsumer(destination);

追问

就是这样设置的，但是不起作用还是取一条
ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("failover://tcp://localhost:61616");
..
Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("activemq?consumer.prefetchSize=100");
MessageConsumer cs = session.createConsumer(destination);

追答

哦。可能是我对你问题理解的偏差。如果是我理解的情况，应该是可以的。你可以打开activeMq web控制台通过停止再启动消费者程序的办法来观看设置是否有效。http://localhost:8161/admin
我说的consumer.prefetchSize=10是ActiveMQ通过prefetch机制来提高性能，这意味这客户端的内存里可能会缓存一定数量的消息。缓存消息的数量由prefetch 来控制。当某个consumer的prefetch buffer已经达到上限，那么broker不会再向consumer分发消息，直到consumer向broker发送消息的确认。此时如果还有消息，在下发prefetch条数的消息。 consumer.prefetchSize的默认值是1000.
你说的可能是同一时刻取出多条消息吧？

追问

是的，是在同一时刻取出多条消息，如果consumer 有的时间处理不过来，broker 会积压一些message,当下一次receive 的时候，如果能够把broker中积压的message 一次性取出，这样效率会高很多，不用交互多次，减少网络成本.