第 6 章 消息传递频道
摘要
消息传递频道为消息传递应用程序提供 plumbing。本章论述了消息传递系统中可用的不同类型的消息通道,以及它们所扮演的角色。
6.1. 点到点频道
概述
在 图 6.1 “指向点频道模式” 中显示的 点对点频道 是保证只有一个接收器消耗任何给定信息的消息 频道。这与 发布与订阅频道 不同,后者允许多个接收方使用相同的消息。特别是,通过 publish-subscribe 频道,多个接收方可以订阅同一频道。如果多个接收器竞争使用一条消息,则最多可使用消息频道,以确保只有一个接收器实际消耗这个信息。
图 6.1. 指向点频道模式
支持点到点频道的组件
以下 Apache Camel 组件支持点到点频道模式:
JMS
在 JMS 中,点到点频道由 队列 表示。例如,您可以为名为 Foo.Bar
的 JMS 队列指定端点 URI,如下所示:
jms:queue:Foo.Bar
限定符 queue:
是可选的,因为 JMS 组件默认创建一个队列端点。因此,您还可以指定以下等同的端点 URI:
jms:Foo.Bar
如需了解更多详细信息,请参阅 Apache Camel 组件参考指南中的 Jms。
ActiveMQ
在 ActiveMQ 中,点到点频道由队列表示。例如,您可以为名为 Foo.Bar
的 ActiveMQ 队列指定端点 URI,如下所示:
activemq:queue:Foo.Bar
如需了解更多详细信息,请参阅 Apache Camel 组件参考指南 中的 ActiveMQ。
SEDA
Apache Camel Staged 事件架构(SEDA)组件使用块队列实施。如果要创建一个 Apache Camel 应用程序 内部的 轻量级点到点频道,请使用 SEDA 组件。例如,您可以为名为 SedaQueue
的 SEDA 队列指定端点 URI,如下所示:
seda:SedaQueue
JPA
Java Persistence API(JPA)组件是一种 EJB 3 持久性标准,用于将实体 Bean 写入数据库。如需了解更多详细信息,请参阅 Apache Camel 组件参考指南 中的 JPA。
XMPP
XMP(Jabber)组件支持点对点频道模式。如需了解更多详细信息,请参阅 Apache Camel 组件参考指南 中的 XMPP。