原文 http://www.ibm.com/developerworks/cn/opensource/os-ag-renegade6/
James欣赏的 ActiveMQ 特性之一是可以在消费者端进行负载平衡。消息组是一种不太为人所知的 JMS 可选特性。“它有点儿像 Web 应用程序的负载平衡,但是应用于消息传递,” 他说。假设您将来自 Amazon 站点的订单放进一个队列中,希望尽可能快地处理它们。JMS 提供者会在消费者之间根据负载平衡原则分配这些消息。但是,如果希望按照次序处理消息,就会遇到一个问题:只能使用一个消费者来处理消息,这样才能保证次序的完整性,才能正确地处理订单。
“所以,如果我们的集群有 1,000 个消费者,可以将 JMSXGroupID 字符串添加到每个消息中,表示它属于哪个组,这样就可以维持消息的次序。例如,可以使用 Books 作为 ID。这样就由一个消费者来处理所有图书,而 Electronics 和其他类别的商品仍然进行负载平衡。还可以使用图书的 ISBN 号作为 ID,这样所有 Getting Things Done 图书由一个消费者处理,JMS Essentials 图书由另一个消费者处理。所以,它是一种有亲和性的可定制的负载平衡,可以支持故障转移。如果一个消费者停止工作了,那么另一个消费者会替代它。甚至可以将当前拥有的图书数量缓存在消费者中,因为在整个集群中只有这一个线程处理这种书的订单,所以其他消费者不会修改数据库。所以可以进行超高效率的缓存,避免锁定和争用问题。这是一种对应用程序进行划分,从而使吞吐量最大化的好方法。”
分享到:
相关推荐
ActiveMQ高可用+负载均衡集群的安装、配置、高可用测试
ActiveMQ高可用+负载均衡集群的安装、配置、高可用测试
activemq负载均衡实现.doc
springboot整合 activeMq 消费者 消费接收消息 包含队列模式点对点发 以及 主题模式一对多 这是消费者的demo consumer 。 里面有消息重发机制,手动确认ACK模式。 配合 producer 生产者demo使用。
高可用之ActiveMQ高可用+负载均衡集群的安装、配置、高可用测试--java源码
使用SpringBoot开发的ActiveMQ生产者/消费者的demo。相关内容可以看这里: https://my.oschina.net/noryar/blog/1575003
动态创建ActiveMQ消费者
activemq生产者和消费者案例代码.zipactivemq生产者和消费者案例代码.zip
ActiveMQ整合Spring(多消费者)
资源好源码、文档
Apache-ActiveMQ高可用性之负载均衡.docx
activeMQ实现生产者和消费者的代码
先到官网下载activemq,启动后,就可以直接运行项目文件了
springboot整合 activeMq 生产者 发送消息 包含队列模式点对点发送消息 以及 主题模式一对多发送消息 这是生产者的demo producer; 需要配合消费者的demo consumer 使用
ActiveMQ+zookeeper实现高可用和负载均衡(代码和测试)
java整合activemq的demo,生产者和消费者两个方法。结合自带的工具http://192.168.1.106:8161。来查看消息传递情况
activemq linux下的多线程客户端,在windows下同样适用,包含生产消息客户端,和消费者消息客户端,以及生产者消息多线程客户端
ActiveMq安卓端
压缩包中包含Client Android 端和Service 端,Service端采用apache-activemq-5.13.3最新的版本。Android端采用MQTT实现了消息的接收,接收消息的回调是messageArrived方法。 Server端的简要使用说明如下: 1、解压...
《RabbitMQ集群环境生产实例部署》《ActiveMQ集群》《ActiveMQ高可用+负载均衡集群的安装、配置、高可用测试》