ActiveMQ 消费者端的负载平衡

原文 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 图书由另一个消费者处理。所以，它是一种有亲和性的可定制的负载平衡，可以支持故障转移。如果一个消费者停止工作了，那么另一个消费者会替代它。甚至可以将当前拥有的图书数量缓存在消费者中，因为在整个集群中只有这一个线程处理这种书的订单，所以其他消费者不会修改数据库。所以可以进行超高效率的缓存，避免锁定和争用问题。这是一种对应用程序进行划分，从而使吞吐量最大化的好方法。”