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 的一部分，并去除结尾的查询选项，而 参数 包含解析的查询选项。这是从 DefaultComponent 继承时必须覆盖的 createEndpoint （） 方法的版本。它具有已为您解析端点 URI 的优点。

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

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

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

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

例如，如果要定义支持两个 URI 查询选项的自定义端点： delete 和 moveNamePostfix。所有这些都必须在端点类中定义对应的 bean 方法(getters 和 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 查询选项注入 消费者 参数。详情请查看 “消费者参数注入”一节。

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

protected boolean useIntrospectionOnEndpoint() {
  return false;
}

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

要实例化调度的 executor 服务，请使用 CamelContext.get ExecutorServiceStrategy 方法返回的 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 Implementation” 显示 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 接口允许您在交换路由之前和之后具有回调。