我使用Oracle高级队列（AQ JMS）。 我想使用多线程来消费使用的QueueReceiver JMS队列。
问 ：这种模式叉多线程，但表现仍接近单线程模型。 如何增加消费的队列？
以下是一小段代码片段：
final QueueReceiver queueReceiver = getQueueReceiver(queueSession);
qConn.start();
//THREAD POOL SIZE
final int threadPoolSize = getThreadCount();
final ExecutorService executor = Executors.newFixedThreadPool(threadPoolSize);
for (int i = 0; i < threadPoolSize; i++) {
executor.submit(new MessageWorker(queueReceiver));
}
和消息工作者的代码看起来像以下：
class MessageWorker extends Thread {
MessageConsumer messageConsumer;
public MessageWorker(MessageConsumer subs) {
this.messageConsumer = subs;
}
/**
* @see java.lang.Thread#run()
*/
@Override
public void run() {
try {
while (true) {
try {
Message msg = messageConsumer.receive();
if (null != msg) {
//log message
logMessage(msg);
//handle message
handleMessage(msg);
//ack
msg.acknowledge();
}
} catch (JMSException e) {
log.error(e);
}
}
} catch (Exception e) {
log.error(e);
} finally {
log.info("Thread:" + this.getName() + " terminated.");
}
}
