Comunicação Remota do Serviço em Java com Reliable Services

Artigo
10/15/2024

Para serviços que não estão vinculados a um protocolo de comunicação específico ou pilha, como WebAPI, WCF (Windows Communication Foundation) ou outros, a estrutura do Reliable Services fornece um mecanismo de comunicação remota para configurar a chamada de procedimento remoto para serviços de forma rápida e fácil. Este artigo descreve como configurar chamadas de procedimento remoto para serviços criados com Java.

Configurar a comunicação remota em um serviço

A configuração da comunicação remota de um serviço é feita em duas etapas simples:

Crie uma interface para implementar o serviço. Essa interface define os métodos disponíveis para uma chamada de procedimento remoto no seu serviço. Os métodos devem ser métodos assíncronos que retornam tarefas. A interface deve implementar microsoft.serviceFabric.services.remoting.Service para sinalizar que o serviço tem uma interface de comunicação remota.
Use um ouvinte de comunicação remota em seu serviço. Esta é uma implementação de CommunicationListener que fornece recursos de comunicação remota. FabricTransportServiceRemotingListener pode ser usado para criar um ouvinte de comunicação remota usando o protocolo de transporte de comunicação remota padrão.

Por exemplo, o serviço sem estado a seguir expõe um único método para obter "Hello World" pela chamada de procedimento remoto.

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;
    }
}

Observação

Os argumentos e os tipos de retorno na interface de serviço podem ser de tipos simples, complexos ou personalizados, mas devem ser serializáveis.

Chamar métodos de serviços remotos

A chamada de métodos em um serviço usando a pilha de comunicação remota é feita usando um proxy local para o serviço por meio da classe microsoft.serviceFabric.services.remoting.client.ServiceProxyBase . O método ServiceProxyBase cria um proxy local usando a mesma interface que o serviço implementa. Com esse proxy, você pode simplesmente chamar métodos na interface remotamente.


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

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

A estrutura remota propaga exceções lançadas no serviço para o cliente. A lógica de manipulação de exceção no cliente usando ServiceProxyBase pode manipular diretamente as exceções que o serviço lança.

Tempo de vida de Proxy do Serviço

A criação do Proxy do Serviço é uma operação simples, de modo que os usuários podem criar quantos forem necessários. As instâncias do Proxy do Serviço podem ser reutilizadas enquanto os usuários precisarem. Se uma chamada de procedimento remoto lança uma exceção, você ainda pode reutilizar a mesma instância do proxy. Cada ServiceProxy contém um cliente de comunicação usado para enviar mensagens durante a transmissão. Ao chamar as chamadas remotas, internamente verifica para ver se o cliente de comunicação é válido. Com base nos resultados das verificações, o cliente de comunicação é recriado se necessário. Portanto, se ocorrer uma exceção, você não precisa recriar ServiceProxy.

Tempo de vida de ServiceProxyFactory

FabricServiceProxyFactory é um alocador que cria um proxy para interfaces remotas diferentes. Se você usar a API ServiceProxyBase.create para criar um proxy, o framework cria um FabricServiceProxyFactory. É útil para criá-lo manualmente quando você precisa substituir propriedades ServiceRemotingClientFactory. Alocador é uma operação cara. FabricServiceProxyFactory mantém o cache dos clientes de comunicação. A prática recomendada é armazenar em cache FabricServiceProxyFactory por mais tempo possível.

Tratamento de exceções remotas

Todas as exceções remotas lançadas pela API de serviço são reenviadas para o cliente como RuntimeException ou FabricException.

O ServiceProxy trata todas as exceções de failover da partição de serviço para a qual foi criado. Ele resolverá novamente os pontos de extremidade se houver exceções de failover (exceções não transitórias) e repetirá a chamada com o ponto de extremidade correto. O número de tentativas da exceção de failover é indefinido. No caso de TransientExceptions, ele repete apenas a chamada.

Os parâmetros de repetição padrão são fornecidos por OperationRetrySettings. Você pode configurar esses valores, passando o objeto OperationRetrySettings para o construtor ServiceProxyFactory.

Próximas etapas

Securing communication for Reliable Services

Compartilhar via