2017-08-15 202 views
1

我想使用静态主机在我的双节点群集上启用消息重新分配。但它似乎并不奏效。ArtemisMQ 2.x上的消息重新分配不起作用

1)我有10个生产者写入队列“MyTestQueue”节点1(但没有消费者)。
2)我在节点2(但没有生产者)上有1个消费者使用来自节点2的消息。

我期望节点1将消息重新分配给消费者存在的节点2,但它不会。节点1上的消息数量仍然等于发送到节点1的消息数量。

我在broker.xml中拥有以下配置,它将forward-when-no-consumers设置为false。 我也设置redistribution-delay值为零。

<jms xmlns="urn:activemq:jms"> 
    <queue name="MyTestQueue"/> 
</jms> 
... 
<cluster-connections> 
     <cluster-connection name="my-test-cluster"> 
      <address>jms</address> 
      <connector-ref>server0-connector</connector-ref> 
      <retry-interval>500</retry-interval> 
      <use-duplicate-detection>true</use-duplicate-detection> 
      <forward-when-no-consumers>false</forward-when-no-consumers> 
      <message-load-balancing>ON_DEMAND</message-load-balancing> 
      <max-hops>1</max-hops> 
      <confirmation-window-size>1024</confirmation-window-size> 
      <static-connectors> 
       <connector-ref>server1-connector</connector-ref> 
      </static-connectors> 
     </cluster-connection> 
    </cluster-connections> 
    ... 
    <address-settings> 
     <address-setting match="#"> 
      <redelivery-delay>5000</redelivery-delay> 
      <redelivery-delay-multiplier>3</redelivery-delay-multiplier> 
      <max-redelivery-delay>10000</max-redelivery-delay> 
      <max-delivery-attempts>10</max-delivery-attempts> 
      <max-size-bytes>104857600</max-size-bytes> 
      <page-size-bytes>10485760</page-size-bytes> 
      <address-full-policy>PAGE</address-full-policy> 
      <redistribution-delay>0</redistribution-delay> 
     </address-setting> 
    </address-settings> 

如何让消息重新分配工作?

回答

2

这可能与已知的issue有关。如果代理不包含应用程序属性字段,则代理无法负载均衡消息。

请问您可以试试吗?

+0

谢谢!你能否指定我需要设置哪种应用程序属性以及在哪里?在客户端?在broker.xml中? – Rox

+0

@Rox在发送的消息上设置一些应用程序属性。任何事情都应该有效。不要在没有任何应用程序属性的情况下完全发送消息。 – user7610

+0

@ user7610:哦,我明白了!我将尝试在消息上设置一个字符串属性并查看它是否有效。结果会回到这里。 – Rox

1

的东西夫妇...

  • 您正在使用什么版本的阿尔忒弥斯?你有没有试过用2.2.0版本来重现这一点?
  • 您使用的是哪种客户端(例如JMS,AMQP,STOMP等)?
  • 您是否拥有可复制的测试用例(例如Artemis附带的其中一个示例的修改版本)?
  • 配置元素< forward-when-no-consumers>在Artemis中无效(虽然它在HornetQ的旧版本中)。