第 42 章 生产者接口
摘要
本章论述了如何实施 Apache Camel 组件，这是实施 Apache Camel 组件的基本步骤。
42.1. Producer 接口
概述
org.apache.camel.Producer 类型的实例代表路由中的目标端点。制作者的角色是将请求（消息为In 消息）发送到特定的物理端点，并接收对应的响应(Out 或 Fault 消息)。Producer 对象基本上是处理器链末尾出现的特殊处理器类型（与路由相同）。图 42.1 “producer Inheritance Hierarchy” 显示制作者的继承层次结构。
图 42.1. producer Inheritance Hierarchy
Producer 接口
例 42.1 “生产者接口” 显示 org.apache.camel.Producer 接口的定义。
例 42.1. 生产者接口
package org.apache.camel;
public interface Producer extends Processor, Service, IsSingleton {
Endpoint<E> getEndpoint();
Exchange createExchange();
Exchange createExchange(ExchangePattern pattern);
Exchange createExchange(E exchange);
}制作者方法
Producer 接口定义了以下方法：
-
process （）（从 Processor herited） WWN-WITH 最重要的方法。制作者本质上是发送请求到端点的特殊处理器，而不将交换对象转发到其他处理器。通过覆盖process （）方法，您可以定义制作者如何向相关端点发送和接收消息。 -
getEndpoint （）WWN-sandboxedReturns 对父端点实例的引用。 -
createExchange （）ALLOW-ALLOW These overloaded 方法与 Endpoint 接口中定义的对应方法类似。通常，这些方法委派到父 Endpoint 实例上定义的对应方法（默认为DefaultEndpoint类是什么）。有时，您可能需要覆盖这些方法。
异步处理
在制作者在制作者的 coreutils-方式中处理交换对象通常涉及向远程目的地发送消息，并等待回复的 reply-提示您获得大量时间。如果您想要避免阻止当前线程，可以选择将制作者作为 异步处理器 来实施。异步处理模式将上述处理器与生产者分离，以便 process （） 方法返回无延迟。请参阅 第 38.1.4 节 “异步处理”。
实施制作者时，您可以通过实施 org.apache.camel.AsyncProcessor 接口来支持异步处理模型。它本身不足以确保将使用异步处理模型：链中前面的处理器调用 process （） 方法的异步版本也是必需的。AsyncProcessor 接口的定义显示在 例 42.2 “AsyncProcessor 接口” 中。
例 42.2. AsyncProcessor 接口
package org.apache.camel;
public interface AsyncProcessor extends Processor {
boolean process(Exchange exchange, AsyncCallback callback);
}
process （） 方法的异步版本采用一个额外的参数，回调 是 org.apache.camel.AsyncCallback 类型。对应的 AsyncCallback 接口被定义，如 例 42.3 “AsyncCallback Interface” 所示。
例 42.3. AsyncCallback Interface
package org.apache.camel;
public interface AsyncCallback {
void done(boolean doneSynchronously);
}
AsyncProcessor.process （） 的 caller 必须提供 AsyncCallback 的实现，以接收处理完成的通知。AsyncCallback.done （） 方法采用布尔值参数，指明处理是否同步执行。通常，标志为 false，表示异步处理。然而，在某些情形中，生产者 可能不 异步处理（尽管要求要求这样做）。例如，如果生产者知道交换的处理将很快完成，它可以通过同步方式处理处理。在这种情况下，已完成的Synchronous 标志应设置为 true。
ExchangeHelper 类
在实施制作者时，您可能会发现在 org.apache.camel.util.ExchangeHelper utility 类中调用一些方法很有帮助。有关 ExchangeHelper 类的详情，请参考 第 35.4 节 “ExchangeHelper Class”。
