ActiveMQ引入了二进制消息的概念,这样用户可以将消息分发的语义(传输连接,负载均衡和智能路由)同超大尺寸消息结合起来.二进制消息并不包含要发送的数据,而是通知要发送的二进制数据(大尺寸二进制对象)已经准备完成了.二进制对象本身是在消息之外传输的,通过FTP或者HTTP传输.事实上,ActiveMQ的二进制消息仅包含二进制数据的URL,通过一个助手方法可以抓取InputStream进而获取真正的二进制数据.下面让我们通过实例来讲解.

ActiveMQ流是一个高级特性,允许你在ActiveMQ客户端使用Java 的IOStream.ActiveMQ会将一个OutputStream拆分成不同的数据块,然后将每一个数据库当成JMS消息并发送.在消息消费者端需要使用一个相对应的ActiveMQ JMS InputStream来重新组装收到的数据块.

消息群组是排他性消息消费者概念的进一步完善.不同于将所有消息都发送到单一的消费者,消息可以被分组,同一组消息会发送到同一个消费者,并且消息生产者通过设置消息头中的JMSXGroupID值给消息分组.ActiveMQ代理确保JMSXGroupID值相同的消息会被发送到相同的消费者,如图12.3所示.

ActiveMQ代理总是以先进先出的方式转发消息.但是,如果你程序的一个队列中有多个消息消费者,你就无法保证程序按照代理发送消息的顺序来处理消息.这是因为在客户端,即使你的消息消费者都使用同一个连接,你也无法控制用于调度消息发送的线程.理想情况是你只使用一个消费者以保证处理消息的顺序.但是,你可能还需要支持失效转移,支持在第一个消息消费者失效后,使用队列的另外一个消息消费者实例来接管第一个小消费者.ActiveMQ支持一个消息队列拥有多个消息消费者,但是仅有一个消费者会从代理接收消息.我们将在下面的小节中阐述这个概念.

通过本章的学习,你已经学到如何使用通配符和组合消息目的地来改善你的ActiveMQ应用程序接收和发送消息的灵活性.你也应理解了由ActiveMQ代理生成的advisory消息了.

对于要求消息能够尽快发送和接收处理的应用程序来说–例如一个实时的数据推送程序–推荐发送非持久化消息.为了提供有限的追溯非持久化消息消费的方法,ActiveMQ为消息主题提供了可配置缓存大小的消息缓存.为此需要做两件事:你的消息消费者需要通知ActiveMQ代理,表示对可追溯消息感兴趣;并且,你需要配置代理中消息目的地以便代理能够决定为稍后的消息消费者缓存多少数量的消息.

Advisory消息是在ActiveMQ代理发生改变时生成的通知消息.通常,在一个新的管理对象(连接,消息目的地,消息生产者消息消费者)加入或离开代理时生成advisory消息,同样,在ActiveMQ代理达到系统限制时也可以生成advisory消息作为告警.

ActiveMQ支持将ActiveMQ消息代理链接起来组成不同的拓扑结构,或者组成彼此互通的代理网络. 通常,地理上分散的应用程序彼此间进行可靠的通信是一个需求.存在这样的情况,即,让所有客户端都连接到一个中心代理,而这不是使用消息系统最理想的示例.本节的剩余部分将探讨ActiveMQ消息的存储和转发概念的相关细节.我们将看到网络中代理之间 如何发现彼此,以及如何配置一个相互协作的ActiveMQ代理网络.

在第3章中,我们创建了一个portfolio example示例程序.该示例程序使用了映射消息用于消息生产者 和消费者之间的数据交换.为了阐述本章内容,我们将修改远离的示例程序,使其更好的适应本章的开发 环境.我们将使用文本格式的XML消息替代映射消息(Map),因为xml格式消息是本章中开发环境(比如 动态语言)里面更常用通信载体.因此,我们将创建一个Java消息生产者用来发送适当的xml格式的文本 消息.本章的其余部分里,我们将根据不同的平台创建合适的消息消费者,它们将演示如何使用Java以 异步方式连接到指定的平台.