java - ActiveMQ 故障转移传输 - 为什么有这么多连接？

Question

我们在代理网络中设置了 4 个 ActiveMQ 代理(每个都在单独的服务器上运行)。大约有60个生产者。生产者使用 JDNI 从 Glassfish 中查找 ActiveMQ 连接工厂。

Glassfish中配置的ActiveMQ URI如下:

failover:(tcp://phxgapm01:61616,tcp://phxgapm02:61616,tcp://phxgapm03:61616,tcp://phxgapm04:61616)?randomize=true&backup=false&maxReconnectAttempts=8

每个生产者进程都会对 javax.jms.ConnectionFactory 进行 JNDI 查找，然后创建 1 个 javax.jms.Connection。当生产者运行时，它会定期创建 javax.jms.Session 和 javax.jms.MessageProducer，将一些消息发送到队列，然后关闭 Session 和 MessageProducer。

这就是所有背景 - 现在是我的问题。从一些(但不是所有)生产者那里，我们会看到如下日志输出流:

2014-12-30 21:07:06,534 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm03:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,538 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm04:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,544 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm02:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,548 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm04:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,552 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm01:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,556 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm02:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,561 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm02:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,565 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm01:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,568 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm02:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,572 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm04:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,577 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm03:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,581 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm04:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,586 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm01:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,590 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm03:61616 - [ActiveMQ Task-1]
2014-12-30 21:07:06,594 INFO  FailoverTransport    - Successfully connected to tcp://phxgapm04:61616 - [ActiveMQ Task-1]

对于某些生产者，我们会每 10 分钟看到一次此输出 - 对于其他生产者来说，频率较低。更令人困惑的是，所有这些生产者都对 JMS 消息传递使用相同的代码 - 因此，虽然生产者创建 session 和消息生产者的频率可能有所不同，但它们都使用相同的代码并且都只创建 1 个连接对象。

通过阅读文档，我的理解是故障转移传输将打开与 1 个代理的连接(在我们的例子中是随机选择的)。为什么我们会看到这种连接流(60 毫秒内到每个代理的多个连接)？使用 netstat 我们可以看到这些连接。这是正常的吗？如果没有，关于可能导致此问题的任何建议？

Answer 1

在没有提高 activeMQ 日志级别的情况下，还有一些推测的余地，但是:

• “对于其他人来说，它不那么频繁” - 在这种情况下观察不同实例的不同行为是完全自然的。如果负载没有在实例之间完美分布，它们在消息传递方面的行为会有所不同。试想一下，您的一个节点接收 90% 的触发输入并独自完成大部分工作。该节点将承受更高的负载，并且使用其 JMS 资源的方式与其他节点完全不同。
• “我的理解是故障转移传输会打开与 1 个代理的连接” - 这是完全正确的。仅当包装 connectionFactory 请求打开新的物理连接时，故障转移才会起作用。在这种情况下，将只为该请求创建一个连接。
• “为什么我们会看到这种连接流” - 我很确定这是因为您的项目中有一个池化实现。您可以看到所有代理都建立了这些连接(随机分布)，表明同时有多个新连接请求。

通过增加应用程序中的日志级别，您将能够准确地看到哪个层启动了此操作以及出于什么原因。可能的原因是:“所有连接都已过期，池将 minIdleConnection 计数恢复到最小值”； “您的应用程序中的某些传入请求需要一次发送大量消息，因此您的池会创建它们”。