13.2. 如何检查表达式语言

先决条件

在可以使用特定的表达式语言前,您必须确保 classpath 上有所需的 JAR 文件。如果 Apache Camel 核心中没有包括您要使用的语言,您必须将相关的 JAR 添加到您的类路径中。

如果使用 Maven 构建系统,只需将相关依赖项添加到 POM 文件即可修改构建时类路径。例如,如果您使用 Ruby 语言,请在您的 POM 文件中添加以下依赖项:

<dependency>
  <groupId>org.apache.camel</groupId>
  <artifactId>camel-groovy</artifactId>
  <!-- Use the same version as your Camel core version -->
  <version>${camel.version}</version>
</dependency>

如果要在红帽 Fuse OSGi 容器中部署应用程序,您还需要确保安装了相关的语言功能(功能在相应的 Maven 工件后被命名)。例如,若要在 OSGi 容器中使用 Groovy 语言,您必须首先通过输入以下 OSGi 控制台来安装 camel-groovy 功能:

karaf@root> features:install camel-groovy
注意

如果您在路由中使用表达式或 predicate,请使用 resource:classpath:pathresource: path 来引用值作为外部资源。例如,resource:classpath:com/foo/myscript.groovy

EAP 部署上的 Camel

camel-groovy 组件由 Camel on EAP(Wildfly Camel)框架支持,它在红帽 JBoss 企业应用平台(JBoss EAP)容器上提供了简化的部署模型。

调用方法

表 13.1 “表达式和优先级语言” 所示,根据所使用的上下文,调用表达式语言有几种不同的语法。您可以调用表达式语言:

作为静态方法

大多数语言都定义了静态方法,可在任何 上下文中使用 org.apache.camel.Expression 类型或 org.apache.camel.Predicate 类型是正常的。静态方法使用字符串表达式(或 predicate)作为其参数,并返回 Expression 对象(通常是一个 Predicate 对象)。

例如,要实施基于内容的路由器以 XML 格式处理消息,您可以根据 /order/address/countryCode 元素的值路由消息,如下所示:

from("SourceURL")
  .choice
    .when(xpath("/order/address/countryCode = 'us'"))
      .to("file://countries/us/")
    .when(xpath("/order/address/countryCode = 'uk'"))
      .to("file://countries/uk/")
    .otherwise()
      .to("file://countries/other/")
  .to("TargetURL");

作为流畅的 DSL 方法

Java fluent DSL 支持另一种调用表达式语言。您可以将表达式作为 Enterprise Integration Pattern(EIP)的参数提供,而是作为 DSL 命令的子使用提供表达式。例如,不将 XPath 表达式作为 filter(xpath("Expression")) 调用,您可以将表达式称为 filter().xpath("Expression")

例如,前面的基于内容的路由器可以在这个调用中重新实施,如下所示:

from("SourceURL")
  .choice
    .when().xpath("/order/address/countryCode = 'us'")
      .to("file://countries/us/")
    .when().xpath("/order/address/countryCode = 'uk'")
      .to("file://countries/uk/")
    .otherwise()
      .to("file://countries/other/")
  .to("TargetURL");

作为 XML 元素

您还可以通过将表达式字符串放在相关的 XML 元素中,在 XML 中调用表达式语言。

例如,在 XML 中调用 XPath 的 XML 元素是 xpath (属于标准 Apache Camel 命名空间)。您可以在基于 XML DSL 内容的路由器中使用 XPath 表达式,如下所示:

<from uri="file://input/orders"/>
<choice>
  <when>
    <xpath>/order/address/countryCode = 'us'</xpath>
    <to uri="file://countries/us/"/>
  </when>
  <when>
    <xpath>/order/address/countryCode = 'uk'</xpath>
    <to uri="file://countries/uk/"/>
  </when>
  <otherwise>
    <to uri="file://countries/other/"/>
  </otherwise>
</choice>

或者,您可以使用 language 元素指定语言表达式,您可以在其中指定 language 属性中的语言名称。例如,您可以使用 语言 元素定义 XPath 表达式,如下所示:

<language language="xpath">/order/address/countryCode = 'us'</language>

作为注解

语言注释在 bean 集成的上下文中使用。该注释提供了一种便捷方式,用于从消息或标头提取信息,然后将提取的数据注入 bean 的方法解析器。

例如,请考虑 bean myBeanProc,它作为 filter() EIP 的 predicate 调用。如果 bean 的 checkCredentials 方法返回 true,则消息被允许继续;但如果方法返回 false,则消息会被阻止。过滤器模式实施如下:

// Java
MyBeanProcessor myBeanProc = new MyBeanProcessor();

from("SourceURL")
  .filter().method(myBeanProc, "checkCredentials")
  .to("TargetURL");

MyBeanProcessor 类的实现利用 @XPath 注释从基础 XML 消息中提取 用户名和密码 ,如下所示:

// Java
import org.apache.camel.language.XPath;

public class MyBeanProcessor {
    boolean void checkCredentials(
        @XPath("/credentials/username/text()") String user,
        @XPath("/credentials/password/text()") String pass
    ) {
        // Check the user/pass credentials...
        ...
    }
}

@XPath 注释放在它要注入的参数之前。请注意,XPath 表达式如何 显式 选择文本节点,方法是将 /text() 附加到路径中,这样可确保仅选择元素的内容,而不是包含标签。

作为 Camel 端点 URI

通过使用 Camel 语言组件,您可以在端点 URI 中调用支持的语言。有两种替代语法。

要调用存储在文件(或者由 Scheme定义的其他资源类型)中的语言脚本,请使用以下 URI 语法:

language://LanguageName:resource:Scheme:Location[?Options]

其中的方案可以是 file:classpath:http:

例如,以下路由从 classpath 中执行 mysimplescript.txt

from("direct:start")
  .to("language:simple:classpath:org/apache/camel/component/language/mysimplescript.txt")
  .to("mock:result");

要调用嵌入的语言脚本,请使用以下 URI 语法:

language://LanguageName[:Script][?Options]

例如,运行存储在 script 字符串中的 Simple 语言 脚本

String script = URLEncoder.encode("Hello ${body}", "UTF-8");
from("direct:start")
  .to("language:simple:" + script)
  .to("mock:result");

有关语言组件的详情,请参阅 Apache Camel 组件参考指南 中的 语言