Compartilhar via

StatelessServiceBase Classe

  • Referência
Pacote:
microsoft.servicefabric.services.runtime
  • java.lang.Object
    • microsoft.servicefabric.services.runtime.StatelessServiceBase

public class StatelessServiceBase

Representa a classe base para o serviço confiável sem estado baseado no Microsoft Service Fabric.

Resumo do Construtor

Construtor Description
StatelessServiceBase()

Resumo do método

Modificador e tipo Método e descrição
List<ServiceInstanceListener> createServiceInstanceListeners()

Substitua esse método para fornecer os ouvintes de comunicação para a instância de serviço. Os pontos de extremidade retornados pelos ouvintes de comunicação são armazenados como uma cadeia de caracteres JSON de ListenerName, pares de cadeia de caracteres de ponto de extremidade como {"Pontos de extremidade":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}
Map<String, String> getAddresses()

Obtém a lista de todos os endereços para essas instâncias de serviço como o par chave-valor (ListenerName, Ponto de Extremidade).
StatelessServicePartition getPartition()

Obtém a partição de serviço à qual a instância de serviço atual pertence.
StatelessServiceContext getServiceContext()

Obtém o contexto de serviço no qual esse serviço sem estado está operando. Ele fornece informações como InstanceId, PartitionId, ServiceName etc.
void onAbort()

Notificação de que o serviço está sendo anulado. RunAsync PODE estar sendo executado simultaneamente com a execução desse método, pois o cancelamento não é aguardado no caminho de anulação.

CompletableFuture<?> onCloseAsync(CancellationToken cancellationToken)

Esse método é chamado como a etapa final de fechamento do serviço. Substitua esse método para ser notificado de que Close foi concluído para os componentes internos dessa instância.
CompletableFuture<?> onOpenAsync(CancellationToken cancellationToken)

Esse método é chamado como a etapa final de abertura do serviço. Substitua esse método para ser notificado de que Open foi concluído para os componentes internos dessa instância.
CompletableFuture<?> runAsync(CancellationToken cancellationToken)

Os serviços que desejam implementar uma tarefa em segundo plano que é executada quando ela é aberta, apenas substituem esse método por sua lógica.
void setAddresses(Map<String, String> addresses)

Define a lista de todos os endereços dessa instância de serviço como o par chave-valor (ListenerName, Ponto de Extremidade).

Detalhes do construtor

StatelessServiceBase

protected StatelessServiceBase()

Detalhes do método

createServiceInstanceListeners

protected List createServiceInstanceListeners()

Substitua esse método para fornecer os ouvintes de comunicação para a instância de serviço. Os pontos de extremidade retornados pelos ouvintes de comunicação são armazenados como uma cadeia de caracteres JSON de ListenerName, pares de cadeia de caracteres de ponto de extremidade como {"Pontos de extremidade":{"Listener1":"Endpoint1","Listener2":"Endpoint2" ...}}

Retornos:

Lista de ServiceInstanceListeners

getAddresses

protected Map getAddresses()

Obtém a lista de todos os endereços para essas instâncias de serviço como o par chave-valor (ListenerName, Ponto de Extremidade).

Retornos:

Uma Map lista de endereços contendo como o par chave-valor (ListenerName, Ponto de Extremidade).

getPartition

protected StatelessServicePartition getPartition()

Obtém a partição de serviço à qual a instância de serviço atual pertence.

Retornos:

Um StatelessServicePartition que representa a partição à qual esse serviço réplica pertence.

getServiceContext

public StatelessServiceContext getServiceContext()

Obtém o contexto de serviço no qual esse serviço sem estado está operando. Ele fornece informações como InstanceId, PartitionId, ServiceName etc.

Retornos:

Um StatelessServiceContext que descreve o contexto do serviço.

onAbort

protected void onAbort()

Notificação de que o serviço está sendo anulado. RunAsync PODE estar sendo executado simultaneamente com a execução desse método, pois o cancelamento não é aguardado no caminho de anulação.

onCloseAsync

protected CompletableFuture onCloseAsync(CancellationToken cancellationToken)

Esse método é chamado como a etapa final de fechamento do serviço. Substitua esse método para ser notificado de que Close foi concluído para os componentes internos dessa instância.

Parâmetros:

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Um CompletableFuture que representa uma operação pendente.

onOpenAsync

protected CompletableFuture onOpenAsync(CancellationToken cancellationToken)

Esse método é chamado como a etapa final de abertura do serviço. Substitua esse método para ser notificado de que Open foi concluído para os componentes internos dessa instância.

Parâmetros:

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Um CompletableFuture que representa uma operação pendente.

runAsync

protected CompletableFuture runAsync(CancellationToken cancellationToken)

Os serviços que desejam implementar uma tarefa em segundo plano que é executada quando ela é aberta, apenas substituem esse método por sua lógica.

Parâmetros:

cancellationToken -

CancellationTokenpara indicar o status de cancelamento da operação.

Retornos:

Um CompletableFuture que representa uma operação pendente.

setAddresses

protected void setAddresses(Map addresses)

Define a lista de todos os endereços dessa instância de serviço como o par chave-valor (ListenerName, Ponto de Extremidade).

Parâmetros:

addresses - Uma Map lista de endereços contendo como o par chave-valor (ListenerName, Ponto de Extremidade).

Aplica-se a