marcuscosta/MVFC.LongPollingv1.0.4
.NET 10.0
Long polling via Redis Pub/Sub com suporte a CancellationToken configurável e notificação por evento ao receber mensagem antes do timeout.
Get Started
$ dotnet add package MVFC.LongPollingReadme
MVFC.LongPolling
Uma biblioteca leve e eficiente de long polling via Redis Pub/Sub para .NET,
com suporte a CancellationToken configurável e payload tipado.
Objetivo
Permitir que clientes HTTP aguardem resultados assíncronos (jobs, webhooks, processamentos) de forma simples, sem polling cego ou WebSockets, usando o canal Pub/Sub do Redis como mecanismo de notificação.
Funcionalidades
- Redis Pub/Sub: Subscription real por canal, sem polling de chave.
- Timeout configurável: Tempo máximo de espera global ou por chamada via
LongPollingOptions. - CancellationToken: Respeita desconexão do cliente HTTP automaticamente.
- Payload tipado:
WaitAsync<T>desserializa o resultado diretamente viaSystem.Text.Json. - Entrega confirmada:
PublishAsyncretornafalsese nenhum subscriber estava ativo. - Sincronização determinística:
WaitUntilReadyAsyncgarante que a subscription está ativa antes de publicar. - Configuração Fluente: Setup simples no
Program.cs. - Prefixo de canal: Isolamento de ambientes via
KeyPrefix.
Instalação
dotnet add package MVFC.LongPolling
Configuração
Básica
builder.Services.AddLongPolling("localhost:6379", cfg =>
{
cfg.DefaultTimeout = TimeSpan.FromSeconds(30);
cfg.KeyPrefix = "poll";
});
Com IConnectionMultiplexer existente
builder.Services.AddLongPolling(existingMultiplexer, cfg =>
{
cfg.DefaultTimeout = TimeSpan.FromSeconds(20);
});
Uso
Aguardar resultado (string)
app.MapGet("/poll/{jobId}", async (
string jobId,
ILongPollingService polling,
CancellationToken ct) =>
{
var result = await polling.WaitAsync(jobId, cancellationToken: ct);
return result is null
? Results.NoContent() // timeout
: Results.Ok(result);
});
Aguardar resultado tipado
app.MapGet("/poll/{jobId}/typed", async (
string jobId,
ILongPollingService polling,
CancellationToken ct) =>
{
var result = await polling.WaitAsync<OrderCompletedEvent>(jobId, cancellationToken: ct);
return result is null
? Results.NoContent()
: Results.Ok(result);
});