消息监听器中的JMS连接池

Question

目前，我正在开发一个独立的Java应用程序，它连接到Websphere MQ以发送和接收消息。

流处于异步模式，我们使用MessageListener类来实现，以便在消息准备就绪时从队列中检索消息。使用侦听器初始化消费者的代码如下：

if(connection == null)
        connection = getJmsConnection();

    try {
        session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        if (isTopic) {
            destination = session.createTopic(destinationName);
        } else {
            destination = session.createQueue(destinationName);
        }
        consumer = session.createConsumer(destination);
        consumer.setMessageListener(listener);
    } catch (JMSException e) {
        e.printStackTrace();
    }

getJmsConnection（）方法将从池中返回连接，该池使用Apache Commons池库实现。

我的问题是，只要程序在运行，从池中分配给侦听器的连接是否会处于活动状态并绑定到该侦听器？或者该连接是间歇使用的，并且可以被其他进程重用？我们的想法是让发送和接收过程重用池中的连接，但我不确定MessageListener如何处理分配给它们的连接。

谢谢你。

Answer 1

这里的关键对象是会话，而不是连接；会话将在这里使用消息消耗（异步或其他方式）进行主要工作。

建议尽可能广泛地尝试和共享连接。临时目的地在连接级别上有作用域。所以使用池化是一个好主意；共享这种连接是完全可能的。

然而，我还要说，也许值得考虑将会议集中起来。这里的代码将创建一个新的会话，每次通过该代码，这将意味着将创建到WebSphereMQ队列管理器的新连接。目前还不清楚这将是什么范围，但如果迅速关闭，它可能会成为瓶颈。