ActiveMQ主题到队列，当使用骆驼路由消息丢失时，从主切换到从？

Question

设置：默认ActiveMQ.XML。本地数据中心的3台服务器上的每台服务器一个ActiveMQ实例，远程数据中心服务器上的每个服务器一个Active MQ实例。所有3个1实例都在运行，但每个数据中心在任何给定时刻只有一个ActiveMQ实例是主实例。来自所有数据中心的所有实例的消息都将持久化到网络KahaDB，我们为每条消息配置了两次重试。

目标：保持数据中心之间的队列同步。

问题：要测试远程服务器何时关闭，所有消息都将被保存/持久化，直到远程服务器重新联机。我将向ActiveMQ主题发送三条消息。

骆驼路由被配置为读取主题并推送到2个本地队列。

第二个camel路由设置为从一个本地队列中读取，并将消息推送到远程ActiveMQ。

当远程服务器关闭（数据中心2关闭），并且我们从主ActiveMQ（通过停止服务）故障切换到从服务器时，3条消息中的1条消息将丢失到以太。这似乎是发送到远程服务器的第一条消息。就好像连接被拒绝了什么的，它就永远消失了，甚至连DLQ都没有？

骆驼配置：

<bean id="local" class="org.apache.activemq.camel.component.ActiveMQComponent">
  <property name="brokerURL" value="tcp://localhost:12345"/>
  <property name="preserveMessageQos" value="true" />
</bean>

<bean id="remote" class="org.apache.activemq.camel.component.ActiveMQComponent">
  <property name="brokerURL" value="failover:(tcp://remotehost:54321)"/>
  <property name="preserveMessageQos" value="true" />
</bean>

<camelContext id="topicToQueueCamelContext" xmlns="http://camel.apache.org/schema/spring">
    <route id="topicToQueue">
        <from uri="local:topic:SomeTopic"/>
        <to uri="local:queue:SomeQueue"/>
        <to uri="local:queue:SomeQueue.Remote"/>
    </route>
</camelContext>

<camelContext id="queueToRemoteQueueCamelContext" xmlns="http://camel.apache.org/schema/spring">
    <route id="queueToRemoteQueue">
        <from uri="local:queue:SomeQueue.Remote"/>
        <to uri="remote:queue:SomeQueue"/>
    </route>
</camelContext>

尝试：将远程骆驼路由设置为事务处理，并在代理URL故障转移传输上设置trackMessages=true。

是否有人对ActiveMQ BrokerURL、ActiveMQ XML或Camel URI查询字符串参数可能丢失有任何想法——或者对如何解决或调试此丢失消息问题有任何想法？

Answer 1

您需要配置您的< code>ActiveMQComponent来使用事务性消息。默认情况下，消息消费不是事务性的。这样您可以获得最佳性能，但是您也“接受”丢失消息。