ActiveMQ如何限制消息的并发消费数？

ActiveMQ中,我们可以通过配置prefetch(预取数量)来限制队列的并发消费数。

主要的JavaScript和Java代码如下:

JavaScript代码:

var connection = new ActiveMQ.Connection({url: 'tcp://localhost:61616'});

connection.onStop = function(e) { /*...*/ };
connection.start();

var session = connection.createSession();
var destination = session.createQueue('TEST.QUEUE'); 

var consumer = session.createConsumer(destination);
consumer.setPrefetchSize(1); // 设置预取1条消息

connection.start();

consumer.onMessage = function(message) {
   // 消费消息
}

这里使用consumer.setPrefetchSize(1)来限制每次只预取1条消息。这相当于同时只允许1个消费者线程并发消费。

Java代码:

Connection connection = factory.createConnection();
connection.start();

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

Destination destination = session.createQueue("TEST.QUEUE");

MessageConsumer consumer = session.createConsumer(destination);
consumer.setMessageListener(this);

consumer.setMessageListener(message -> {
   // 消费消息
});

consumer.setPrefetchSize(1); // 设置预取1条消息 

connection.close();

这里也使用consumer.setPrefetchSize(1)来限制每次预取1条消息。在消费一条消息后,Broker才会dispatch下一条消息给该消费者。

总的来说,通过设置合理的prefetch值,我们可以限制ActiveMQ队列的并发消费数。