欢迎来到天天文库
浏览记录
ID:14280768
大小:60.00 KB
页数:6页
时间:2018-07-27
《activemq集群的使用与配置》由会员上传分享,免费在线阅读,更多相关内容在行业资料-天天文库。
1、Clustering(集群)ActiveMQ从多种不同的方面提供了集群的支持。1、QueueconsumerclustersActiveMQ支持订阅同一个queue的consumers上的集群。如果一个consumer失效,那么所有未被确认(unacknowledged)的消息都会被发送到这个queue上其它的consumers。如果某个consumer的处理速度比其它consumers更快,那么这个consumer就会消费更多的消息。需要注意的是,笔者发现AcitveMQ5.0版本的Queueconsumerclusters存在一个b
2、ug:采用AMQMessageStore,运行一个producer,两个consumer,并采用如下的配置文件:Xml代码3、tenceAdapterdirectory="activemq-data/BugBroker1"maxFileLength="32mb"/>那么经过一段时间后可能会报出如下错误:ERROR[ActiveMQTransport:tcp:///127.0.0.1:1843-RecoveryListenerAdapter.java:58-RecoveryListenerAdapter]MessageidID:versus-1837-1203915536609-0:2:
3、tenceAdapterdirectory="activemq-data/BugBroker1"maxFileLength="32mb"/>
4、1:1:419couldnotberecoveredfromthedatastore!Apache官方文档说,此bug已经被修正,预定在5.1.0版本上体现。2、Brokerclusters一个常见的场景是有多个JMSbroker,有一个客户连接到其中一个broker。如果这个broker失效,那么客户会自动重新连接到其它的broker。在ActiveMQ中使用failover://协议来实现这个功能。ActiveMQ3.x版本的reliable://协议已经变更为failover://。如果某个网络上有多个brokers而且客户使用静
5、态发现(使用Static6Transport或FailoverTransport)或动态发现(使用DiscoveryTransport),那么客户可以容易地在某个broker失效的情况下切换到其它的brokers。然而,standalonebrokers并不了解其它brokers上的consumers,也就是说如果某个broker上没有consumers,那么这个broker上的消息可能会因得不到处理而积压起来。目前的解决方案是使用Networkofbrokers,以便在broker之间存储转发消息。ActiveMQ在未来会有更好的特性
6、,用来在客户端处理这个问题。从ActiveMQ1.1版本起,ActiveMQ支持networksofbrokers。它支持分布式的queues和topics。一个broker会相同对待所有的订阅(subscription):不管他们是来自本地的客户连接,还是来自远程broker,它都会递送有关的消息拷贝到每个订阅。远程broker得到这个消息拷贝后,会依次把它递送到其内部的本地连接上。有两种方式配置Networkofbrokers,一种是使用statictransport,如下:Xml代码7、ver"persistent="false"useJmx="false">…另外一种是使用multicast8、discovery,如下:Xml代码
7、ver"persistent="false"useJmx="false">…另外一种是使用multicast
8、discovery,如下:Xml代码
此文档下载收益归作者所有