如何使用jms.Connection.setExceptionListner释放资源并重新连接？

Question

假设我每个 JVM 有一个 Connection （作为单例实现），作为文档的派生，该文档建议使用一个 Connection 因为它是一个重对象。

来自文档：

...连接是一个相对的 重量级的物体。大多数客户都会 完成所有的消息传递 连接... JMS 客户端 通常会创建一个连接，一个或 更多会话和大量消息 生产者和消费者。

我正在尝试决定如何处理我的 Sessions、Producers 和 Consumers 相对于 ExceptionListener位于连接级别。
据我所知，当抛出 JMSException 时，它们不再可用是非常合理的，但我不确定触发上述侦听器后应该做什么。
我的 Session 保存在 ThreadLocal 中，它也保存在单例中。
我可以使用它在侦听器中调用 MySessionSingleton.closeSession() ，但这只会关闭绑定到抛出异常的线程的 Session ，而不是所有其他会话。
此外，这不考虑生产者\消费者及其重新连接。
我看到使用但我不愿意模仿的一个可能的解决方案是为每个生产者\消费者建立一个连接和一个会话，这样我就可以控制上述所有内容。

如有任何想法，将不胜感激，
伊泰
澄清：
我当前的实现是由一位前程序员实现的，这就是我上面提到的正在使用的实现，它给我带来的最大问题是我需要多个生产者和消费者来使用与我相同的 Session需要 JTA 事务，并且我认为（可能是错误的）我需要那些生产者\消费者来共享会话。
这种联系是该决定的衍生。
因此，基本上即使我保持每个连接一个会话的关系，当一个会话有多个生产者\消费者时，我仍然会遇到上述问题。

Answer 1

也许这是一个天真的问题，因为我对 JMS 没有太多的实际经验，但这不是调用 connection.close() 的最简单方法吗？

JMS API 表示“无需关闭已关闭连接的会话、生产者和消费者”。

另外，可以将全局标志设置为消息处理程序循环等的信号。

Answer 2

我仍然不明白为什么你只需要一个 Connection 对象:-)。我会让应用程序服务器（我假设您正在其中运行）负责为您管理连接资源。

即使用 ConnectionFactory 来获取连接并创建会话以及消费者和生产者。

大致是这样的：

public void notify(String errorOccurrence)
{
    Connection connection = null;

    try
    {
        connection = connectionFactory.createConnection();

        Session session = connection.createSession(true, 
                          javax.jms.Session.AUTO_ACKNOWLEDGE);

        TextMessage message = session.createTextMessage(errorOccurrence);

        MessageProducer messageProducer = 
                            session.createProducer(errorOccurrenceChannel);

        messageProducer.send(message);
    }
    catch (JMSException e)
    {
        handleJmsExcption(e);
    }
    finally
    {
        if (connection != null)
        {
            try
            {
                connection.close();
            }
            catch (JMSException e)
            {
                handleJmsExcption(e);
            }
        }
    }
}