Tibjms javax.jms.JMSException: 服务器未知的连接

Tibjms javax.jms.JMSException: Connection unknown by server

我正在使用 Tibjms jar 进行 JMS 连接,它在正常情况下工作正常,但如果与 jms 提供程序的连接丢失然后又恢复,我会遇到问题。为了重现该问题,我执行了以下步骤 -

  1. 连接到内网并启动服务器。工作正常。

  2. 断开与 Intranet 的连接。它开始尝试重新连接服务器。很好

  3. 再次连接到 Intranet。它会抛出未知异常并且永远不会再次连接。问题.

所以,我的问题是 "javax.jms.JMSException: Connection unknown by server",它告诉我的不多,您可以在日志末尾看到它。

你可以从下面的日志中看到 -

2017-10-13 15:40:52,333 [     http-nio-8080-exec-2] INFO  org.springframework.web.servlet.DispatcherServlet - FrameworkServlet 'dispatcherServlet': initialization completed in 37 ms
2017-10-13 15:41:29,293 [k Reader (Server-3285015)] ERROR com.example.jms.PaxJmsClient - Exception received from jms
javax.jms.JMSException: Disconnected from ssl://10.10.10.10:5071, will attempt to reconnect
    at com.tibco.tibjms.TibjmsConnection._invokeOnExceptionCallback(TibjmsConnection.java:2132)
    at com.tibco.tibjms.TibjmsConnection._reconnect(TibjmsConnection.java:1912)
    at com.tibco.tibjms.TibjmsConnection$ServerLinkEventHandler.onEventReconnect(TibjmsConnection.java:387)
    at com.tibco.tibjms.TibjmsxLinkTcp._doReconnect(TibjmsxLinkTcp.java:598)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.work(TibjmsxLinkTcp.java:317)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.run(TibjmsxLinkTcp.java:259)
2017-10-13 15:42:29,334 [k Reader (Server-3285015)] ERROR com.example.jms.PaxJmsClient - Exception received from jms
javax.jms.JMSException: Reconnecting to ssl://11.11.11.11:5071, attempt 1 out of 100
    at com.tibco.tibjms.TibjmsConnection._invokeOnExceptionCallback(TibjmsConnection.java:2132)
    at com.tibco.tibjms.TibjmsConnection._reconnect(TibjmsConnection.java:1975)
    at com.tibco.tibjms.TibjmsConnection$ServerLinkEventHandler.onEventReconnect(TibjmsConnection.java:387)
    at com.tibco.tibjms.TibjmsxLinkTcp._doReconnect(TibjmsxLinkTcp.java:598)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.work(TibjmsxLinkTcp.java:317)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.run(TibjmsxLinkTcp.java:259)
2017-10-13 15:42:32,335 [k Reader (Server-3285015)] ERROR com.example.jms.PaxJmsClient - Exception received from jms
javax.jms.JMSException: Reconnecting to ssl://10.10.10.10:5071, attempt 1 out of 100
    at com.tibco.tibjms.TibjmsConnection._invokeOnExceptionCallback(TibjmsConnection.java:2132)
    at com.tibco.tibjms.TibjmsConnection._reconnect(TibjmsConnection.java:1975)
    at com.tibco.tibjms.TibjmsConnection$ServerLinkEventHandler.onEventReconnect(TibjmsConnection.java:387)
    at com.tibco.tibjms.TibjmsxLinkTcp._doReconnect(TibjmsxLinkTcp.java:598)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.work(TibjmsxLinkTcp.java:317)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.run(TibjmsxLinkTcp.java:259)
2017-10-13 15:43:35,358 [k Reader (Server-3285015)] ERROR com.example.jms.PaxJmsClient - Exception received from jms
javax.jms.JMSException: Reconnecting to ssl://11.11.11.11:5071, attempt 2 out of 100
    at com.tibco.tibjms.TibjmsConnection._invokeOnExceptionCallback(TibjmsConnection.java:2132)
    at com.tibco.tibjms.TibjmsConnection._reconnect(TibjmsConnection.java:1975)
    at com.tibco.tibjms.TibjmsConnection$ServerLinkEventHandler.onEventReconnect(TibjmsConnection.java:387)
    at com.tibco.tibjms.TibjmsxLinkTcp._doReconnect(TibjmsxLinkTcp.java:598)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.work(TibjmsxLinkTcp.java:317)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.run(TibjmsxLinkTcp.java:259)
2017-10-13 15:43:38,359 [k Reader (Server-3285015)] ERROR com.example.jms.PaxJmsClient - Exception received from jms
javax.jms.JMSException: Reconnecting to ssl://10.10.10.10:5071, attempt 2 out of 100
    at com.tibco.tibjms.TibjmsConnection._invokeOnExceptionCallback(TibjmsConnection.java:2132)
    at com.tibco.tibjms.TibjmsConnection._reconnect(TibjmsConnection.java:1975)
    at com.tibco.tibjms.TibjmsConnection$ServerLinkEventHandler.onEventReconnect(TibjmsConnection.java:387)
    at com.tibco.tibjms.TibjmsxLinkTcp._doReconnect(TibjmsxLinkTcp.java:598)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.work(TibjmsxLinkTcp.java:317)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.run(TibjmsxLinkTcp.java:259)
2017-10-13 15:44:41,368 [k Reader (Server-3285015)] ERROR com.example.jms.PaxJmsClient - Exception received from jms
javax.jms.JMSException: Reconnecting to ssl://11.11.11.11:5071, attempt 3 out of 100
    at com.tibco.tibjms.TibjmsConnection._invokeOnExceptionCallback(TibjmsConnection.java:2132)
    at com.tibco.tibjms.TibjmsConnection._reconnect(TibjmsConnection.java:1975)
    at com.tibco.tibjms.TibjmsConnection$ServerLinkEventHandler.onEventReconnect(TibjmsConnection.java:387)
    at com.tibco.tibjms.TibjmsxLinkTcp._doReconnect(TibjmsxLinkTcp.java:598)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.work(TibjmsxLinkTcp.java:317)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.run(TibjmsxLinkTcp.java:259)
2017-10-13 15:44:45,951 [k Reader (Server-3285015)] ERROR com.example.jms.PaxJmsClient - Exception received from jms
javax.jms.JMSException: Reconnecting to ssl://10.10.10.10:5071, attempt 3 out of 100
    at com.tibco.tibjms.TibjmsConnection._invokeOnExceptionCallback(TibjmsConnection.java:2132)
    at com.tibco.tibjms.TibjmsConnection._reconnect(TibjmsConnection.java:1975)
    at com.tibco.tibjms.TibjmsConnection$ServerLinkEventHandler.onEventReconnect(TibjmsConnection.java:387)
    at com.tibco.tibjms.TibjmsxLinkTcp._doReconnect(TibjmsxLinkTcp.java:598)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.work(TibjmsxLinkTcp.java:317)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.run(TibjmsxLinkTcp.java:259)
2017-10-13 15:44:50,525 [k Reader (Server-3285015)] ERROR com.example.jms.PaxJmsClient - Exception received from jms
javax.jms.JMSException: Connection unknown by server
    at com.tibco.tibjms.Tibjmsx.buildException(Tibjmsx.java:659)
    at com.tibco.tibjms.TibjmsConnection._invokeOnExceptionCallback(TibjmsConnection.java:2114)
    at com.tibco.tibjms.TibjmsConnection._onDisconnected(TibjmsConnection.java:2487)
    at com.tibco.tibjms.TibjmsConnection$ServerLinkEventHandler.onEventDisconnected(TibjmsConnection.java:367)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.work(TibjmsxLinkTcp.java:328)
    at com.tibco.tibjms.TibjmsxLinkTcp$LinkReader.run(TibjmsxLinkTcp.java:259)

我的代码 -

    @PostConstruct
    public void configurePaxJmsClient() {

        try {
            // create Topic Connection Factory
            TibjmsTopicConnectionFactory cf = new TibjmsTopicConnectionFactory(serverUrl);
            cf.setSSLTrustedCertificate(sslCertificatePath);
            cf.setSSLEnableVerifyHostName(false);
            cf.setUserName(username);
            cf.setUserPassword(password);

            cf.setReconnAttemptCount(100);
            cf.setReconnAttemptDelay(60000);
            cf.setReconnAttemptTimeout(10000);

            cf.setConnAttemptCount(100);
            cf.setConnAttemptDelay(60000);
            cf.setConnAttemptTimeout(10000);

            Tibjms.setExceptionOnFTEvents(true);
            Tibjms.setExceptionOnFTSwitch(true);

            // creation the connection and install an exception handler
            connection = cf.createTopicConnection(username, password);
            connection.setExceptionListener(this);

            // You might also use CLIENT_ACKNOWLEDGE here
            session = connection.createTopicSession(false, javax.jms.Session.AUTO_ACKNOWLEDGE);
            Topic topic = session.createTopic(topicName);

            // Create the subscriber and install the listener
            TopicSubscriber ts;
            /*if (dsName == null || dsName.length() == 0) {
                ts = session.createSubscriber(topic);
            } else {
                ts = session.createDurableSubscriber(topic, dsName);
            }*/

            if (dsName == null || dsName.length() == 0) {
                ts = session.createSubscriber(topic, messageSelector, false);
            } else {
                ts = session.createDurableSubscriber(topic, dsName, messageSelector, false);
            }

            //
            ts.setMessageListener(this);
            connection.start();

        } catch (JMSException e) {
            LOGGER.error("Failed to connect with message:" + e.getMessage(), e);
            releaseResources();
        }
    }

    @Override
    public void onException(JMSException e) {
        LOGGER.error("Exception received from jms", e);
    }

你们能告诉我这里的问题是什么或者指出正确的方向吗?

此外,在 spring bean 的 @PostConstruct 中初始化 jms 连接是否合适?

为什么EMS报“reconnect failed: connection unknown for id=xxxxx”? 此消息表示当客户端尝试重新连接时,EMS 服务器没有或不再有客户端连接信息。

可能有两个原因:

  1. 参数“ft_reconnect_timeout”不够高。在客户端重新连接服务器之前,连接已被服务器清除。 这可以通过为 tibemsd.conf 中的“ft_reconnect_timeout”参数设置更高的值来解决。默认值为 60 秒。

  2. 参数“ft_reconnect_timeout”是备份服务器等待客户端重新连接的时间(以秒为单位) (在故障转移情况下承担主服务器的角色之后),此参数以秒为单位指定服务器将保持挂起连接的时间。 如果客户端没有在此时间段内重新连接,则服务器会从共享状态文件中删除其状态。 如果客户端在“ft_reconnect_timeout”中设置的时间后尝试重新连接,则服务器没有客户端连接信息并打印"reconnect failed: connection unknown"消息。

所以会建议您根据自己的环境设置值并测试same.Also 如果 Ft_reconnect_timeout 值很高,很多连接和连接相关的对象长期保存在内存中,你可能有内存问题。如果连接使用的是 clientID,您可能会 运行 进入“clientID 已经存在”的问题。