即使wireFormat.maxInactivityDuration=0，ActiveMQ连接也会超时

Question

我正在收听一个Activemq队列。

我的配置如下:

ACTIVEMQ_BROKER_URL =failover:(tcp://LON6QAEQTAPP01:61616?wireFormat.maxInactivityDuration=0)

从控制台日志中，我可以看到尝试重新连接到该服务器。

[2014-08-20 08:57:43,303]INFO 236[ActiveMQ Task-1]-org.apache.activemq.transport.failover.FailoverTransport.doReconnect（FailoverTransport.java:1030）-成功连接到tcp：//LON6QAEQTAPP01:61616？wireFormat.maxInactivityDuration=0[2014-08-20 08:57:43,355]INFO 288[ActiveMQ Task-1]-org.apache.activemq.transport.failover.FailoverTransport.doReconnect（FailoverTransport.java:1030）-成功连接到tcp：//LON6QAEQTAPP01:61616？wireFormat.maxInactivityDuration=0[2014-08-20 08:57:43,374]INFO 307[ActiveMQ Task-1]-org.apache.activemq.transport.failover.FailoverTransport.doReconnect（FailoverTransport.java:1030）-成功连接到tcp：//LON6QAEQTAPP01:61616？wireFormat.maxInactivityDuration=0

我仍然无法使用该消息。我正在使用以下代码尝试从代码端处理它，但仍然无法使连接持久化。

try
        {
            connection.start();
            while (true)
            {
                try
                {
                    if (connection.isClosed() || connection.isTransportFailed() || session.isClosed() || !connection.getTransport().isConnected())
                    {
                        log.info("Connection was reset, re-connecting..");
                        connection.cleanup();
                        init();
                        connection.start();
                    }
                }
                catch (Throwable t)
                {
                    init();
                    log.error("Connection was reset, re-connecting in exception block", t);
                }
                Thread.sleep(30000L);
            }


private void init() throws Exception
{
    init(brokerURL, queueName, userName, password, manual);
}

public void init(String brokerURL, String queueName, String userName, String password, boolean manual) throws Exception
{
    this.manual = manual;
    this.brokerURL = brokerURL;
    this.queueName = queueName;
    this.userName = userName;
    this.password = password;
    ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(userName, password, brokerURL);
    connection = (ActiveMQConnection) connectionFactory.createConnection();
    connection.addTransportListener(new TransportListener()
    {

        @Override
        public void transportResumed()
        {
            log.info("Transport Resumed ");

        }

        @Override
        public void transportInterupted()
        {
            log.info("Transport Interupted ");

        }

        @Override
        public void onException(IOException arg0)
        {
            arg0.printStackTrace();
            log.error("Transport Exception: " + arg0.getMessage());
        }

        @Override
        public void onCommand(Object arg0)
        {
            // TODO Auto-generated method stub

        }
    });

    connection.setExceptionListener(this);
    connection.setCloseTimeout(10);
    session = (ActiveMQSession) connection.createSession(false, Session.AUTO_ACKNOWLEDGE);// CLIENT_ACKNOWLEDGE
    Destination destination = session.createQueue(queueName);
    MessageConsumer consumer = session.createConsumer(destination);
    consumer.setMessageListener(this);
}

有人可以帮助我，让我如何让这种联系一直活跃起来。它通常在不活动40分钟左右后超时。

Answer 1

试图以你现在的方式强行重新连接一个打开的连接绝对不会对你有好处。如果您想自己处理连接中断，您需要拆除连接并创建一个新的连接。您真正应该做的是找出是什么关闭了您的连接，可能是防火墙关闭了不活动的连接或负载平衡器。看看你的环境，看看还有什么会让你与外界失去联系。

如果配置为这样做，则代理可以重新平衡集群中的客户机。您是否在群集环境中使用多个客户端等？