activemq Dynamic Broker-Cluster测试问题

发布于 2021-11-28 05:32:30 字数 4510 浏览 735 评论 1

activemq配置动态如下:


A:<networkConnectors> 

         <networkConnectoruri="multicast://default"

           dynamicOnly="true"

           networkTTL="3"

           prefetchSize="1"

           decreaseNetworkConsumerPriority="true" />

</networkConnectors>

<transportConnectors>

<transportConnectorname="openwire"uri="tcp://0.0.0.0:61616 " discoveryUri="multicast://default"/>

</transportConnectors>

B:<networkConnectors> 

         <networkConnectoruri="multicast://default"

           dynamicOnly="true"

           networkTTL="3"

           prefetchSize="1"

           decreaseNetworkConsumerPriority="true" />

</networkConnectors>

<transportConnectors>

<transportConnectorname="openwire"uri="tcp://0.0.0.0:61617" discoveryUri="multicast://default"/>

</transportConnectors>

JAVA客户端61616发送10条数据(比如是1-10),开启61617消费数据,消费2条数据(1,2)后停止消费数据,开启61616消费数据,消费3条数据(3,4,5)后停止消费数据。此时开启61617消费数据,发现没有数据可以消费,开启61616可以消费数据(6,7,8,9,10)。这是什么原因呢?在测试过程中发现有时候61616发送10条数据,开启61617消费几条数据后停止,开启61616消费却发现一条数据也没有。只能由61617消费这10条数据。我想达到的效果是,61616发送10条数据,61616消费几条数据后停止,61617消费几条后停止,此时开启61616依旧可以继续消费。该如何实现?




如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

后知后觉 2021-11-29 20:14:01

请问这个问题解决了吗?

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文