38.2. 如何实施组件

概述

本节概述了实施自定义 Apache Camel 组件所需的步骤。

您需要实施哪些接口?

在实施组件时,通常需要实现以下 Java 接口:

  • org.apache.camel.Component
  • org.apache.camel.Endpoint
  • org.apache.camel.Consumer
  • org.apache.camel.Producer

另外,还需要实现以下 Java 接口:

  • org.apache.camel.Exchange
  • org.apache.camel.Message

实施步骤

您通常实现自定义组件,如下所示:

  1. 实现组件接口 mvapich-criuA 组件对象充当端点工厂。您可以扩展 DefaultComponent 类,并实现 createEndpoint () 方法。

    请参阅 第 39 章 组件接口

  2. 实施 Endpoint 接口 categories-wagonAn 端点代表由特定 URI 标识的资源。实施端点时采取的方法取决于消费者是否遵循 事件驱动的 模式、调度的轮询 模式还是 轮询 模式。 对于事件驱动的模式,通过扩展 DefaultEndpoint 类并实施以下方法来实现端点:

    • createProducer()
    • createConsumer()

      对于调度的轮询模式,通过扩展 ScheduledPollEndpoint 类并实施以下方法来实现端点:

    • createProducer()
    • createConsumer()

      对于轮询模式,通过扩展 DefaultPollingEndpoint 类并实施以下方法来实现端点:

    • createProducer()
    • createPollConsumer()

      请参阅 第 40 章 端点接口

  3. 根据您需要 实施 的模式(事件驱动的、调度轮询或轮询),您可以采用一些不同的方法来实现消费者。对于确定用于处理消息交换的线程模型,消费者实施也非常重要。

    请参阅 第 41.2 节 “实施 Consumer 接口”

  4. 实施 Producer 接口 criu- iwlTo 实施生成者,您可以扩展 DefaultProducer 类并实施 process () 方法。

    请参阅 第 42 章 生成者接口

  5. (可选)实施 Exchange 或 Message 接口 iwl- iwl。Exchange 的默认实现和 Message 可以直接使用,但偶尔您可能会发现自定义这些类型所必需的。

    请参阅 第 43 章 Exchange Interface第 44 章 消息接口

安装和配置组件

您可以使用以下方法之一安装自定义组件:

  • 将组件直接添加到 CamelContext iwl - iwlThe CamelContext.addComponent () 方法,以编程方式添加组件程序。
  • 使用 Spring 配置 criu-MAPPINGThe 标准 Spring bean 元素添加 组件会创建一个组件实例。bean 的 id 属性隐式定义组件前缀。详情请查看 第 38.3.2 节 “配置组件”
  • 将 Apache Camel 配置为自动发现组件 mvapich -mvapichAuto-discovery,确保 Apache Camel 根据需要自动加载组件。详情请查看 第 38.3.1 节 “设置自动诊断”