ActiveMq NMS 大约 30 秒后断开连接

Question

我正在尝试使用 ActiveMq 进行简单的发布/订阅。我可以让一切正常工作，但订阅者在大约 30 秒后断开连接。我一直在寻找可以更改的超时类型的值，但似乎没有任何效果。这是订阅者：

using System;
using Apache.NMS;
using Apache.NMS.ActiveMQ;
using Apache.NMS.ActiveMQ.Commands;

namespace ActiveMQCatcher
{
    internal class Program
    {
        private static void Main(string[] args)
        {
            IConnectionFactory factory = new ConnectionFactory("tcp://localhost:61616/");

            using (IConnection connection = factory.CreateConnection())
            {
                connection.ClientId = "MYID";
                connection.Start();

                using (ISession session = connection.CreateSession())
                {
                    IMessageConsumer consumer = session.CreateConsumer(new ActiveMQTopic("MYTOPIC"), null, false);
                    consumer.Listener += consumer_Listener;

                    Console.ReadLine();
                }

                connection.Stop();
            }
        }

        private static void consumer_Listener(IMessage message)
        {
            Console.WriteLine("Got: " + ((ITextMessage) message).Text);
        }
    }
}

我尝试了这个：

connection.RequestTimeout = TimeSpan.MaxValue;

但它似乎没有改变任何东西。

要解决该问题，只需运行该程序并等待大约 30 秒。您可以在 ActiveMQ 控制台中看到连接消失 (http://localhost:8161/admin/connections.jsp默认情况下）

有什么想法吗？

Answer 1

当然，我在发布问题后几分钟就弄清楚了。这是其他人寻找的答案：

问题是 NMS 使用 OpenWire，而 OpenWire 默认情况下有 30 秒超时。您可以在 \conf\ActiveMq.xml 文件中更改此设置。以下是您需要更改的内容：

<transportConnectors>
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616?wireFormat.maxInactivityDuration=0"/>
</transportConnectors>

wireFormat.maxInactivityDuration 参数是关键。

Answer 2

警告！
看起来，如果您设置 maxInactivityDuration=0 ，那么套接字永远不会消失。
即使您在 IConnection 上调用 Close 和 Dispose ，底层连接及其运行的线程仍然保留。
根据您的实现，这可能意味着内存泄漏。

Answer 3

听起来您使用的是较旧版本的 NMS，请尝试更新到最新版本 (1.5.5)，此问题应该会消失。有几个与故障转移和不活动监视器相关的问题已在最近几个版本中全部解决。最新版本已得到很好的强化。

蒂姆
Fusesource.com

Answer 4

不确定它是一个答案还是一个更多的问题（或两个；），

但在我们的 NMS 使用中，我们指定wireFormat.MaxInactivityDuration=-1
在客户端的连接 url 中。

似乎有相同的效果，但我们应该使用“-1”还是“0”......？
想知道，有什么区别...

另外，有趣的是，不知怎的，我们没有在服务器配置上指定任何内容，但我们所有的 JAVA 应用程序连接似乎无论如何都保持连接（是因为 JAVA 客户端对 OpenWire config.params 使用不同的默认值吗？或者短信？）