第 7 章 消息结构


摘要

消息构造模式描述了通过系统传递的消息的各种形式和功能。

7.1. 关联标识符

概述

图 7.1 “关联标识符模式” 中显示的 关联标识符 模式描述了如何与带有请求消息的回复消息匹配,因为异步消息传递系统用于实现请求回复协议。这种理念是,请求消息应该使用唯一的令牌(请求 ID )生成,该请求 ID 标识请求消息,并且回复消息应包含令牌、关联 ID,其中包含匹配的请求 ID。

Apache Camel 通过获取或设置消息上的标头来支持来自 EIP 模式的 Correlation 标识符。

在使用 ActiveMQ 或 JMS 组件时,关联标识符标头称为 JMSCorrelationID。您可以将自己的关联标识符添加到任何消息交换中,以帮助在单个对话(或业务流程)中关联消息。关联标识符通常存储在 Apache Camel 消息标头中。

有些 EIP 模式会关闭子消息,在这种情况下,Apache Camel 会向 Exchange 添加关联 ID 作为密钥 Exchange 的属性。Exchange.CORRELATION_ID 链接到源交换。例如,分割器、多播、接收者列表和 有线 tap EIP 执行此操作。

图 7.1. 关联标识符模式

关联标识符模式

事件消息

Camel 通过支持 消息 上的 Exchange Pattern (可以设置为 InOnly )来指示单向事件消息,从而支持 企业集成模式 中的事件消息。???然后,Camel Apache Camel 组件参考 使用底层传输或协议实施此模式。

事件消息解决方案

许多 Apache Camel 组件参考 的默认行为是 InOnly,如 JMS、File 或 SEDA

明确指定 InOnly

如果您使用默认为 InOut 的组件,您可以使用 pattern 属性覆盖端点 的消息交换 模式。

foo:bar?exchangePattern=InOnly

从 Camel 上的 2.0 开始,您可以使用 DSL 指定 消息交换模式。

使用 Fluent Builder

from("mq:someQueue").
  inOnly().
  bean(Foo.class);

或者您可以使用显式模式调用端点

from("mq:someQueue").
  inOnly("mq:anotherQueue");

使用 Spring XML 扩展

<route>
    <from uri="mq:someQueue"/>
    <inOnly uri="bean:foo"/>
</route>
<route>
    <from uri="mq:someQueue"/>
    <inOnly uri="mq:anotherQueue"/>
</route>
Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

关于红帽文档

Legal Notice

Theme

© 2026 Red Hat
返回顶部