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

42.2. 实施 Producer 接口

实施制作者的替代方法
复制链接

您可以使用以下方法之一实施制作者：

如何实施同步制作者
复制链接

例 42.4 “DefaultProducer 实现” 概述了如何实施同步生成者。在本例中，调用 Producer.process （） 块，直到收到回复为止。

例 42.4. DefaultProducer 实现

import org.apache.camel.Endpoint;
import org.apache.camel.Exchange;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultProducer;

public class CustomProducer extends DefaultProducer {
1 


    public CustomProducer(Endpoint endpoint) {
2 

        super(endpoint);
        // Perform other initialization tasks...
    }

    public void process(Exchange exchange) throws Exception {
3 

        // Process exchange synchronously.
        // ...
    }
}
Copy to Clipboard Toggle word wrap
1
通过扩展 org.apache.camel.impl.DefaultProducer 类，实施自定义同步制作者类 CustomProducer。
2
实施接受对父端点的引用的构造器。
3
process （） 方法实施代表制作者代码的核心。process （） 方法的实现完全依赖于您要实现的组件类型。

概述了 process （） 方法通常按如下方式实现：

  • 如果交换包含 In 消息，如果这与指定的交换模式一致，请将 In 消息发送到指定的端点。
  • 如果交换模式预计 Out 消息的接收，请等待直到收到 Out 消息。这通常会导致 process （） 方法在很长时间内阻止。
  • 收到回复后，调用 exchange.setOut （），以将回复附加到交换对象。如果回复包含错误消息，请使用 Message.setFault (true) 在 Out 消息上设置 fault 标志。

如何实施异步制作者
复制链接

例 42.5 “CollectionProducer 实现” 概述了如何实施异步生产者。在这种情况下，您必须同时实施同步 process （） 方法和异步 process （） 方法（采用额外的 AsyncCallback 参数）。

例 42.5. CollectionProducer 实现

import org.apache.camel.AsyncCallback;
import org.apache.camel.AsyncProcessor;
import org.apache.camel.Endpoint;
import org.apache.camel.Exchange;
import org.apache.camel.Producer;
import org.apache.camel.impl.DefaultProducer;

public class _CustomProducer_ extends DefaultProducer implements AsyncProcessor {
1 


    public _CustomProducer_(Endpoint endpoint) {
2 

        super(endpoint);
        // ...
    }

    public void process(Exchange exchange) throws Exception {
3 

        // Process exchange synchronously.
        // ...
    }

    public boolean process(Exchange exchange, AsyncCallback callback) {
4 

        // Process exchange asynchronously.
        CustomProducerTask task = new CustomProducerTask(exchange, callback);
        // Process 'task' in a separate thread...
        // ...
        return false;
5 

    }
}

public class CustomProducerTask implements Runnable {
6 

    private Exchange exchange;
    private AsyncCallback callback;

    public CustomProducerTask(Exchange exchange, AsyncCallback callback) {
        this.exchange = exchange;
        this.callback = callback;
    }

    public void run() {
7 

        // Process exchange.
        // ...
        callback.done(false);
    }
}
Copy to Clipboard Toggle word wrap
1
通过扩展 org.apache.camel.impl.DefaultProducer 类并实施 AsyncProcessor 接口，实施自定义异步制作者类 CustomProducer。
2
实施接受对父端点的引用的构造器。
3
实施同步 process （） 方法。
4
实施异步 process （） 方法。您可以通过几种方法实施异步方法。此处显示的方法是创建一个 java.lang.Runnable 实例，它代表在子线程中运行的代码。然后，您可以使用 Java 线程 API 在子线程中运行任务（例如，通过创建新线程或将任务分配给现有线程池）。
5
通常，您从异步 process （） 方法返回 false，以指示交换是异步处理的。
6
CustomProducerTask 类封装在子线程中运行的处理代码。此类必须存储 Exchange 对象的副本，交换，以及 AsyncCallback 对象( 回调 )作为私有成员变量。
7
run （） 方法包含将 In 消息发送到 producer 端点的代码，并等待收到回复（若有）。收到回复(Out message 或 Fault 消息)并将其插入到交换对象后，您必须调用 callback.done （） 来通知处理已完成的调用者。
返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

Theme

© 2025 Red Hat