Red Hat Summit 红帽全球峰会支持控制台（Console）开发人员开始试用联系人

40.2. 实施端点接口

实施端点的替代方法
复制链接

支持以下替代端点实现模式：

事件驱动的端点实现
复制链接

如果您的自定义端点符合事件驱动的模式（请参阅 第 38.1.3 节 “消费者模式和线程”），请通过扩展抽象类 org.apache.camel.impl.DefaultEndpoint 来实现，如 例 40.2 “实施 DefaultEndpoint” 所示。

例 40.2. 实施 DefaultEndpoint

import java.util.Map;
import java.util.concurrent.BlockingQueue;

import org.apache.camel.Component;
import org.apache.camel.Consumer;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultEndpoint;
import org.apache.camel.impl.DefaultExchange;

public class CustomEndpoint extends DefaultEndpoint {
1 


    public CustomEndpoint(String endpointUri, Component component) {
2 

        super(endpointUri, component);
        // Do any other initialization...
    }

    public Producer createProducer() throws Exception {
3 

        return new CustomProducer(this);
    }

    public Consumer createConsumer(Processor processor) throws Exception {
4 

        return new CustomConsumer(this, processor);
    }

    public boolean isSingleton() {
        return true;
    }

    // Implement the following methods, only if you need to set exchange properties.
    //
    public Exchange createExchange() {
5 

        return this.createExchange(getExchangePattern());
    }

    public Exchange createExchange(ExchangePattern pattern) {
        Exchange result = new DefaultExchange(getCamelContext(), pattern);
        // Set exchange properties
        ...
        return result;
    }
}
Copy to Clipboard Toggle word wrap
1
通过扩展 DefaultEndpoint 类，实施事件驱动的自定义端点 CustomEndpoint。
2
您必须至少有一个构造器，它采用端点 URI、endpointUri，以及父组件引用，组件 作为参数。
3
实施 createProducer （） 工厂方法来创建制作者端点。
4
实施 createConsumer （） factory 方法来创建事件驱动的消费者实例。
5
通常，不需要 覆盖 createExchange （） 方法。默认情况下，从 DefaultEndpoint 继承的实现会创建一个 DefaultExchange 对象，该对象可用于任何 Apache Camel 组件。如果您需要在 DefaultExchange 对象中初始化一些交换属性，请在此处覆盖 createExchange （） 方法，以添加交换属性设置。
重要

不要覆盖 createPollingConsumer （） 方法。

DefaultEndpoint 类提供以下方法的默认实现，您可能会在编写自定义端点代码时很有用：

  • getEndpointUri （） wagon-wagonReturns 端点 URI。
  • getCamelContext （） HEKETI-wagonReturns 对 CamelContext 的引用。
  • getComponent （） wagon- swigReturns 对父组件的引用。
  • createPollingConsumer （） HEKETI-wagonCreates a polling consumer。创建的轮询消费者的功能基于事件驱动的消费者。如果您覆盖事件驱动的消费者方法 createConsumer （），您将获得轮询消费者实施。
  • createExchange (Exchange e) HEKETI-wagonConverts the given Exchange 对象 e，将这个端点所需的类型改为此端点所需的类型。此方法使用覆盖的 createExchange （） 端点创建新端点。这可确保该方法也适用于自定义交换类型。

调度的轮询端点实现
复制链接

如果您的自定义端点符合调度的轮询模式（请参阅 第 38.1.3 节 “消费者模式和线程”），则通过从抽象类 org.apache.camel.impl.ScheduledPollEndpoint 继承来实现它，如 例 40.3 “ScheduledPollEndpoint 实现” 所示。

例 40.3. ScheduledPollEndpoint 实现

import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.ExchangePattern;
import org.apache.camel.Message;
import org.apache.camel.impl.ScheduledPollEndpoint;

public class CustomEndpoint extends ScheduledPollEndpoint {
1 


    protected CustomEndpoint(String endpointUri, CustomComponent component) {
2 

        super(endpointUri, component);
        // Do any other initialization...
    }

    public Producer createProducer() throws Exception {
3 

        Producer result = new CustomProducer(this);
        return result;
    }

    public Consumer createConsumer(Processor processor) throws Exception {
4 

        Consumer result = new CustomConsumer(this, processor);
        configureConsumer(result);
5 

        return result;
    }

    public boolean isSingleton() {
        return true;
    }

    // Implement the following methods, only if you need to set exchange properties.
    //
    public Exchange createExchange() {
6 

        return this.createExchange(getExchangePattern());
    }

    public Exchange createExchange(ExchangePattern pattern) {
        Exchange result = new DefaultExchange(getCamelContext(), pattern);
        // Set exchange properties
        ...
        return result;
    }
}
Copy to Clipboard Toggle word wrap
1
通过扩展 ScheduledPollEndpoint 类，实施计划轮询自定义端点 CustomEndpoint。
2
您必须至少有一个构造器，其使用端点 URI、endpointUri 和父组件引用，组件 作为参数。
3
实施 createProducer （） 工厂方法来创建制作者端点。
4
实施 createConsumer （） factory 方法来创建调度的轮询消费者实例。
5
ScheduledPollEndpoint 基本类中定义的 configureConsumer （） 方法负责将消费者查询选项注入消费者。请参阅 “消费者参数注入”一节。
6
通常，不需要 覆盖 createExchange （） 方法。默认情况下，从 DefaultEndpoint 继承的实现会创建一个 DefaultExchange 对象，该对象可用于任何 Apache Camel 组件。如果您需要在 DefaultExchange 对象中初始化一些交换属性，请在此处覆盖 createExchange （） 方法，以添加交换属性设置。
重要

不要覆盖 createPollingConsumer （） 方法。

轮询端点实施
复制链接

如果您的自定义端点符合轮询消费者模式（请参阅 第 38.1.3 节 “消费者模式和线程”），则通过继承抽象类 org.apache.camel.impl.DefaultPollingEndpoint 来实现，如 例 40.4 “DefaultPollingEndpoint 实现” 所示。

例 40.4. DefaultPollingEndpoint 实现

import org.apache.camel.Consumer;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.ExchangePattern;
import org.apache.camel.Message;
import org.apache.camel.impl.DefaultPollingEndpoint;

public class CustomEndpoint extends DefaultPollingEndpoint {
    ...
    public PollingConsumer createPollingConsumer() throws Exception {
        PollingConsumer result = new CustomConsumer(this);
        configureConsumer(result);
        return result;
    }

    // Do NOT implement createConsumer(). It is already implemented in DefaultPollingEndpoint.
    ...
}
Copy to Clipboard Toggle word wrap

由于此 CustomEndpoint 类是一个轮询端点，您必须实施 createPollingConsumer （） 方法，而不是 createConsumer （） 方法。从 createPollingConsumer （） 返回的消费者实例必须从 PollingConsumer 接口继承。有关如何实现轮询消费者的详情，请参考 “轮询消费者实施”一节。

除了 createPollingConsumer （） 方法的实现外，实施 DefaultPollingEndpoint 的步骤与实施 ScheduledPollEndpoint 的步骤类似。详情请查看 例 40.3 “ScheduledPollEndpoint 实现”。

实施 BrowsableEndpoint 接口
复制链接

如果要公开当前端点中待处理的交换实例列表，您可以实施 org.apache.camel.spi.BrowsableEndpoint 接口，如 例 40.5 “BrowsableEndpoint Interface” 所示。如果端点执行某种类型的传入事件，则需要实施此接口。例如，Apache Camel SEDA 端点实现了 BrowsableEndpoint 接口都为 BrowsableEndpoint，请参阅 例 40.6 “SedaEndpoint 实现”。

例 40.5. BrowsableEndpoint Interface

package org.apache.camel.spi;

import java.util.List;

import org.apache.camel.Endpoint;
import org.apache.camel.Exchange;

public interface BrowsableEndpoint extends Endpoint {
    List<Exchange> getExchanges();
}
Copy to Clipboard Toggle word wrap

Example
复制链接

例 40.6 “SedaEndpoint 实现” 显示 SedaEndpoint 的示例实施。SEDA 端点是 事件驱动的端点的示例。传入的事件存储在 FIFO 队列中( java.util.concurrent.BlockingQueue的实例)，SEDA 使用者启动一个线程来读取和处理事件。事件本身由 org.apache.camel.Exchange 对象表示。

例 40.6. SedaEndpoint 实现

package org.apache.camel.component.seda;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.BlockingQueue;

import org.apache.camel.Component;
import org.apache.camel.Consumer;
import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultEndpoint;
import org.apache.camel.spi.BrowsableEndpoint;

public class SedaEndpoint extends DefaultEndpoint implements BrowsableEndpoint {
1 

    private BlockingQueue<Exchange> queue;

    public SedaEndpoint(String endpointUri, Component component, BlockingQueue<Exchange> queue) {
2 

        super(endpointUri, component);
        this.queue = queue;
    }

    public SedaEndpoint(String uri, SedaComponent component, Map parameters) {
3 

        this(uri, component, component.createQueue(uri, parameters));
    }

    public Producer createProducer() throws Exception {
4 

        return new CollectionProducer(this, getQueue());
    }

    public Consumer createConsumer(Processor processor) throws Exception {
5 

        return new SedaConsumer(this, processor);
    }

    public BlockingQueue<Exchange> getQueue() {
6 

        return queue;
    }

    public boolean isSingleton() {
7 

        return true;
    }

    public List<Exchange> getExchanges() {
8 

        return new ArrayList<Exchange> getQueue());
    }
}
Copy to Clipboard Toggle word wrap
1
SedaEndpoint 类遵循通过扩展 DefaultEndpoint 类来实现事件驱动的端点的模式。SedaEndpoint 类还实施 BrowsableEndpoint 接口，它提供对队列中交换对象列表的访问。
2
根据事件驱动的消费者的常规模式，SedaEndpoint 定义了一个构造器，它采用端点参数、endpointUri 和组件引用参数 component。
3
提供了另一个构造器，它将队列创建委派给父组件实例。
4
createProducer （） 工厂方法创建 CollectionProducer 实例，这是将事件添加到队列中的制作者实施。
5
createConsumer （） factory 方法创建一个 SedaConsumer 实例，它负责拉取队列的事件并处理它们。
6
getQueue （） 方法返回对队列的引用。
7
isSingleton （） 方法返回 true，这表示应当为每个唯一 URI 字符串创建一个端点实例。
8
getExchanges （） 方法实现来自 BrowsableEndpoint 的对应抽象方法。
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

Theme

© 2025 Red Hat