即使使用 PooledConnectionFactory，JmsTemplate 也不会关闭连接

Question

我们使用 AMQ Broker 5.5 和 Spring 3.0 来配置连接工厂和其他东西。 我们使用的连接工厂是 PooledConnectionFactory，我的配置的一部分如下所示：

  <属性名称=“connectionFactory”>

    <属性名称=“brokerURL”值=“some_url”/>

    

 

    <属性名称=“connectionFactory”>

   

    <属性名称=“explicitQosEnabled”值=“true”/>

    <属性名称=“timeToLive”值=“86400000”/>

几天前，我们的代理崩溃并不断重新启动，并出现以下错误：

java.lang.OutOfMemoryError: requests

369384 bytes for Chunk::new。交换空间不足？

那时，从 jconsole 中，我找不到代理的任何异常情况，除了我们的一个客户端应用程序 它通过每分钟发送和侦听消息来与服务器进行通信（通过代理），创建了约 3000 个连接（在 jconsole 上看到）。 一旦我们关闭它，一切就恢复正常了。

因此，为了避免这种情况，我尝试在finally块中关闭连接，执行类似的操作。

try {

   connection = myJmsTemplate.getConnectionFactory().createConnection();

   session = connection.createSession(false, 1);
   String messageSelector = "JMSCorrelationID='" + correlationId + "'";
   responseConsumer = session.createConsumer(receiveDestination, messageSelector);
   LOG.info("Starting connection");
   connection.start();
   myJmsTemplate.send(sendDestination, new SimpleTextMessageCreator(
   message, receiveDestination, correlationId));
   LOG.info("Waiting for message with " + messageSelector + " for " + DEFAULT_TIMEOUT + " ms");
   TextMessage responseMessage = (TextMessage) responseConsumer.receive(DEFAULT_TIMEOUT);
}

catch (Someexception e) {do something}
finally {
   responseConsumer.close();
   session.close();
   connection.close();
}

但即便如此，我也可以看到连接在 jconsole 中浮动，并且只有在发布消息的客户端应用程序关闭时才会丢失。 有人可以帮助我了解这里发生的情况以及如何在每个 pub sub 周期后关闭连接。

提前谢谢你，

哈里

Answer 1

虚惊。还有另一段代码使连接保持打开状态。关闭它解决了这个问题。