ActiveMQ Artemis在HA故障转移期间发布消息丢失

我使用ActiveMQ Artemis 2.17.0，我希望避免在故障转移期间生产者中丢失消息。

在 Artemis 主动切换到被动期间处理的消息发布丢失，方法是捕获ActiveMQUnBlockedException并再次发送消息。代理配置为主动/被动 HA 共享存储。在host1中配置的主动节点和在host2中配置的被动节点。网址是：

(tcp://host1:61616,tcp://host2:61616)?ha=true&reconnectAttempts=-1&blockOnDurableSend=false

blockOnDurableSend设置为false以实现高吞吐量。在主动到被动切换期间，发布代码会引发ActiveMQUnBlockedException但不会在被动到主动切换期间

引发。我们正在使用 Spring 4.2.5 和CachingConnectionFactory进行连接工厂。

我使用以下代码发送消息：

private void sendMessageInternal(final ConnectionFactory connectionFactory, final Destination queue, final String message)
throws JMSException {
try (final Connection connection = connectionFactory.createConnection();) {
connection.start();
try (final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
final MessageProducer producer = session.createProducer(queue);) {
final TextMessage textMessage = session.createTextMessage(message);
producer.send(textMessage);
}
} catch (JMSException thr) {
if (thr.getCause() instanceof ActiveMQUnBlockedException) {
// consider as fail-over disconnection, send message again.
} else {
throw thr;
}
}
}

在主机 1 机器中，Artemis 部署为主节点 - 节点 1。在 host2 机器中，Artemis 部署为从属 - node2。按照我执行的步骤来模拟故障转移

节点

1 和节点 2 已启动
，节点 2 作为备份服务器启动
终止节点 1，节点 2 成为活动服务器
客户端发布代码抛出ActiveMQUnBlockedException并处理以再次发送消息
。节点 1 再次变为活动服务器，节点 2 再次变为备份服务器
客户端发布代码未引发消息ActiveMQUnBlockedException和丢失。

在步骤 #3 期间获取以下错误堆栈。(终止节点 1 和节点 2 成为实时服务器)。

javax.jms.JMSException: AMQ219016: Connection failure detected. Unblocking a blocking call that will never get a response
at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:540)
at org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.sendBlocking(ChannelImpl.java:434)
at org.apache.activemq.artemis.core.protocol.core.impl.ActiveMQSessionContext.sessionStop(ActiveMQSessionContext.java:470)
at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.stop(ClientSessionImpl.java:1121)
at org.apache.activemq.artemis.core.client.impl.ClientSessionImpl.stop(ClientSessionImpl.java:1110)
at org.apache.activemq.artemis.jms.client.ActiveMQSession.stop(ActiveMQSession.java:1244)
at org.apache.activemq.artemis.jms.client.ActiveMQConnection.stop(ActiveMQConnection.java:339)
at org.springframework.jms.connection.SingleConnectionFactory$SharedConnectionInvocationHandler.localStop(SingleConnectionFactory.java:644)
at org.springframework.jms.connection.SingleConnectionFactory$SharedConnectionInvocationHandler.invoke(SingleConnectionFactory.java:577)
at com.sun.proxy.$Proxy5.close(Unknown Source)
at com.eu.amq.failover.test.ProducerNodeTest.sendMessageInternal(ProducerNodeTest.java:133)
at com.eu.amq.failover.test.ProducerNodeTest.sendMessage(ProducerNodeTest.java:110)
at com.eu.amq.failover.test.ProducerNodeTest.main(ProducerNodeTest.java:90)

你得到的ActiveMQUnBlockedException来自春天对javax.jms.Connection#stop的调用。这与发送消息无关。收到此特定异常时重新发送邮件可能会导致重复邮件。

最终，您的问题与设置blockOnDurableSend=false直接相关。这告诉客户端"即发即弃"。换句话说，客户端不会等待代理的响应来确保消息确实成功。这种缺少等待会增加吞吐量，但会降低可靠性。

如果您真的想减轻潜在的消息丢失，您有两个主要选择。

设置blockOnDurableSend=true.这将降低消息吞吐量，但这是保证消息成功到达代理的最简单方法。

使用CompletionListener.这将允许您保留blockOnDurableSend=false，但如果发送消息时出现问题，尽管信息将异步提供，但仍会收到通知应用程序。JMS 2 中专门为此类场景添加了此功能。有关更多详细信息，请参阅 JavaDoc。

相关内容

最新更新

热门标签：