WEB开发网
开发学院软件开发Java Geronimo 叛逆者: Apache Geronimo 的 JMS 实现:... 阅读

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

 2010-04-23 00:00:00 来源:WEB开发网   
核心提示: 每个消息(即帧)以一个命令开头,以一个表示 null 字符的 ASCII 符号结束,Geronimo 叛逆者: Apache Geronimo 的 JMS 实现:ActiveMQ(7),在这个例子中,我将从服务器发送到客户机的消息显示为斜体,避免锁定和争用问题,这是一种对应用程序进行划分,以便区

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

上一页  2 3 4 5 6 7 8  下一页

Tags:Geronimo 叛逆者 Apache

编辑录入:爽爽 [复制链接] [打 印]
赞助商链接