Geronimo 叛逆者: Apache Geronimo 的 JMS 实现：ActiveMQ

每个消息（即帧）以一个命令开头，以一个表示 null 字符的 ASCII 符号结束。在这个例子中，我将从服务器发送到客户机的消息显示为斜体，以便区分。在这里可以看到，一个客户机连接到这个系统，它将一个消息发送到队列 thingsIllDoToday，然后订阅 weatherChanges 队列。代理每当接收到属于这个队列的消息时，就把消息发送给这个客户机。

Stomp 项目已经开发了 Ruby、Python、Perl、PHP、C、C# 和 Java 语言的客户机。还可以使用二进制连接格式 OpenWire，这实际上是 ActiveMQ 的默认连接协议。它比较快，但是比较难实现。

消费者端的负载平衡

James 还告诉我，他最欣赏的 ActiveMQ 特性之一是可以在消费者端进行负载平衡。消息组是一种不太为人所知的 JMS 可选特性。“它有点儿像 Web 应用程序的负载平衡，但是应用于消息传递，” 他说。假设您将来自 Amazon 站点的订单放进一个队列中，希望尽可能快地处理它们。JMS 提供者会在消费者之间根据负载平衡原则分配这些消息。但是，如果希望按照次序处理消息，就会遇到一个问题：只能使用一个消费者来处理消息，这样才能保证次序的完整性，才能正确地处理订单。

“所以，如果我们的集群有 1,000 个消费者，可以将 JMSXGroupID 字符串添加到每个消息中，表示它属于哪个组，这样就可以维持消息的次序。例如，可以使用 Books 作为 ID。这样就由一个消费者来处理所有图书，而 Electronics 和其他类别的商品仍然进行负载平衡。还可以使用图书的 ISBN 号作为 ID，这样所有 Getting Things Done 图书由一个消费者处理，JMS Essentials 图书由另一个消费者处理。所以，它是一种有亲和性的可定制的负载平衡，可以支持故障转移。如果一个消费者停止工作了，那么另一个消费者会替代它。甚至可以将当前拥有的图书数量缓存在消费者中，因为在整个集群中只有这一个线程处理这种书的订单，所以其他消费者不会修改数据库。所以可以进行超高效率的缓存，避免锁定和争用问题。这是一种对应用程序进行划分，从而使吞吐量最大化的好方法。”