SbeServer

SbeServer

public SbeServer(IAuthorization authorization, ITransactionIdStorage transactionIdStorage, string licenseFeatureId, DateTime componentTimestamp, IMessageConverter converter)

sbeServer = SbeServer(authorization, transactionIdStorage, licenseFeatureId, componentTimestamp, converter)

Inicializa uma nova instância do SbeServer.

Authorization

public IAuthorization Authorization { get; }

value = sbeServer.Authorization

A autenticação do cliente.

ComponentTimestamp

public DateTime ComponentTimestamp { get; }

value = sbeServer.ComponentTimestamp

Hora do componente.

Converter

public IMessageConverter Converter { get; }

value = sbeServer.Converter

Conversor de mensagens.

LicenseFeatureId

public string LicenseFeatureId { get; }

value = sbeServer.LicenseFeatureId

ID da funcionalidade de licença.

SendOutHeartbeats

public bool SendOutHeartbeats { get; set; }

value = sbeServer.SendOutHeartbeats
sbeServer.SendOutHeartbeats = value

Enviar batimentos cardíacos através do canal de mensagens enviadas.

TransactionIdStorage

public ITransactionIdStorage TransactionIdStorage { get; }

value = sbeServer.TransactionIdStorage

ConfigureAcceptedSocket

private void ConfigureAcceptedSocket(TcpClient client)

sbeServer.ConfigureAcceptedSocket(client)

Aplicar TCP KeepAlive a um soquete cliente aceito. As sondas de manutenção vivas mantêm as entradas de fluxo NAT/firewall vivas e os pares mortos da superfície rapidamente.

CreateSubscription

protected override SbeServerSubscription CreateSubscription(ClientSbeSession session, string requestId, ServerSubscription subscription, MessageTypes type)

result = sbeServer.CreateSubscription(session, requestId, subscription, type)

GetSessionKey

protected override string GetSessionKey(ClientSbeSession session)

result = sbeServer.GetSessionKey(session)

IsStubSubscription

protected override bool IsStubSubscription(SbeServerSubscription subscription)

result = sbeServer.IsStubSubscription(subscription)

NextResponseId

private static string NextResponseId()

result = SbeServer.NextResponseId()

Gerar um ID de resposta único que NÃO polua TransactionIdStorage. Evita colisões entre IDs de resposta gerados pelo servidor e mdReqIds fornecidos pelo cliente.

OnClearListenerState

protected override void OnClearListenerState()

sbeServer.OnClearListenerState()

Limpar o estado de ouvinte específico do protocolo (stop outleners, etc.).

OnProcess

private IAsyncEnumerable<Message> OnProcess(ClientSbeSession session, ushort templateId, byte[] payload, CancellationToken cancellationToken)

result = sbeServer.OnProcess(session, templateId, payload, cancellationToken)

Enviar mensagem SBE recebida por templateId.

OnStartListeners

protected override void OnStartListeners(CancellationToken cancellationToken)

sbeServer.OnStartListeners(cancellationToken)

Iniciar ouvintes específicos do protocolo (TCP, etc.). Adicionar tarefas a _backgroundTasks.

ProcessInMessage

protected override void ProcessInMessage(Message message, CancellationToken cancellationToken)

sbeServer.ProcessInMessage(message, cancellationToken)

Processe uma mensagem recebida e route para clientes subscritos.

ProcessLogout

protected override void ProcessLogout(ClientSbeSession session)

sbeServer.ProcessLogout(session)

ReadFramedMessageAsync

private static Task<byte[]> ReadFramedMessageAsync(Stream stream, CancellationToken cancellationToken)

result = SbeServer.ReadFramedMessageAsync(stream, cancellationToken)

Quadro SBE: ler [4-byte longituture] [payload].

ScheduleSessionWork

protected override void ScheduleSessionWork(ClientSbeSession session, ServerSubscription subscription, string requestId, Func<ClientSbeSession, string, CancellationToken, ValueTask<bool>> handler)

sbeServer.ScheduleSessionWork(session, subscription, requestId, handler)

WriteFramedAsync

private ValueTask<bool> WriteFramedAsync(ClientSbeSession session, Func<SbeRecordSerializer, byte[], int> serialize, CancellationToken cancellationToken)

result = sbeServer.WriteFramedAsync(session, serialize, cancellationToken)

Caminho de gravação de saída central: serialize a mensagem no buffer de gravação de sessão (crescendo e tentando novamente no transbordamento de imagens grandes não são largadas), então frame e envie- a. O buffer pode ser reatribuído pelo Int32}), então é re- lido após serialização.