NeoBus

Neobus

Neobus es una poderosa biblioteca que le permite enviar comandos, consultas y eventos utilizando el patrón CQRS en .NET. Simplifica la implementación de sistemas distribuidos y arquitecturas basadas en eventos integrándose sin problemas con Kafka. Si le resulta útil a Neobus, considere darle una estrella para mostrar su apoyo.

Instalación

Puede instalar fácilmente Neobus a través de Nuget Package Manager:

 > Install-Package NeoBus

Configuración

Para configurar Neobus, agregue la siguiente configuración a su archivo appsettings.json y especifique su dirección del servidor Kafka:

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

Registro

Incorpore neobus en su proyecto registrándolo en el archivo Startup.cs dentro del método ConfigureServices :

services . AddNeoBus ( Assembly . GetExecutingAssembly ( ) ) ;

Eventos distribuidos (Kafka)

Para eventos distribuidos utilizando Kafka, registre los servicios necesarios de la siguiente manera:

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

Si está utilizando una versión inferior a 1.2.0, use el siguiente código para registrar y registrar manualmente comandos y consultas:

services . AddNeoBus ( ) ;

Registro de comandos, consultas y eventos en memoria

Para registrar comandos y consultas, siga estos pasos:

Controladores de comando y consultas:

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

Manitadores de eventos en memoria:

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

Proyecto de muestra

Explore un proyecto de muestra que demuestre cómo usar Neobus:

Muestra para usar neobus

Configuración de Kafka con Docker Compose

Para ejecutar Kafka localmente, siga estas instrucciones:

1. Instale Docker en su máquina local.
2. Descargue el archivo docker-compose-kafka.yml desde la solución del proyecto.
3. Abra su terminal como administrador.
4. Navegue al directorio que contiene el archivo docker-compose-kafka.yml .
5. Ejecute el siguiente comando:

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

Ahora Kafka está en funcionamiento en un contenedor Docker.

Obtenga más información

Para obtener más información sobre Neobus y sus aplicaciones, considere leer los siguientes artículos:

1. Aplicación e introducción de EventBus del paquete Neobus
2. کارusión EventBus و معرفی پکیج Neobus (persa)

Siéntase libre de explorar estos recursos para mejorar su comprensión de Neobus y sus capacidades.