java - JmsTemplate 无法发送响应，因为 javax.jms.IllegalStateException : Session is closed

Question

我有一个使用 Spring 连接到 TIBCO(队列)的独立应用程序。有时，由于各种原因，TIBCO 连接会被服务器关闭。大多数事情都正在从中恢复。但是，有时 JmsTemplate 由于以下错误而无法发送响应。我进行了重试，但同样的错误不断出现(请参阅下面的跟踪)。

可能重要的细节:

我正在使用 DefaultMessageListenerContainer 来获取请求并在该接收线程中发送响应。另外，我对 DefaultMessageListenerContainer 和 JmsTemplate 使用相同的连接工厂。

Caused by: org.springframework.jms.IllegalStateException: Session is closed; nested exception is javax.jms.IllegalStateException: Session is closed
        at org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:279)
        at org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:169)
        at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:487)
        at org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:559)
        at org.springframework.jms.core.JmsTemplate.convertAndSend(JmsTemplate.java:682)
        at org.springframework.jms.core.JmsTemplate.convertAndSend(JmsTemplate.java:670)
        at org.springframework.integration.jms.JmsSendingMessageHandler.send(JmsSendingMessageHandler.java:149)
        at org.springframework.integration.jms.JmsSendingMessageHandler.handleMessageInternal(JmsSendingMessageHandler.java:116)
        at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:127)
        ... 83 more
Caused by: javax.jms.IllegalStateException: Session is closed
        at com.tibco.tibjms.TibjmsxSessionImp._createProducer(TibjmsxSessionImp.java:1067)
        at com.tibco.tibjms.TibjmsxSessionImp.createProducer(TibjmsxSessionImp.java:5080)
        at org.springframework.jms.core.JmsTemplate.doCreateProducer(JmsTemplate.java:1114)
        at org.springframework.jms.core.JmsTemplate.createProducer(JmsTemplate.java:1095)
        at org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:591)
        at org.springframework.jms.core.JmsTemplate$3.doInJms(JmsTemplate.java:562)
        at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:484)
        ... 89 more

与 TIBCO 队列的通信是使用 Spring 框架完成的。这是配置。 DefaultMessageListenerContainer 接收消息并进行处理，然后使用 JmsTemplate 发回响应。连接工厂在接收方和发送方之间共享(这会是一个问题吗？)。

    <bean id="connectionFactory"
            class="org.springframework.jms.connection.SingleConnectionFactory">
            <constructor-arg ref="tibcoJNDI" />
            <property name="targetConnectionFactory">
                    <bean class="org.springframework.jndi.JndiObjectFactoryBean">
                            <property name="jndiTemplate" ref="tibcoJNDI"/>
                            <property name="jndiName" value="${tibco.queueConnectionFactory}" />
                    </bean>
            </property>
            <property name="reconnectOnException" value="true"/>

    </bean>

<bean id="client.req.msg.lstnr" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="autoStartup" value="false"/>
    <property name="connectionFactory" ref="connectionFactory"/>
    <property name="destination" ref="ext_client.request.queue"/>
    <property name="sessionAcknowledgeMode" value="3"/>
    <property name="concurrentConsumers" value="6"/>
    <property name="receiveTimeout" value="60000"/>
</bean>

<jms:outbound-channel-adapter
    jms-template="ext.outbound.jms.template"
    channel="jms.to.ext.clnt.reply"/>

<bean id="ext.outbound.jms.template" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="connectionFactory"/>
    <property name="defaultDestination" ref="ext_client.reply.queue"/>
    <property name="timeToLive" value="10800000" />
    <property name="explicitQosEnabled" value="true" />
</bean>

还有一个可能有帮助的细节。我刚刚注意到第一个异常(exception)实际上是不同的。首先出现“连接已关闭”异常，然后是多个“ session 已关闭”异常(重试时)。

Caused by: javax.jms.JMSException: Connection is closed
    at com.tibco.tibjms.TibjmsxLink.sendRequest(TibjmsxLink.java:322)
    at com.tibco.tibjms.TibjmsxLink.sendRequest(TibjmsxLink.java:286)
    at com.tibco.tibjms.TibjmsxLink.sendRequestMsg(TibjmsxLink.java:261)
    at com.tibco.tibjms.TibjmsxSessionImp._createProducer(TibjmsxSessionImp.java:1075)
    at com.tibco.tibjms.TibjmsxSessionImp.createProducer(TibjmsxSessionImp.java:5080)
    at org.springframework.jms.core.JmsTemplate.doCreateProducer(JmsTemplate.java:1114)
    at org.springframework.jms.core.JmsTemplate.createProducer(JmsTemplate.java:1095)
    at org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:591)
    at org.springframework.jms.core.JmsTemplate$3.doInJms(JmsTemplate.java:562)
    at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:484)
    ... 89 more

Answer 1

Spring 似乎没有正确处理这种情况。我通过重写 JmsTemplate (下面的代码)并自己处理异常(清理 session 和连接)解决了这个问题。我希望这会有所帮助。

public <T> T execute(SessionCallback<T> action, boolean startConnection) throws JmsException {
    try {
        return super.execute(action, startConnection);
    } catch (JmsException jmse) {
        logger.error("Exception while executing in JmsTemplate (will cleanup session & connection): ", jmse);
        Object resourceHolder =
                TransactionSynchronizationManager.getResource(getConnectionFactory());
        if (resourceHolder != null && resourceHolder instanceof JmsResourceHolder) {
            ((JmsResourceHolder)resourceHolder).closeAll();
        }

        throw jmse;
    }
}