Pular para o conteúdo principal

Hangfire - processamento em background fácil no .NET

A necessidade de realizar uma tarefa em segundo plano é muito comum, seja para gravar um arquivo, enviar um e-mail, executar um processo de banco pesado, enfim, qualquer coisa que não deve "bloquear" o usuário no thread principal, e é aí que o Hangfire entra, ele recebe tarefas e as trata em filas realizando a execução em background e mais:

  • As tarefas entram em uma fila e a execução ocorre na sequência;
  • Uma execução só é considerada "falha" quando as tentativas já se esgotaram (por padrão são 10);
  • Dá para criar uma tarefa simplesmente a colocando na fila;
  • Dá para criar um fluxo de execução de tarefas constante dentro de um intervalo;
  • Dá para agendar a execução de tarefas;
  • Dá para condicionar a execução de tarefas após o sucesso de outra tarefa;
  • Todo o fluxo é tratado em tabelas do próprio Hangfire, podendo ser gerido em vários bancos de dados (relacionais ou não);
  • Os registros referentes as tarefas possuem um tempo limitado de vida, depois de concluidos são apagados (por padrão 1 dia);
  • É disponibilizado um dashboard para acompanhar as tarefas;

Instalação

Para esse post será criada uma aplicação web, uma API padrão sem funcionalidades, e o Hangfire vai usar o SqlServer para suas tabelas, então para nosso caso precisaremos dos seguintes pacotes:

Configuração

Em resumo precisamos apenas alterar o Startup, configurando, adicionando e usando o HangFire:

Em "ConfigureServices":

            services.ConfigureHangfire(HostingEnvironment, Configuration);

            services.AddHangfireServer();

Em "Configure":

            app.UseHangfireDashboard();

            new HangfireExamples().StartExamples();

Execução única (assim que possível)

Esse recurso permite que uma tarefa seja incluida na fila sendo executada assim que possível, se a fila estiver vazia ela é executada de imediato, no exemplo abaixo executaremos o método "FireAnfForgetExample":

BackgroundJob.Enqueue(() => FireAnfForgetExample(null));

Execução recorrente

Aqui temos a capacidade de programar uma tarefa para ser executada de tempos em tempos, no exemplo abaixo executaremos o método "RecurringJobExample" de minuto em minuto:

RecurringJob.AddOrUpdate(() => RecurringJobExample(null), Cron.Minutely);

Execução agendada

Caso a necessidade seja a de agendar uma execução futura podemos fazer com o exemplo abaixo, onde o método "DelayedJobExample" é executado em uma semana:

BackgroundJob.Schedule(() => DelayedJobExample(null), TimeSpan.FromDays(7));

Execução contínua

Esse último recurso nos permite condicionar a execução de uma terefa ao sucesso de uma outra, para isso primeiro precisamos pegar o ID da tarefa "principal" e informa-lo para a tarefa "condicional", no exemplo abaixo executamos o método "ContinuationTaskFirst" e caso ele seja concluido com sucesso o método "ContinuationTaskSecond" será executado:

var jobId = BackgroundJob.Enqueue(() => ContinuationTaskFirst(null));

BackgroundJob.ContinueJobWith(jobId, () => ContinuationTaskSecond(null));

Dashboard

Como mencionado o Hangfire fornece uma aplicação web que nos permite acompanhar toda movimentação, basta acessar "url_site/hangfire":

  • Painel de monitoramento com gráficos em tempo real e histórico:
  • Página de Tarefas para consultar "Enfileiradas", "Agendadas", "Processando", "Concluido", "Em falha", "Removidas" e "Aguardando";
  • Página de Retentativas para ver o que ainda não deu certo de ser executado;
  • Página de Tarefas recorrentes para ver o que está configurado como "recorrente";
  • Página de Servidores para ver onde o Hangfire esta rodando;

Conclusão

O Hangfire é uma forma bem poderosa e simples de se trabalhar com filas de execução em segundo plano, fornecendo inclusive uma série de ferramentas para acompanhamento desse trabalho, é sem dúvidas uma das maneiras mais simples de tratar essa questão.

Projeto de exemplo

Fonte

Comentários

Mais visitadas

Alterar cores do PageControl (Delphi)

O padrão Windows todo cinza não é muito atraente, por isso quando nos utilizarmos do PageControl podemos alterar suas cores e fontes da seguinte maneira: Em primeiro lugar devemos alterar a propriedade OwnerDraw para TRUE ; Depois implementar seu método DrawTab da seguinte maneira: //pinta a fonte Control.Canvas.Font.Color:=clBlack; // // pinta a paleta / aba Control.Canvas.brush.Color:=clSkyBlue; PageControl1.Canvas.Rectangle(Rect); Control.Canvas.TextOut(Rect.left+5,Rect.top+3,PageControl1.Pages[tabindex].Caption); // pinta a parte interna (tabsheet) PageControl1.Pages[TabIndex].brush.Color := Control.Canvas.brush.Color; PageControl1.Pages[TabIndex].Repaint; Caso a intenção seja manter cada aba com seu próprio estilo basta adicionar um CASE filtrando o índice das abas: case TabIndex of   0: Control.Canvas.Font.Color:=clBlack;   1: Control.Canvas.Font.Color:=clWindow; ...

Como pegar valor de coluna invisível do GridView

Em determinado momento nos deparamos com a seguinte situação, nossa tabela do banco de dados possui como campo chave, um ID por exemplo, incrementado por uma rotina da aplicação, do banco ou algum outro mecanismo de incremento (sequences, increment, etc), logo não há porque mostrar essa coluna para o usuário porque o mesmo não sabe de sua existência, e seu valor não tem qualquer relevância para ele, sendo assim o mais lógico a se fazer é não mostra-lá na aplicação. Seu valor é necessário já que por se tratar de uma chave primária precisaremos dela para atualizar, inserir ou excluir os dados, então o que fazer? A resposta seria simples, deixemos ele invisível, buscaremos seu valor e o usuário não perceberá, porém a partir da versão 2005 do visual Studio as colunas setadas com "visible = false" não são renderizadas, com isso ao se tentar acessar seu valor o que recebemos é nada. Para contornarmos essa situação podemos codificar o seguinte: protected void GridView1_R...

Aplicação Flask usando Nginx e Gunicorn

Aplicação Flask usando Nginx e Gunicorn Se você já desenvolveu uma aplicação Flask básica, sabe que o servidor de desenvolvimento embutido não é ideal para produção. Ele não é projetado para lidar com altos volumes de tráfego ou conexões simultâneas. Para tornar sua aplicação Flask mais robusta e pronta para produção, podemos usar o Gunicorn como servidor de aplicação e o Nginx como proxy reverso. Neste artigo, vamos adaptar o exemplo anterior ( Criando uma Aplicação CRUD com Flask, PostgreSQL e Docker ) para incluir o Nginx e o Gunicorn. O que são Nginx e Gunicorn? Gunicorn O Gunicorn (Green Unicorn) é um servidor de aplicação WSGI que roda aplicações Python como o Flask. Ele é eficiente e simples de configurar, lidando com múltiplas requisições ao mesmo tempo, algo que o servidor embutido do Flask não faz bem. Nginx O Nginx é um servidor web que atua como um proxy reverso. Ele recebe requisições HTTP e as encaminha ao Gunicorn. Além disso, o Nginx pode: Servir arquivos ...