基于 CachingConnectionFactory 的发布有时会因错误而失败，因为连接已被服务器终止

问题描述

有时在将消息发布到队列时会遇到以下异常。我在 Spring Boot 中使用 JMS 模板和 CachingConnectionFactory。在 CachingConnectionFactory 的文档中，我可以看到需要关闭会话。但是当我使用 JMS 模板时，不明白如何关闭会话。是不是这个问题。错误并不总是发生，失败的行为是随机的。请帮忙提出您的建议

Caused by: javax.jms.JMSException: Connection has been terminated by the server
    at com.tibco.tibjms.Tibjmsx.buildException(Tibjmsx.java:676)
    at com.tibco.tibjms.TibjmsxSessionImp._confirmTransacted(TibjmsxSessionImp.java:3576)
    at com.tibco.tibjms.TibjmsxSessionImp._confirm(TibjmsxSessionImp.java:3982)
    at com.tibco.tibjms.TibjmsxSessionImp._commit(TibjmsxSessionImp.java:3211)
    at com.tibco.tibjms.TibjmsxSessionImp.commit(TibjmsxSessionImp.java:5374)
    at com.fedex.mi.decorator.jms.FedexJmsSession.commit(FedexJmsSession.java:139)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.springframework.jms.connection.CachingConnectionFactory$CachedSessionInvocationHandler.invoke(CachingConnectionFactory.java:383)
    at com.sun.proxy.$Proxy130.commit(UnkNown Source)
    at org.springframework.jms.support.JmsUtils.commitIfNecessary(JmsUtils.java:218)
    at org.springframework.jms.core.jmstemplate.doSend(jmstemplate.java:612)
    at org.springframework.jms.core.jmstemplate.lambda$send$3(jmstemplate.java:586)
    at org.springframework.jms.core.jmstemplate.execute(jmstemplate.java:504)
    ... 68 more

解决方法

我不认为异常与不关闭连接有关。很可能 TibcoEMS 服务器由于某种原因不可用或连接因某些网络问题而终止。

您需要在 CachingConnectionFactory 定义中定义 reconnectOnException 设置，以便在您还没有设置时自动重新连接。

类似：

<bean id="tibcoConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
    <property name="targetConnectionFactory" ref="tibcoServerJndiObjectFactoryBean"/>
    <property name="reconnectOnException" value="true"/>
    <property name="sessionCacheSize" value="100"/>
    <property name="cacheConsumers" value="false"/>
</bean>

您可能还需要在 TibcoEMS 端定义 QueueConnectionFactory 容错故障转移设置

https://docs.tibco.com/pub/ems/8.5.1/doc/html/GUID-270D7C10-7686-44B0-BC11-D7BFF1F33A7E.html