通过 Reliable Services 在 Java 中进行服务远程调用

对于不依赖于特定的通信协议或堆栈的服务，如 WebAPI、Windows Communication Foundation (WCF) 或其他服务，Reliable Services 框架提供一种远程处理机制，以便快速而轻松地为这些服务设置远程过程调用。 本文讨论如何为使用 Java 编写的服务设置远程过程调用。

为服务设置远程调用

为服务设置远程访问只需两个简单步骤：

1. 为服务创建要实现的接口。 此接口定义了可以用于您服务的远程过程调用的方法。 这些方法必须是返回任务的异步方法。 此接口必须实现 microsoft.serviceFabric.services.remoting.Service 以表明此服务具有远程处理接口。
2. 在服务中使用远程侦听器。 这是可以提供远程处理功能的 CommunicationListener 实现。 可使用 FabricTransportServiceRemotingListener 通过默认的远程处理传输协议来创建远程处理侦听器。

例如，以下无状态服务提供一个方法，通过远程过程调用获取“Hello World”。

import java.util.ArrayList;
import java.util.concurrent.CompletableFuture;
import java.util.List;
import microsoft.servicefabric.services.communication.runtime.ServiceInstanceListener;
import microsoft.servicefabric.services.remoting.Service;
import microsoft.servicefabric.services.runtime.StatelessService;

public interface MyService extends Service {
    CompletableFuture<String> helloWorldAsync();
}

class MyServiceImpl extends StatelessService implements MyService {
    public MyServiceImpl(StatelessServiceContext context) {
       super(context);
    }

    public CompletableFuture<String> helloWorldAsync() {
        return CompletableFuture.completedFuture("Hello!");
    }

    @Override
    protected List<ServiceInstanceListener> createServiceInstanceListeners() {
        ArrayList<ServiceInstanceListener> listeners = new ArrayList<>();
        listeners.add(new ServiceInstanceListener((context) -> {
            return new FabricTransportServiceRemotingListener(context,this);
        }));
        return listeners;
    }
}

调用远程服务方法

若要通过远程处理堆栈在服务上调用方法，可以通过 microsoft.serviceFabric.services.remoting.client.ServiceProxyBase 类通过本地代理调用该服务。 ServiceProxyBase 方法通过使用此服务实现的相同接口来创建本地代理。 使用该代理，可以远程调用接口上的方法。

MyService helloWorldClient = ServiceProxyBase.create(MyService.class, new URI("fabric:/MyApplication/MyHelloWorldService"));

CompletableFuture<String> message = helloWorldClient.helloWorldAsync();

此远程处理框架将服务引发的异常传播到客户端。 因此，在客户端使用 ServiceProxyBase 的异常处理逻辑可直接处理服务引发的异常。

服务代理生存期

由于 ServiceProxy 创建是轻量型操作，因此可根据需求随意创建，数目不限。 只要需要，服务代理实例就可以再利用。 如果远程过程调用引发了异常，仍可以重复使用相同的代理实例。 每个 ServiceProxy 都包含用于通过线路发送消息的通信客户端。 进行远程调用时，会在内部执行检查，以确认通信客户端是否有效。 根据这些检查结果，必要时将重新创建通信客户端。 因此，如果发生异常，则无需重新创建 ServiceProxy。

ServiceProxyFactory 生存期

FabricServiceProxyFactory 是为不同远程接口创建代理的工厂。 如果使用 API ServiceProxyBase.create创建代理，则框架创建 FabricServiceProxyFactory。 当需要重写 ServiceRemotingClientFactory 属性时，手动创建一个会非常有用。 工厂运行成本高。 FabricServiceProxyFactory 维护通信客户端的缓存。 最佳做法是尽可能久地缓存 FabricServiceProxyFactory。

远程异常处理

服务 API 引发的所有远程异常都作为 RuntimeException 或 FabricException 发送回客户端。

ServiceProxy 处理为其创建的服务分区的所有故障转移例外。 如果存在故障转移异常（非暂时性异常），它将重新解析终结点，并使用正确的终结点重试调用。 故障转移异常的重试次数无限。 在瞬态异常（TransientExceptions）情况下，它仅重试调用。

默认重试参数由 OperationRetrySettings 提供。 可以通过将 OperationRetrySettings 对象传递给 ServiceProxyFactory 构造函数来配置这些值。

后续步骤

• 确保 Reliable Services 的通信安全