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)
);
Copy to Clipboard Toggle word wrap

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

<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>
Copy to Clipboard Toggle word wrap

326.15.1. codec (Serialization)
复制链接

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

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

326.15.2. Transactions
复制链接

需要 Spring PlatformTransactionManager 来编配事务。

326.15.2.1. Service (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>
Copy to Clipboard Toggle word wrap

326.15.4. Optimistic locking
复制链接

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

以下检查已完成：

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

您还可以添加 FQN 类名称，如果任何原因异常（或任何嵌套）等于任何 FQN 类名称，则其 optimistick 锁定错误。

例如，我们从 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>
Copy to Clipboard Toggle word wrap
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

Theme

© 2025 Red Hat