Red Hat Summit 红帽全球峰会支持控制台（Console）开发人员开始试用联系人

326.15. 将正文和标头存储为文本

从 Camel 2.11 开始提供

您可以配置 JdbcAggregationRepository 以存储消息正文，并选择(ed)标头作为 String 在单独的列中选择。例如，要存储正文，并且以下两个标头 companyName 和 accountName 使用以下 SQL： 

CREATE TABLE aggregationRepo3 (
 id varchar(255) NOT NULL,
 exchange blob NOT NULL,
 body varchar(1000),
 companyName varchar(1000),
 accountName varchar(1000),
 constraint aggregationRepo3_pk PRIMARY KEY (id)
);
CREATE TABLE aggregationRepo3_completed (
 id varchar(255) NOT NULL,
 exchange blob NOT NULL,
 body varchar(1000),
 companyName varchar(1000),
 accountName varchar(1000),
 constraint aggregationRepo3_completed_pk PRIMARY KEY (id)
);

然后，将存储库配置为启用此行为，如下所示： 

<bean id="repo3"
  class="org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository">
  <property name="repositoryName" value="aggregationRepo3"/>
  <property name="transactionManager" ref="txManager3"/>
  <property name="dataSource" ref="dataSource3"/>
  <!-- configure to store the message body and following headers as text in the repo -->
  <property name="storeBodyAsText" value="true"/>
  <property name="headersToStoreAsText">
    <list>
      <value>companyName</value>
      <value>accountName</value>
    </list>
  </property>
</bean>

326.15.1. codec (Serialization)
复制链接

由于它们可以包含任何类型的有效载荷，因此交换不能按照设计序列化。它将转换为一个字节数组，以存储在数据库 BLOB 字段中。所有这些转换都由 JdbcCodec 类处理。代码的详情需要注意： ClassLoadingAwareObjectInputStream。

ClassLoadingAwareObjectInputStream 已从 Apache ActiveMQ 项目中重复使用。它嵌套 ObjectInputStream，并将其与 ContextClassLoader 一起使用，而不是 当前的Thread。其好处在于能够加载由其他捆绑包公开的类。这允许交换正文和标头具有自定义类型对象引用。

326.15.2. transaction
复制链接

需要 Spring PlatformTransactionManager 来编配事务。

326.15.2.1. 服务(Start/Stop)
复制链接

start 方法验证数据库和存在所需的表。如果出现错误，它将在启动期间失败。

326.15.3. 聚合器配置
复制链接

根据目标环境，聚合器可能需要一些配置。如您已经了解，每个聚合器应具有自己的存储库（在数据库中创建的对应表对）和数据源。如果默认的 lobHandler 没有适应您的数据库系统，它可以与 lobHandler 属性注入。

以下是 Oracle 的声明： 

<bean id="lobHandler" class="org.springframework.jdbc.support.lob.OracleLobHandler">
  <property name="nativeJdbcExtractor" ref="nativeJdbcExtractor"/>
</bean>
<bean id="nativeJdbcExtractor"
  class="org.springframework.jdbc.support.nativejdbc.CommonsDbcpNativeJdbcExtractor"/>
<bean id="repo"
  class="org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository">
  <property name="transactionManager" ref="transactionManager"/>
  <property name="repositoryName" value="aggregation"/>
  <property name="dataSource" ref="dataSource"/>
  <!-- Only with Oracle, else use default -->
  <property name="lobHandler" ref="lobHandler"/>
</bean>

326.15.4. 最佳锁定
复制链接

从 Camel 2.12 开始，您可以打开 optimisticLocking，并在集群环境中使用此基于 JDBC 的聚合存储库，其中多个 Camel 应用程序为聚合存储库共享同一数据库。如果存在竞争条件，则 JDBC 驱动程序将抛出一个供应商特定异常，Jdb cAggregationRepository 可以响应。要了解导致 JDBC 驱动程序的例外情况被视为一个 optimistick locking 错误，我们需要一个映射程序来执行此操作。因此，有 org.apache.camel.processor.aggregate.jdbc.JdbcOptimisticLockingExceptionMapper 允许您实施您的自定义逻辑（如果需要）。有默认的实现 org.apache.camel.processor.aggregate.jdbc.DefaultJdbcOptimisticLockingExceptionMapper，它的工作方式如下：

完成以下检查：

  • 如果导致异常是 SQLException，则如果以 23 开始，则会检查 SQLState。
  • 如果原因的例外是 DataIntegrityViolationException
  • 如果导致异常类名称的名称的名称中包含 "ConstraintViolation"。
  • 如果已经配置了任何类名称，则对 FQN 类名称进行可选检查

您可以添加 FQN 类名，如果任何原因异常（或任何嵌套）等于任何 FQN 类名称，然后是最佳锁定错误。

下面是一个示例，我们从 JDBC 供应商定义 2 个额外的 FQN 类名称： 

<bean id="repo"
class="org.apache.camel.processor.aggregate.jdbc.JdbcAggregationRepository">
  <property name="transactionManager" ref="transactionManager"/>
  <property name="repositoryName" value="aggregation"/>
  <property name="dataSource" ref="dataSource"/>
  <property name="jdbcOptimisticLockingExceptionMapper" ref="myExceptionMapper"/>
</bean>
<!-- use the default mapper with extraFQN class names from our JDBC driver -->
<bean id="myExceptionMapper" class="org.apache.camel.processor.aggregate.jdbc.DefaultJdbcOptimisticLockingExceptionMapper">
  <property name="classNames">
    <util:set>
      <value>com.foo.sql.MyViolationExceptoion</value>
      <value>com.foo.sql.MyOtherViolationExceptoion</value>
    </util:set>
  </property>
</bean>
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务，以及可以信赖的内容，帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

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

關於紅帽

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

Theme

© 2026 Red Hat返回顶部