ActiveMQ：在没有代理的情况下启动消费者

Question

我正在编写一个从队列消费的 JMS 客户端。如果重要的话，我的经纪人是 activemq。

一项要求是，即使代理关闭，客户端也应该启动。在这种情况下，它的行为应该就像队列中没有消息一样，一旦代理启动并且消息开始出现，就会做出相应的行为。

问题是在我的代码中：

connectionFactory = new ActiveMQConnectionFactory(url);
Connection connection = connectionFactory.createConnection();
connection.start()

如果代理关闭，那么它就会陷入connection.start()。虽然我想要的是 connection.start() 静静地返回，并继续尝试在后台连接并在可以的时候消耗消息，而在不能的时候保持沉默。

我怎样才能做到这一点。

Answer 1

使用单独的线程从队列中消费并启动连接。您将需要使用并发队列实现。

线程 1：

• 实例化队列
• 启动线程 2
• 尝试连接/阻止
• 将消息添加到队列

线程 2（或某种池）：

• 启动客户端
• 从队列/块读取
• 处理消息

Answer 2

有两种方法可以解决此类场景，AMQ-2114 中描述了其中一种方法：

1. 通过使用 AMQ-2114 中建议的代理 URI。通过使用 AMQ-2114 中建议的代理 URI，创建一个嵌入式代理，并通过网络连接到远程代理。但是，正如所指出的，代理 URI 不使用故障转移连接器。

2. 通过使用手动配置为使用代理网络的嵌入式代理。我过去曾使用过这种方法，其中 ActiveMQ 代理实例嵌入到 Java 应用程序中，并配置了与远程代理的网络连接。这将允许您的客户端连接到嵌入式代理而不会挂起，并将消息发送到嵌入式代理。消息将从嵌入式代理流向远程代理，但仅当消费者对远程代理上的消息有需求时（即，消费者连接到远程代理并请求消息）。与嵌入式代理的连接可以使用故障转移传输，并且与远程代理的网络连接也可以使用故障转移传输。

我为此解决方案给出的示例是销售人员笔记本电脑上的 Java 应用程序的用例。即使销售人员没有连接到他们的办公室网络，这样的应用程序也需要继续工作。这里的解决方案是在Java应用程序中嵌入一个代理，这样应用程序在发送消息时就不会挂起，即使它没有连接到办公网络。当应用程序再次连接到办公网络时，它将自动连接到另一个代理并且消息将流动。

布鲁斯

Answer 3

为了后代，我强烈建议使用 Spring 的 DefaultMessageListenerContainer 来消费消息，一旦使用以下配置 代码片段：

<jms:listener-container>
    <jms:listener destination="queue.orders" ref="orderService" method="placeOrder"/>
</jms:listener-container>

它将负责根据您的特定要求连接到 jms 队列基础设施（如果 JMS 基础设施关闭，应用程序上下文仍会加载，但重试线程会每隔几秒尝试恢复连接）。

Answer 4

我认为 ActiveMQ 有协议（许多协议......）来改变连接行为。尝试在您的网址中使用“failover://”或类似内容，看看它是如何工作的。

Answer 5

我现在也在解决这个问题。请参阅 AMQ-2114。

我不太明白接受的答案，所以我建议赏金。

我正在使用 ActiveMQ 的 C++ 版本。但我相信这应该不会有太大差异。

我考虑过在单独的线程中调用connection.start()，并在TransportListener::transportResumed()中调用connection->createSession()。但是createSession挂掉了。

最重要的是，我没有可行的解决方案，我很高兴知道该问题的其他解决方案。