8.12. 服务调用

从 Camel 2.18 开始提供。

服务调用 模式允许您在分布式系统中调用远程服务。要调用的服务会在服务 registry 中查找，如 Kubernetes、Consul、etcd 或 Zookeeper。模式将服务 registry 的配置与服务的调用分开。

Maven 用户必须为要使用的服务 registry 添加依赖项。可能包括：

要调用服务，请参考服务的名称，如下所示：

from("direct:start")
    .serviceCall("foo")
    .to("mock:result");

以下示例显示了调用服务的 XML DSL：

<camelContext xmlns="http://camel.apache.org/schema/spring">
  <route>
    <from uri="direct:start"/>
    <serviceCall name="foo"/>
    <to uri="mock:result"/>
  </route>
</camelContext>

在这些示例中，Camel 使用与服务 registry 集成的组件来用名称 foo 查找服务。lookup 返回一组 IP:PORT 对，引用托管远程服务的活跃服务器列表。然后 Camel，从该列表列出要使用的服务器并使用所选的 IP 和 PORT 号构建 Camel URI。

默认情况下，Camel 使用 HTTP 组件。在上例中，调用解析为由动态 toD 端点调用的 Camel URI，如下所示：

toD("http://IP:PORT")

<toD uri="http:IP:port"/>

您可以使用 URI 参数调用服务，例如 beer=yes ：

serviceCall("foo?beer=yes")

<serviceCall name="foo?beer=yes"/>

您还可以提供上下文路径，例如：

serviceCall("foo/beverage?beer=yes")

<serviceCall name="foo/beverage?beer=yes"/>

正如您所见，服务名称解析为 Camel 端点 URI。以下是一些更多示例。→ 显示 Camel URI 的解析：

serviceCall("myService") -> http://hostname:port
serviceCall("myService/foo") -> http://hostname:port/foo
serviceCall("http:myService/foo") -> http:hostname:port/foo

<serviceCall name="myService"/> -> http://hostname:port
<serviceCall name="myService/foo"/> -> http://hostname:port/foo
<serviceCall name="http:myService/foo"/> -> http:hostname:port/foo

要完全控制解析的 URI，请提供指定所需 Camel URI 的额外 URI 参数。在指定的 URI 中，您可以使用服务名称，它解析为 IP:PORT。以下是一些示例：

serviceCall("myService", "http:myService.host:myService.port/foo") -> http:hostname:port/foo
serviceCall("myService", "netty4:tcp:myService?connectTimeout=1000") -> netty:tcp:hostname:port?connectTimeout=1000

<serviceCall name="myService" uri="http:myService.host:myService.port/foo"/> -> http:hostname:port/foo
<serviceCall name="myService" uri="netty4:tcp:myService?connectTimeout=1000"/> -> netty:tcp:hostname:port?connectTimeout=1000

上面的示例调用名为 myService 的服务。第二个参数控制解析的 URI 的值。请注意，第一个示例使用 serviceName.host 和 serviceName.port 来引用 IP 或 PORT。如果您只指定 serviceName，则会解析为 IP:PORT。

默认情况下，Camel 使用 HTTP 组件来调用服务。您可以配置不同组件的使用，如 HTTP4 或 Netty4 HTTP，如下例所示：

KubernetesConfigurationDefinition config = new KubernetesConfigurationDefinition();
config.setComponent("netty4-http");

// Register the service call configuration:
context.setServiceCallConfiguration(config);

from("direct:start")
    .serviceCall("foo")
    .to("mock:result");

以下是 XML DSL 中的示例：

<camelContext xmlns="http://camel.apache.org/schema/spring">
  <kubernetesConfiguration id="kubernetes" component="netty4-http"/>
  <route>
    <from uri="direct:start"/>
    <serviceCall name="foo"/>
    <to uri="mock:result"/>
  </route>
</camelContext>

每个实现都有以下选项：

Kubernetes 实现支持以下选项：