2.6. 转换消息内容

摘要

Apache Camel 支持各种转换消息内容的方法。除了修改消息内容的简单原生 API 外，Apache Camel 还支持与几个不同的第三方库和转换标准集成。

2.6.1. 简单消息转换

概述

Java DSL 具有内置 API，允许您对传入和传出消息执行简单的转换。例如，例 2.1 “简单的 Incoming 信息转换” 中显示的规则会将文本 World! 附加到传入消息正文的末尾。

例 2.1. 简单的 Incoming 信息转换

from("SourceURL").setBody(body().append(" World!")).to("TargetURL");

其中 setBody （） 命令取代了传入消息正文的内容。

API 用于简单转换

您可以使用以下 API 类在路由器规则中执行消息内容的简单转换：

org.apache.camel.model.ProcessorDefinition
org.apache.camel.builder.Builder
org.apache.camel.builder.ValueBuilder

ProcessorDefinition 类

org.apache.camel.model.ProcessorDefinition 类定义了 DSL 命令，您可以直接插入到路由器 rule CamelAwsS-DESTINATIONfor，例如例 2.1 “简单的 Incoming 信息转换” 中的 setBody （） 命令。表 2.5 “从 ProcessorDefinition 类转换方法” 显示与转换消息内容相关的 ProcessorDefinition 方法：

表 2.5. 从 ProcessorDefinition 类转换方法
方法	描述
`Type convertBodyTo(Class type)`	将 IN 消息正文转换为指定类型。
`type removeFaultHeader (String name)`	添加一个处理器，删除 FAULT 消息中的标头。
`type removeHeader (String name)`	添加一个处理器，用于删除 IN 消息中的标头。
`type removeProperty (String name)`	添加删除交换属性的处理器。
`ExpressionClause<ProcessorDefinition<Type>> setBody()`	添加在 IN 消息上设置正文的处理器。
`类型 setFaultBody (Expression expression)`	添加在 FAULT 消息上设置正文的处理器。
`类型 setFaultHeader (String name, Expression expression)`	添加在 FAULT 消息上设置标头的处理器。
`ExpressionClause<ProcessorDefinition<Type>> setHeader (String name)`	添加在 IN 消息上设置标头的处理器。
`类型 setHeader (String name, Expression expression)`	添加在 IN 消息上设置标头的处理器。
`ExpressionClause<ProcessorDefinition<Type>> setOutHeader (String name)`	添加在 OUT 消息上设置标头的处理器。
`类型 setOutHeader (String name, Expression expression)`	添加在 OUT 消息上设置标头的处理器。
`ExpressionClause<ProcessorDefinition<Type>> setProperty (String name)`	添加设置 Exchange 属性的处理器。
`type setProperty (String name, Expression expression)`	添加设置 Exchange 属性的处理器。
`ExpressionClause<ProcessorDefinition<Type>> transform()`	添加在 OUT 消息上设置正文的处理器。
`类型转换(Expression expression)`	添加在 OUT 消息上设置正文的处理器。

builder 类

org.apache.camel.builder.Builder 类提供对预期表达式或 predicates 的上下文中的消息内容的访问。换句话说，Builder 方法通常在 DSL 命令的参数 中调用，例如：例 2.1 “简单的 Incoming 信息转换” 中的 body （） 命令。表 2.6 “Builder 类中的方法” 总结了 Builder 类中可用的静态方法。

表 2.6. Builder 类中的方法
方法	描述
`静态 <E 扩展 Exchange> ValueBuilder<E> body （）`	为交换上入站正文返回 predicate 和值构建器。
`静态 <E 扩展 Exchange,T> ValueBuilder<E> bodyAs (Class<T> type)`	返回入站消息正文的 predicate 和 value builder 作为特定类型的类型。
`静态 <E 扩展 Exchange> ValueBuilder<E> constant (Object value)`	返回常量表达式。
`静态 <E 扩展 Exchange> ValueBuilder<E> faultBody （）`	为交换上的错误正文返回 predicate 和值构建器。
`静态 <E extends Exchange,T> ValueBuilder<E> faultBodyAs (Class<T> type)`	返回 fault 消息正文的 predicate 和 value builder 作为特定类型。
`静态 <E 扩展 Exchange> ValueBuilder<E> 标头(String name)`	返回交换上标头的 predicate 和值构建器。
`静态 <E 扩展 Exchange> ValueBuilder<E> outBody （）`	返回交换上出站正文的 predicate 和值构建器。
`静态 <E extends Exchange> ValueBuilder<E> outBodyAs (Class<T> type)`	返回出站消息正文的 predicate 和 value builder 作为特定类型。
`static ValueBuilder 属性(String name)`	返回交换上属性的 predicate 和值构建器。
`静态值Builder regexReplaceAll (Expression 内容, String regex, Expression replacement)`	返回一个表达式，用给定的替换替换所有正则表达式。
`静态值Builder regexReplaceAll (Expression 内容, String regex, String replacement)`	返回一个表达式，用给定的替换替换所有正则表达式。
`静态 ValueBuilder sendTo (String uri)`	将一个表达式处理返回给给定端点 uri。
`静态 <E extends Exchange> ValueBuilder<E> systemProperty (String name)`	返回给定系统属性的表达式。
`静态 <E 扩展 Exchange> ValueBuilder<E> systemProperty (String name, String defaultValue)`	返回给定系统属性的表达式。

ValueBuilder 类

org.apache.camel.builder.ValueBuilder 类允许您修改 Builder 方法返回的值。换句话说，ValueBuilder 中的方法提供了修改消息内容的简单方法。表 2.7 “ValueBuilder 类中的修饰符方法” 总结了 ValueBuilder 类中可用的方法。也就是说，表中仅显示用于修改调用它们的值的方法（更多详情，请参阅 API 参考文档 ）。

表 2.7. ValueBuilder 类中的修饰符方法
方法	描述
`ValueBuilder<E> append (Object value)`	使用给定值附加此表达式的字符串评估。
`predicate contains (Object value)`	创建一个 predicate，左手表达式包含右手表达式的值。
`ValueBuilder<E> convertTo(Class type)`	使用注册的类型转换器将当前值转换为给定的类型。
`ValueBuilder<E> convertToString()`	使用注册的类型转换器转换字符串。
`predicate endWith (Object value)`
`<T> T evaluate (Exchange Exchange, Class<T> 类型)`
`predicate in (Object… values)`
`predicate in (Predicate… predicates)`
`predicate isEqualTo (Object value)`	如果当前值等于给定 `值` 参数，则返回 true。
`predicate isGreaterThan (Object value)`	如果当前值大于给定 `值` 参数，则返回 true。
`predicate isGreaterThanOrEqualTo (Object value)`	如果当前值大于或等于给定 `值` 参数，则返回 true。
`predicate isInstanceOf (Class type)`	如果当前值是给定类型的实例，则返回 true。
`predicate isLessThan (Object value)`	如果当前值小于给定 `值` 参数，则返回 true。
`predicate isLessThanOrEqualTo (Object value)`	如果当前值小于或等于给定 `值` 参数，则返回 true。
`predicate isNotEqualTo (Object value)`	如果当前值不等于给定 `值` 参数，则返回 true。
`Predicate isNotNull()`	如果当前值不是 `null`，则返回 true。
`predicate isNull （）`	如果当前值为 `null`，则返回 true。
`predicate match (Expression expression)`
`predicate not (Predicate predicate)`	对 predicate 参数进行求值。
`ValueBuilder prepend (Object value)`	将这个表达式的字符串评估添加到给定值。
`predicate regex (String regex)`
`ValueBuilder<E> regexReplaceAll (String regex, Expression<E> replacement)`	使用给定的替换替换正则表达式的所有发生情况。
`ValueBuilder<E> regexReplaceAll(String regex, String replacement)`	使用给定的替换替换正则表达式的所有发生情况。
`ValueBuilder<E> regexTokenize (String regex)`	使用给定的正则表达式调整此表达式的字符串转换。
`ValueBuilder sort(Comparator comparator)`	使用给定的比较器对当前值进行排序。
`predicate startWith (Object value)`	如果当前值与 `value` 参数的字符串值匹配，则返回 true。
`ValueBuilder<E> tokenize()`	使用逗号令牌分隔符调整此表达式的字符串转换。
`ValueBuilder<E> tokenize (String token)`	使用给定令牌分隔符调整此表达式的字符串转换。

2.6.2. Marshalling 和 Unmarshalling

Java DSL 命令

您可以使用以下命令在低级和高级别消息格式间转换：

marshal （） criu-criu 将高级别数据格式转换为低级数据格式。
unmarshal（）criu-criu 将低级数据格式转换为高级别的数据格式。

数据格式

Apache Camel 支持以下数据格式的 marshalling 和 unmarshalling：

Java 序列化
JAXB
XMLBeans
XStream

Java 序列化

允许您将 Java 对象转换为二进制数据的 Blob。对于此数据格式，unmarshalling 将二进制 blob 转换为 Java 对象，marshalling 将 Java 对象转换为二进制 blob。例如，要从端点 SourceURL 读取序列化 Java 对象，并将其转换为 Java 对象，您可以使用类似如下的规则：

from("SourceURL").unmarshal().serialization()
.<FurtherProcessing>.to("TargetURL");

或者，在 Spring XML 中：

<camelContext id="serialization" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="SourceURL"/>
    <unmarshal>
      <serialization/>
    </unmarshal>
    <to uri="TargetURL"/>
  </route>
</camelContext>

JAXB

提供 XML 模式类型和 Java 类型之间的映射（请参阅 https://jaxb.dev.java.net/）。对于 JAXB，unmarshalling 将 XML 数据类型转换为 Java 对象，marshalling 将 Java 对象转换为 XML 数据类型。在使用 JAXB 数据格式之前，您必须使用 JAXB 编译器生成 Java 类（在架构中表示 XML 数据类型）编译 XML 模式。这称为绑定 schema。绑定架构后，您可以使用类似如下的代码将 unmarshal XML 数据的规则定义为 Java 对象：

org.apache.camel.spi.DataFormat jaxb = new org.apache.camel.model.dataformat.JaxbDataFormat("GeneratedPackageName");

from("SourceURL").unmarshal(jaxb)
.<FurtherProcessing>.to("TargetURL");

其中 GeneratedPackagename 是 JAXB 编译器生成的 Java 软件包的名称，其中包含代表 XML 模式的 Java 类。

或者，在 Spring XML 中：

<camelContext id="jaxb" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="SourceURL"/>
    <unmarshal>
      <jaxb prettyPrint="true" contextPath="GeneratedPackageName"/>
    </unmarshal>
    <to uri="TargetURL"/>
  </route>
</camelContext>

XMLBeans

提供 XML 模式类型和 Java 类型之间的替代映射（请参阅 http://xmlbeans.apache.org/）。对于 XMLBeans，unmarshalling 将 XML 数据类型转换为 Java 对象，marshalling 将 Java 对象转换为 XML 数据类型。例如，要使用 XMLBeans 将 XML 数据到 Java 对象，您可以使用类似如下的代码：

from("SourceURL").unmarshal().xmlBeans()
.<FurtherProcessing>.to("TargetURL");

或者，在 Spring XML 中：

<camelContext id="xmlBeans" xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="SourceURL"/>
    <unmarshal>
      <xmlBeans prettyPrint="true"/>
    </unmarshal>
    <to uri="TargetURL"/>
  </route>
</camelContext>

XStream

提供 XML 类型和 Java 类型之间的另一个映射（请参阅 http://www.xml.com/pub/a/2004/08/18/xstream.html）。xstream 是一个序列化库（如 Java 序列化），可让您将任何 Java 对象转换为 XML。对于 XStream，unmarshalling 将 XML 数据类型转换为 Java 对象，marshalling 将 Java 对象转换为 XML 数据类型。

from("SourceURL").unmarshal().xstream()
.<FurtherProcessing>.to("TargetURL");

注意

Spring XML 目前不支持 XStream 数据格式。

2.6.3. 端点绑定

什么是绑定？

在 Apache Camel 中，绑定是通过应用数据格式、Content Enricher 或验证步骤来嵌套端点的方法，例如：应用数据格式、内容丰富或验证步骤。条件或转换应用于来自的消息，互补条件或转换将应用到消息。

DataFormatBinding

DataFormatBinding 类对于您要定义特定数据格式的绑定的具体情况很有用（请参阅第 2.6.2 节 “Marshalling 和 Unmarshalling”）。在这种情况下，您需要创建绑定的所有操作都是创建一个 DataFormatBinding 实例，在构造器中传递对相关数据格式的引用。

例如，例 2.2 “JAXB Binding” 中的 XML DSL 片段显示一个绑定（带有 ID，jaxb），它能够在与 Apache Camel 端点关联时对 JAXB 数据格式进行 marshalling 和 unmarshalling the JAXB 数据格式：

例 2.2. JAXB Binding

<beans ... >
    ...
    <bean id="jaxb" class="org.apache.camel.processor.binding.DataFormatBinding">
        <constructor-arg ref="jaxbformat"/>
    </bean>

    <bean id="jaxbformat" class="org.apache.camel.model.dataformat.JaxbDataFormat">
        <property name="prettyPrint" value="true"/>
        <property name="contextPath" value="org.apache.camel.example"/>
    </bean>

</beans>

将绑定与端点关联

以下替代方案可用于将绑定与端点关联：

绑定 URI

要将绑定与端点关联，您可以将端点 URI 与 绑定前缀：NameOfBinding，其中 NameOfBinding 是绑定的 bean ID （例如，在 Spring XML 中创建的绑定 bean ID）。

例如，以下示例演示了如何将 ActiveMQ 端点与例 2.2 “JAXB Binding” 中定义的 JAXB 绑定关联。

<beans ...>
    ...
    <camelContext xmlns="http://camel.apache.org/schema/spring">
        <route>
            <from uri="binding:jaxb:activemq:orderQueue"/>
            <to uri="binding:jaxb:activemq:otherQueue"/>
        </route>
    </camelContext>
    ...
</beans>

BindingComponent

您可以不将前缀与端点关联，而是让关联隐式，以便绑定不需要出现在 URI 中。对于没有隐式绑定的现有端点，实现此操作的最简单方法是使用 BindingComponent 类来嵌套端点。

例如，要将 jaxb 绑定与 activemq 端点关联，您可以定义一个新的 BindingComponent 实例，如下所示：

<beans ... >
    ...
    <bean id="jaxbmq" class="org.apache.camel.component.binding.BindingComponent">
        <constructor-arg ref="jaxb"/>
        <constructor-arg value="activemq:foo."/>
    </bean>

    <bean id="jaxb" class="org.apache.camel.processor.binding.DataFormatBinding">
        <constructor-arg ref="jaxbformat"/>
    </bean>

    <bean id="jaxbformat" class="org.apache.camel.model.dataformat.JaxbDataFormat">
        <property name="prettyPrint" value="true"/>
        <property name="contextPath" value="org.apache.camel.example"/>
    </bean>

</beans>

（可选） jaxbmq 的第二个构造器参数定义 URI 前缀。现在，您可以使用 jaxbmq ID 作为端点 URI 的方案。例如，您可以使用此绑定组件定义以下路由：

<beans ...>
    ...
    <camelContext xmlns="http://camel.apache.org/schema/spring">
        <route>
            <from uri="jaxbmq:firstQueue"/>
            <to uri="jaxbmq:otherQueue"/>
        </route>
    </camelContext>
    ...
</beans>

前面的路由等同于以下路由，它使用绑定 URI 方法：

<beans ...>
    ...
    <camelContext xmlns="http://camel.apache.org/schema/spring">
        <route>
            <from uri="binding:jaxb:activemq:foo.firstQueue"/>
            <to uri="binding:jaxb:activemq:foo.otherQueue"/>
        </route>
    </camelContext>
    ...
</beans>

注意

对于实现自定义 Apache Camel 组件的开发人员，可以通过实施从 org.apache.camel.spi.HasBinding 接口继承的端点类来实现此目的。

BindingComponent constructors

BindingComponent 类支持以下构造器：

public BindingComponent(): 无参数形式。使用属性注入来配置绑定组件实例。
public BindingComponent (Binding binding): 将此绑定组件与指定的 Binding 对象关联，绑定。
public BindingComponent (Binding binding, String uriPrefix): 将此绑定组件与指定的 Binding 对象、绑定和 URI 前缀( uriPrefix )关联。这是最常用的构造器。
public BindingComponent (Binding binding, String uriPrefix, String uriPostfix): 此构造器支持额外的 URI post-fix, uriPostfix, 参数，该参数会自动附加到使用此绑定组件定义的任何 URI 中。

实现自定义绑定

除了 DataFormatBinding 外，它用于 marshalling 和 unmarshalling 数据格式，您可以实施自己的自定义绑定。定义自定义绑定，如下所示：

实施 org.apache.camel.Processor 类，对传入消费者端点的消息执行转换( 从 元素应用)。
实施补充 org.apache.camel.Processor 类，对来自制作者端点的消息执行反向转换( 应用到 元素)。
实施 org.apache.camel.spi.Binding 接口，该接口充当处理器实例的工厂。

绑定接口

例 2.3 “org.apache.camel.spi.Binding 接口” 显示 org.apache.camel.spi.Binding 接口的定义，您必须实施该接口来定义自定义绑定。

例 2.3. org.apache.camel.spi.Binding 接口

// Java
package org.apache.camel.spi;

import org.apache.camel.Processor;

/**
 * Represents a <a href="http://camel.apache.org/binding.html">Binding</a> or contract
 * which can be applied to an Endpoint; such as ensuring that a particular
 * <a href="http://camel.apache.org/data-format.html">Data Format</a> is used on messages in and out of an endpoint.
 */
public interface Binding {

    /**
     * Returns a new {@link Processor} which is used by a producer on an endpoint to implement
     * the producer side binding before the message is sent to the underlying endpoint.
     */
    Processor createProduceProcessor();

    /**
     * Returns a new {@link Processor} which is used by a consumer on an endpoint to process the
     * message with the binding before its passed to the endpoint consumer producer.
     */
    Processor createConsumeProcessor();
}

何时使用绑定

当您需要将相同转换应用到许多不同类型的端点时，绑定很有用。

2.6. 转换消息内容

2.6.1. 简单消息转换

概述

API 用于简单转换

ProcessorDefinition 类

builder 类

ValueBuilder 类

2.6.2. Marshalling 和 Unmarshalling

Java DSL 命令

数据格式

Java 序列化

JAXB

XMLBeans

XStream

2.6.3. 端点绑定

什么是绑定？

DataFormatBinding

将绑定与端点关联

绑定 URI

BindingComponent

BindingComponent constructors

实现自定义绑定

绑定接口

何时使用绑定

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Red Hat legal and privacy links

Red Hat legal and privacy links