Forem: Fernando Mendes

Gerenciando a integridade de suas aplicações em AspNet Core

Fernando Mendes — Mon, 30 Sep 2019 13:04:59 +0000

Olá pessoal, tudo bem?

Com o crescimento dos microserviços, temos a preocupação de saber se as nossas aplicações, banco de dados, serviços e etc, estão rodando normalmente, se nenhum deles está fora do ar.

Para isso existe um pacote do nuget muito legal, que se chama:
*AspNetCore.Diagnostics.HealthChecks

Verifique se pelo o que você precisa, existe a o pacote específico, veja em:
https://github.com/xabaril/AspNetCore.Diagnostics.HealthChecks

Para o controle de aplicações, serviços, banco de dados, existe um pacote complementar para cada um.

Como por exemplo:

AspNetCore.HealthChecks.MongoDb
AspNetCore.HealthChecks.RabbitMQ
AspNetCore.HealthChecks.Kafka
AspNetCore.HealthChecks.Uris

Vamos fazer um exemplo, da utilização desse pacote.

Estrutura da solução

Veja que criei duas API´s.

Neste exemplo, quero gerenciar o meu banco de dados que será em Mongodb, meu serviço de fila que será Kafka, e API exemplohealthchecks2.

Para o projeto ExemploHealthChecks adicione as referências:

Install-Package AspNetCore.HealthChecks.MongoDb
Install-Package AspNetCore.HealthChecks.Kafka
Install-Package AspNetCore.HealthChecks.Uris
Install-Package AspNetCore.HealthChecks.UI
Install-Package AspNetCore.HealthChecks.UI.Client

Veja como configurar o Kafka, no meu post sobre o serviço:
https://dev.to/marraia

Configure no Startup.cs, os endereços dos serviços que iremos monitorar:

Veja que na linha 19, estamos adicionando os serviços que vamos monitorar, com seus respectivos endereços

    services.AddHealthChecks()
      .AddMongoDb(connectionMongo, name: "mongoDb")
      .AddKafka(configKafka, name: "kafka")
      .AddUrlGroup(new Uri(enderecoExemplo2), name: "exemploHelathChecks2");

E na linha 25, vamos adicionar um dashboard para visualizar a integridades dos serviços configurados

services.AddHealthChecksUI();

O pacote do Health com esse Dashboard, cria um arquivo chamado healthchecksdb que irá armazenar os dados coletados dos serviços, como uma especie de banco de dados.

Na linha 38, estamos gerando uma URL para o Dashboard do Health. Para funcionar corretamente essa URL, temos que adicionar ao arquivo appsettings.json essa configuração:

"HealthChecks-UI": {
    "HealthChecks": [
      {
        "Name": "Health-ExemploAPI",
        "Uri": "http://localhost:61303/health-marraia"
      }
    ]
  }

E na linha 45, ativamos o Dashboard, para ser utilizado depois que aplicação for iniciada.

Depois de configurado, vamos executar o projeto.

Agora, para abrir o Dashboard do Health que configuramos, vamos abrir esse link:
http://localhost:61303/healthchecks-ui

Veja que ele verifica em um tempo configurado, a integridades dos serviços. No exemplo, todos os serviços estão no ar.

Agora, não irei executar a API exemploHealthChecks2, para mostrar que ficará diferente a visualização no Dashboard

Veja que a API exemploHealthChecks2, fica com um estado de Unhealthy

Bom pessoal, este exemplo é bem simples, somente para mostrar como de forma fácil e simples, criar um monitoramento de seus serviços e aplicações.

Espero que tenham gostado, segue o projeto que utilizei de exemplo em meu Github:

marraia/HealthChecks

Até a próxima!

Utilizando Log em ASP .NET Core

Fernando Mendes — Fri, 27 Sep 2019 12:26:29 +0000

Olá pessoal, o Asp .NET Core contempla várias funcionalidades nativas que anteriormente precisávamos baixar referências de terceiros como por exemplo:

Injeção de Dependências (Simple Injector, AutoFac, etc…)
Log (NLog, elmah.io, e etc…) … e algumas outras mais…

Neste post vou falar sobre uma delas, que é o Log! Em desenvolvimento de sistemas, precisamos muitas vezes logar a entrada de dados de uma API, ou logar uma exceção para analisar o que pode estar acontecendo dentro de um fluxo do sistema e etc..

O Log do Asp .NET Core, funciona em vários providers:

Console
Depurar
EventLog
AzureAppServices
TraceSource
EventSource

No exemplo abaixo vou mostrar, como se loga via console do Visual Studio:
Pelo Visual Studio vamos criar uma WebApi em Asp .NET Core

Criação da API

Estrutura da API

Edite o arquivo Startup.cs, adicione o using Microsoft.Extensions.Logging e no método Configure, adicione um novo parâmetro: ILoggerFactory loggerFactory

E adicione no método as configurações de Console e Debug, desta forma o Log vai ser feito pelo Console do Visual Studio em tempo de depuração.

Alteração do método Main()

Vamos criar uma nova controller para API chamada Cidade, e vamos injetar o ILogger no construtor da controller

Injeção da interface do ILogger

Adicionei um método GET na API, e vou logar como informação o Id que está sendo passado ao método.

Log de informação com Id de Evento

Ao executar o método na API, o Log é executado no console do Visual Studio em tempo de depuração:

Log no console do Visual Studio

Obs: O ILogger tem várias categorias, além do Information que são:

Error
Critical
Trace
Warning
Debug

Ótimo, mas além logar somente em debug não me adianta muita coisa, quero e preciso logar todas as entradas na API, e também logar todas as exceções que possam acontecer na aplicação.
Para isso, temos que criar uma extensão do ILogger e fazer com que o provider salve os dados do log em um banco de dados. Com isso criei esta estrutura na solução:

Para criar a extensão, temos que usar o ILoggerFactory para criar um novo contexto, um novo provider para configurar o Log a ser registrado em um banco de dados.

Essa configuração está na classe AppLoggerExtensions

Configurar um novo contexto de Log

Depois temos que sobrescrever o método de Log, herdando do ILoggerProvider
Essa implementação está na classe AppLoggerProvider

Sobrescrevendo o método de criar Log

Para depois de fato criar o Log no banco de dados, obtendo as informações que foram colocadas no Log, também sobrescrevendo o método de Log, herdando de ILogger

Essa implementação está na classe AppLogger

Sobrescrevendo o método de criar Log

Criei também, um repositório para executar o log no banco de dados.

Para isso, criei uma tabela em meu banco de dados chamada EventLog, com essa estrutura:

Tabela de Log

Criei uma entidade LogEvento, para ser de model da tabela

Entidade LogEvento

Na classe RepositorioLogger existe um método para executar o comando no banco.

Antes de rodar a API, precisamos adicionar esse novo provider nas configurações da API. Edite o arquivo Startup.cs e adicione o novo contexto, passando a string de conexão de seu banco de dados.

Enfim, rodando a aplicação e executando a API, o Log é inserido na tabela EventLog.

Executando a API pelo Postman

Log na tabela do banco de dados, como no exemplo acima tínhamos escrito.

Controller da API

Log incluído na tabela

Fazendo corretamente as configurações, vocês terão controle de Log em sua aplicação de forma fácil e simples, sem depender de Dlls de terceiros ou fazer na mão.

Espero que tenham gostado do artigo e até a próxima!

Segue o fonte de exemplo em meu Github
Marraia-Log

Utilizando Kafka em suas aplicações AspNet Core

Fernando Mendes — Tue, 24 Sep 2019 17:28:04 +0000

Olá pessoal, tudo bem com vocês?!

Depois de quase um ano sem escrever, por vários motivos profissionais e pessoais, estou aqui escrevendo novamente. Depois também de várias pessoas me cobrarem por retornar a escrever.

Mas vamos lá, talvez seja um assunto que alguns de vocês podem já conhecer, e já usam, mas mesmo assim resolvi escrever sobre esse tema, e fazer um exemplo da utilização do Apache Kafka com AspNet Core.

Primeiramente, preciso explicar para aqueles que ainda não conhecem o Apache Kafka, para que ele serve.

O Apache Kafka, foi desenvolvido na linguagem Scala e Java, e para quem já usa o RabbitMQ para processamento de filas e troca de mensagens, o conceito é o mesmo, mas com algumas diferenças, principalmente performance, e diferente conteúdo de mensagem, como por exemplo streaming, sim isso mesmo que você leu, streaming..

O Apache Kafka, é muito mais performático que o RabbitMQ, ele lida com alta taxa de transferência, bilhões de mensagens. No seu design, foi dada uma atenção especial para o manuseio eficiente de vários consumidores do mesmo fluxo que leem em velocidades diferentes (streamimg)

Vamos fazer um exemplo, de como usar o Apache Kafka.

Primeiramente, vamos fazer a instalação do serviço do Apache Kafka em algum servidor, irei instalar o serviço no Docker. Procurei uma imagem oficial, mas não encontrei, existem algumas por ai, mas irei usar essa que deu certo wurstmeister/kafka

Segue o compose a ser executado em seu servidor com Docker.

Depois de executar o compose, pode perceber que você terá dois serviços rodando, o Apache Kafka e o Apache ZooKeeper.

Dai agora você se pergunta: Fernando, o que é esse tal de Apache ZooKeeper?
O Apache Kafka, usa o Apache ZooKeeper, para manter e coordenar os brokers. Ele é responsável por controlar o status dos nós do cluster e permite que vários clientes executem leituras e gravações simultâneas.

Com o Apache Kafka funcionando em seu Docker junto com o Apache ZooKeeper, vamos criar uma API(Producer) e um Hosted Service (Consumer) em Asp Net Core.

Estrutura da solução

Nos dois projetos, vamos adicionar referência:
PM> Install-Package Confluent.Kafka -Version 1.1.0

Essa referência, irá fazer nos comunicar com o serviço do Apache Kafka.
No projeto Kafka.Producer.API, vamos criar uma nova controller de nome Producer, e adicionar esse código:

Veja que na linha 29, colocamos o nome da “fila”, de “fila_pedido”. Isso foi configurado na criação do container. No Apache Kafka, nos chamamos de Tópico.
Quer dizer, para qual canal iremos mandar a mensagem,e por qual canal iremos obter a mensagem.

Neste caso, fizemos quem irá mandar a mensagem. Agora, a seguir vamos codificar, quem irá receber a mensagem.

No projeto Kafka.Consumer.Handler, vamos criar uma classe de nome MessageHandler.cs, para ser o consumidor da mensagem.

Iremos adicionar esse código nessa classe.

Veja que na linha 20, eu adiciono de qual canal iremos ler as mensagens enviadas.
Caso tenha a mensagem, iremos adicionar no Log a mensagem recebida.
Vamos rodar a aplicação, e ir nesse endereço: http://localhost:55080/swagger/index.html

Swagger
Já adicionei o Swagger na aplicação, e vou colocar uma mensagem a ser enviada.

Quando a mensagem é enviada, o consumer recebe a mensagem:

Mensagem de Log

Bom gente, está um exemplo simples de como usar o Apache Kafka em suas
aplicações, microserviços em Asp Net Core utilizando Docker para hospedar o serviço do Apache Kafka.

Para suas aplicações que terá um grande volume de mensagens, e precisa de muita performance, ai está o Apache Kafka.

Espero terem gostado, segue o fonte em meu Github
Marraia-Kafka

Um grande abraço e até a próxima!