通过 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 是有用的。 Factory 是一项高成本操作。 FabricServiceProxyFactory 维护通信客户端的缓存。 最佳做法是尽可能久地缓存 FabricServiceProxyFactory。

远程异常处理

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

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

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

后续步骤

• 确保 Reliable Services 的通信安全