如何解决基于 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
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。