java多线程jms队列接收器

问题描述

我使用的是oracle Advanced Queuing（AQ JMS）。我正在尝试使用多个线程来使用QueueReceiver来使用jms队列。

I am using oracle Advanced Queuing (AQ JMS). I am trying to use multiple threads to consume jms queue using QueueReceiver.

问题：此模型分叉多个线程，但性能仍然接近单线程模型。如何增加队列消耗？

Question: This model forks multiple threads, but performance is still close to single threaded model. How to increase queue consumption?

以下是代码snipet：

Following is code snipet:

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));
        }

消息工作者代码如下所示：

And message worker code looks like following:

    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.");
        }
    }

推荐答案

那里应该是每个线程的单独JMS会话。在您的代码段中似​​乎没有为每个线程创建会话。

There should be a separate JMS Session for each Thread. It doesn't seem like there is a session created for each Thread in your code snippet.

这篇关于java多线程jms队列接收器的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！