46.4. 编程模型


概述

在 API 组件框架的上下文中,主要组件实施类派生自 org.apache.camel.util.component 软件包中的基本类。这些基本类定义了在实施组件时您可以(可选)覆盖的一些方法。在本节中,我们提供了这些方法的简要描述,以及如何在您自己的组件实施中使用它们。

要实现的组件方法

除了生成的方法实现(通常不需要修改)外,您还可以选择性地覆盖 组件 类中的一些方法:

doStart()
(可选) 在冷启动时为组件创建资源的回调。另一种方法是采用 lazy 初始化 策略(仅在需要资源时创建资源)。实际上,lazy 初始化通常是最佳策略,因此通常不需要 doStart 方法。
doStop()

(可选) 在组件停止时调用代码的回调。停止组件意味着其所有资源都已关闭,内部状态会被删除,缓存将被清除,以此类推。

注意

Camel 保证在当前 CamelContext 关闭时 始终 调用 doStop,即使对应的 doStart 没有被调用。

doShutdown
(可选)CamelContext 关闭时调用代码的回调。虽然可以重启停止的组件(使用冷启动语义),但关闭的组件完全完成。因此,这个回调代表释放任何属于组件的资源的最后一个机会。

在组件类中实施的其他方法?

组件 类是保存对组件对象本身相同(或类似)生命周期的对象的自然位置。例如,如果组件使用 OAuth 安全性,则自然会拥有对 组件 类中所需 OAuth 对象的引用,并在 组件 类中定义方法以创建 OAuth 对象。

要实现的端点方法

您可以修改一些生成的方法,并选择性地覆盖 Endpoint 类中的一些继承方法,如下所示:

afterConfigureProperties()

此方法中需要做的主要事项是创建适当的代理类(API 类),以匹配 API 名称。API 名称(已从端点 URI 中提取)可通过继承的 apiName 字段或通过 getApiName accessor 提供。通常,您将在 apiName 字段中进行切换来创建对应的代理类。例如:

// Java
private Object apiProxy;
...
@Override
protected void afterConfigureProperties() {
    // TODO create API proxy, set connection properties, etc.
    switch (apiName) {
        case HELLO_FILE:
            apiProxy = new ExampleFileHello();
            break;
        case HELLO_JAVADOC:
            apiProxy = new ExampleJavadocHello();
            break;
        default:
            throw new IllegalArgumentException("Invalid API name " + apiName);
    }
}
getApiProxy (ApiMethod method, Map<String, Object> args)

覆盖此方法,以返回您在 afterConfigureProperties 中创建的代理实例。例如:

@Override
public Object getApiProxy(ApiMethod method, Map<String, Object> args) {
    return apiProxy;
}

特殊情况下,您可能想要选择代理取决于 API 方法和参数。如果需要,getApiProxy 为您提供了采用这种方法的灵活性。

doStart()
(可选) 在冷启动期间创建资源的回调。具有与 Component.doStart () 相同的语义。
doStop()
(可选) 在组件停止时调用代码的回调。具有与 Component.doStop () 相同的语义。
doShutdown
(可选) 在组件关闭时调用代码的回调。具有与 Component.doShutdown () 相同的语义。
interceptPropertyNames (Set<String> propertyNames)

(可选) API 组件框架使用端点 URI 和提供的选项值来确定要调用的方法(可能源自于过载和别名)。但是,如果组件内部添加了选项或方法参数,框架可能需要帮助来确定要调用的正确方法。在这种情况下,您必须覆盖 interceptPropertyNames 方法,并将额外的(隐藏或隐式)选项添加到 propertyNames 设置中。在 propertyNames 集合中提供了 method 参数的完整列表,框架将能够识别要调用的正确方法。

注意

您可以在 EndpointProducerConsumer 类的级别覆盖此方法。基本规则是,如果选项 同时 影响制作者端点和消费者端点,则覆盖 Endpoint 类中的方法。

interceptProperties (Map<String,Object> properties)

(可选) 通过覆盖这个方法,您可以在调用 API 方法前修改或设置选项的实际值。例如,如果需要,您可以使用此方法为某些选项设置默认值。在实践中,通常需要覆盖 intercept Property Names 方法和 interceptProperty 方法。

注意

您可以在 EndpointProducerConsumer 类的级别覆盖此方法。基本规则是,如果选项 同时 影响制作者端点和消费者端点,则覆盖 Endpoint 类中的方法。

要实现的消费者方法

您可以选择覆盖 Consumer 类中的一些继承方法,如下所示:

interceptPropertyNames (Set<String> propertyNames)
(可选) 这个方法的语义与 Endpoint.interceptPropertyNames类似
interceptProperties (Map<String,Object> properties)
(可选) 这个方法的语义与 Endpoint.interceptProperties类似
doInvokeMethod (Map<String, Object> args)

(可选) 覆盖这个方法可让您截获 Java API 方法的调用。覆盖此方法的最常见原因是围绕方法调用自定义错误处理。例如,以下代码片段中显示了覆盖 doInvokeMethod 的典型方法:

// Java
@Override
protected Object doInvokeMethod(Map<String, Object> args) {
    try {
        return super.doInvokeMethod(args);
    } catch (RuntimeCamelException e) {
        // TODO - Insert custom error handling here!
        ...
    }
}

在此实施中,您应该在 super-class 上调用 doInvokeMethod,以确保 Java API 方法被调用。

interceptResult (Object methodResult, Exchange resultExchange)
(可选) 对 API 方法调用的结果进行一些额外的处理。例如,您可以在 Camel Exchange 对象中添加自定义标头,此时 resultExchange
object splitResult (Object result)

(可选) 默认情况下,如果方法 API 调用的结果是 java.util.Collection 对象或 Java 数组,API 组件框架会将结果分成多个交换对象(因此单个调用结果将转换为多个消息)。

如果要更改默认的行为,您可以覆盖消费者端点中的 splitResult 方法。result 参数包含 API 消息调用的结果。如果要分割结果,您应该返回数组类型。

注意

您还可以通过在端点 URI 中设置 consumer.splitResult=false 来关闭默认分割行为。

要实施的制作者方法

您可以选择覆盖 Producer 类中的一些继承方法,如下所示:

interceptPropertyNames (Set<String> propertyNames)
(可选) 这个方法的语义与 Endpoint.interceptPropertyNames类似
interceptProperties (Map<String,Object> properties)
(可选) 这个方法的语义与 Endpoint.interceptProperties类似
doInvokeMethod (Map<String, Object> args)
(可选) 这个方法的语义与 Consumer.doInvokeMethod 类似。
interceptResult (Object methodResult, Exchange resultExchange)
(可选) 这个方法的语义与 Consumer.interceptResult 类似。
注意

Producer.splitResult () 方法 不会被 调用,因此无法分割 API 方法的结果与消费者端点相同。要获得与生成者端点类似的效果,您可以使用 Camel 的 split () DSL 命令(标准企业集成模式之一)来分割 集合 或数组结果。

消费者轮询和线程模型

API 组件框架中消费者端点的默认线程模型 已调度轮询消费者。这意味着,消费者端点中的 API 方法会定期调用,调度的时间间隔。如需了解更多详细信息,请参阅 “调度的轮询消费者实施”一节

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

© 2024 Red Hat, Inc.