1

Oracle Advanced Queuing (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.");
        }
    }
4

1 に答える 1

0

スレッドごとに個別の JMS セッションが必要です。コード スニペットのスレッドごとにセッションが作成されているようには見えません。

于 2013-01-30T20:39:56.297 に答える