第 34 章 了解消息格式
摘要
在开始使用 Apache Camel 编程之前,您应该清晰地了解消息和消息交换的建模。由于 Apache Camel 可以处理许多消息格式,因此基本消息类型设计为具有抽象格式。Apache Camel 提供访问和转换消息正文和消息标题中数据格式所需的 API。
34.1. Exchanges
概述
Exchange 对象 是封装收到的消息并存储其关联元数据(包括 交换属性)的打包程序。另外,如果将当前消息分配给制作者端点,则交换提供了一个临时插槽来存放回复( Out 消息)。
在 Apache Camel 中交换的一个重要功能是,它们支持创建消息。如果不需要明确访问消息的路由,这可以提供重要的优化。
图 34.1. 通过路由交换对象
图 34.1 “通过路由交换对象” 显示通过路由进行交换对象。在路由上下文中,交换对象作为 Processor.process ()
方法的参数传递。这意味着交换对象可被源端点、目标端点和所有处理器直接访问。
Exchange 接口
org.apache.camel.Exchange 接口定义了访问 In 和 Out 消息的方法,如 例 34.1 “Exchange Methods” 所示。
例 34.1. Exchange Methods
// Access the In message Message getIn(); void setIn(Message in); // Access the Out message (if any) Message getOut(); void setOut(Message out); boolean hasOut(); // Access the exchange ID String getExchangeId(); void setExchangeId(String id);
有关 Exchange 界面中方法的完整描述,请参考 第 43.1 节 “Exchange Interface”。
延迟创建消息
Apache Camel 支持在、Out、和 失败消息 中创建 lazy。这意味着,只有在您尝试访问它们前,才会创建消息实例(例如,通过调用 getIn ()
或 getOut ()
)。lazy 消息创建语义由 org.apache.camel.impl.DefaultExchange
类实施。
如果您调用 no-argument accessors (getIn ()
或 getOut ()
),或者如果您调用与 true 等于 true
的 accessor (即 getIn (true)
)或 getOut (true)
,则默认方法实施会创建一个新消息实例(如果尚不存在)。
如果您使用与 false
相等的布尔参数调用 accessor (即 getIn (false)
或 getOut (false)
),则默认方法实现会返回当前消息值。[1]
延迟创建交换 ID
Apache Camel 支持 lazy 创建交换 ID。您可以在任何交换上调用 getExchangeId ()
来获取该交换实例的唯一 ID,但只有在实际调用方法时才会生成 ID。此方法的 DefaultExchange.getExchangeId ()
实现将 ID 生成委派给使用 CamelContext
注册的 UUID 生成器。
有关如何使用 CamelContext
注册 UUID 生成器的详情,请参考 第 34.4 节 “内置 UUID Generators”。