39.2. 实施组件接口

您可以通过扩展 org.apache.camel.impl.DefaultComponent 类来实施新的组件，该类为某些方法提供了一些标准功能和默认实施。特别是，DefaultComponent 类支持 URI 解析和创建 调度的 executor （用于调度的轮询模式）。

基本组件接口中定义的 createEndpoint(String uri) 方法使用一个完整的、未解析的端点 URI，作为其唯一参数。另一方面，DefaultComponent 类定义了带有以下签名的 createEndpoint（） 方法的三参数版本：

protected abstract Endpoint createEndpoint(
    String uri,
    String remaining,
    Map parameters
)
throws Exception;

URI 是原始的、未解析的 URI； 剩余的 是 URI 的一部分，该 URI 在开始剥离组件前缀后，并削减查询选项末尾的查询选项； 参数 包含解析的查询选项。这是从 DefaultComponent 继承时必须覆盖的 createEndpoint（） 方法的这个版本。具有已为您解析端点 URI 的优点。

以下文件组件的端点 URI 示例显示了 URI 解析在实践中如何工作：

file:///tmp/messages/foo?delete=true&moveNamePostfix=.old

对于此 URI，以下参数将传递给 createEndpoint（） 的三参数版本：

默认情况下，从 URI 查询选项中提取的参数会在端点的 bean 属性中注入。DefaultComponent 类会自动注入您的参数。

例如，如果要定义支持两个 URI 查询选项的自定义端点： delete 和 moveName Postfix。您必须执行的所有操作是在端点类中定义对应的 bean 方法（getter 和 setters）：

public class FileEndpoint extends ScheduledPollEndpoint {
    ...
    public boolean isDelete() {
        return delete;
    }
    public void setDelete(boolean delete) {
        this.delete = delete;
    }
    ...
    public String getMoveNamePostfix() {
        return moveNamePostfix;
    }
    public void setMoveNamePostfix(String moveNamePostfix) {
        this.moveNamePostfix = moveNamePostfix;
    }
}

也可以将 URI 查询选项注入 消费者 参数。详情请查看 “consumer 参数注入”一节。

如果您的 Endpoint 类上没有定义参数，您可以通过禁用端点参数注入来优化端点创建过程。要在端点中禁用参数注入，请覆盖 useIntrospectionOnEndpoint（） 方法并把它返回 false，如下所示：

protected boolean useIntrospectionOnEndpoint() {
  return false;
}

调度的 executor 在调度的轮询模式中使用，该模式负责推动消费者端点的定期轮询（调度的 executor 实际上是线程池实施）。

要实例化调度的 executor 服务，请使用 CamelContext.getExecutorServiceStrategy（） 方法返回的 ExecutorServiceStrategy 对象。有关 Apache Camel 线程模型的详情，请参考 第 2.8 节 “线程模型”。

如果要在创建端点实例前验证 URI，您可以覆盖 DefaultComponent 类中的 validateURI（） 方法，该类具有以下签名：

protected void validateURI(String uri,
                           String path,
                           Map parameters)
   throws ResolveEndpointFailedException;

如果提供的 URI 没有所需格式，则 validateURI（） 的实施应抛出 org.apache.camel.ResolveEndpointFailedException 异常。

例 39.2 “createEndpoint（）的实现” 概述了如何实施 DefaultComponent.createEndpoint（） 方法，它负责根据需要创建端点实例。

public class CustomComponent extends DefaultComponent { 1
    ...
    protected Endpoint createEndpoint(String uri, String remaining, Map parameters) throws Exception { 2
        CustomEndpoint result = new CustomEndpoint(uri, this); 3
        // ...
        return result;
    }
}

例 39.3 “文件编译实施” 显示了一个 FileComponent 类实施示例。

package org.apache.camel.component.file;

import org.apache.camel.CamelContext;
import org.apache.camel.Endpoint;
import org.apache.camel.impl.DefaultComponent;

import java.io.File;
import java.util.Map;

public class FileComponent extends DefaultComponent {
    public static final String HEADER_FILE_NAME = "org.apache.camel.file.name";

    public FileComponent() { 1
    }

    public FileComponent(CamelContext context) { 2
        super(context);
    }

    protected Endpoint createEndpoint(String uri, String remaining, Map parameters) throws Exception { 3
        File file = new File(remaining);
        FileEndpoint result = new FileEndpoint(file, uri, this);
        return result;
    }
}

SynchronizationRouteAware 接口允许您在交换之前和路由后具有回调。