NeoBus

Neobus

Neobus é uma biblioteca poderosa que permite enviar comandos, consultas e eventos usando o padrão CQRS no .NET. Ele simplifica a implementação de sistemas distribuídos e arquiteturas orientadas por eventos, integrando-se perfeitamente ao Kafka. Se você achar útil Neobus, considere dar -lhe uma estrela para mostrar seu apoio.

Instalação

Você pode instalar facilmente o Neobus via Nuget Package Manager:

 > Install-Package NeoBus

Configuração

Para configurar o Neobus, adicione as seguintes configurações ao seu arquivo appsettings.json e especifique o endereço do servidor Kafka:

 "NeoBus" : {
    "Kafka" : {
        "Servers" : [ " localhost:9092 " ]
    }
}

Registro

Incorpore o Neobus em seu projeto, registrando -o no arquivo Startup.cs no método ConfigureServices :

services . AddNeoBus ( Assembly . GetExecutingAssembly ( ) ) ;

Eventos distribuídos (Kafka)

Para eventos distribuídos usando Kafka, registre os serviços necessários da seguinte forma:

services . AddHostedService < KafkaEventSubscriberService < ProductAddedEventOnKafka , ProductAddedEventOnKafkaHandler > > ( ) ;
services . AddSingleton < ProductAddedEventOnKafkaHandler > ( ) ;

Se você estiver usando uma versão inferior a 1.2.0, use o código a seguir para se registrar e registrar manualmente comandos e consultas:

services . AddNeoBus ( ) ;

Comandos de registro, consultas e eventos na memória

Para registrar comandos e consultas, siga estas etapas:

Manipuladores de comando e consulta:

services . AddScoped < IRequestHandler < ProductAddCommand , CommandResult > , ProductAddCommandHandler > ( ) ;
services . AddScoped < IRequestHandler < GetProductQuery , CommandResult > , GetProductQueryHandler > ( ) ; 

Manipuladores de eventos na memória:

services . AddScoped < INotificationHandler < ProductAddedEvent > , ProductAddedEventHandler > ( ) ; 

Projeto de amostra

Explore um projeto de amostra que demonstra como usar o Neobus:

Amostra para uso neobus

Configurando Kafka com Docker Compose

Para executar Kafka localmente, siga estas instruções:

1. Instale o docker na sua máquina local.
2. Faça o download do arquivo docker-compose-kafka.yml de dentro da solução do projeto.
3. Abra seu terminal como administrador.
4. Navegue até o diretório que contém o arquivo docker-compose-kafka.yml .
5. Execute o seguinte comando:

docker-compose -f docker-compose-kafka.yml up

Agora Kafka está em funcionamento em um recipiente do Docker.

Saber mais

Para obter mais informações sobre Neobus e suas aplicações, considere ler os seguintes artigos:

1. Aplicação e introdução do Eventbus do pacote Neobus
2. کاربر Sem Eventbus و معرفی پکیج neobus (persa)

Sinta -se à vontade para explorar esses recursos para aprimorar sua compreensão de Neobus e suas capacidades.