activemq Dynamic Broker-Cluster测试问题
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 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论
评论(1)
请问这个问题解决了吗?