NeoBus

Neobus

Neobus ist eine leistungsstarke Bibliothek, mit der Sie Befehle, Abfragen und Ereignisse mit dem CQRS -Muster in .NET senden können. Es vereinfacht die Implementierung von verteilten Systemen und ereignisorientierten Architekturen, indem sie nahtlos in Kafka integriert werden. Wenn Sie Neobus hilfreich finden, sollten Sie ihm einen Stern geben, um Ihre Unterstützung zu zeigen.

Installation

Sie können Neobus problemlos über Nuget Paket Manager installieren:

 > Install-Package NeoBus

Konfiguration

Um Neobus zu konfigurieren, fügen Sie die folgenden Einstellungen Ihrer appsettings.json -Datei hinzu und geben Sie Ihre KAFKA -Serveradresse an:

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

Anmeldung

Integrieren Sie Neobus in Ihr Projekt, indem Sie es in der Datei Startup.cs in der Methode ConfigureServices registrieren:

services . AddNeoBus ( Assembly . GetExecutingAssembly ( ) ) ;

Verteilte Ereignisse (Kafka)

Registrieren Sie für verteilte Ereignisse mit Kafka die erforderlichen Dienste wie folgt:

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

Wenn Sie eine Version unter 1.2.0 verwenden, verwenden Sie den folgenden Code, um Befehle und Abfragen manuell zu registrieren:

services . AddNeoBus ( ) ;

Registrieren Sie Befehle, Abfragen und Memory-Ereignisse

Befolgen Sie die folgenden Schritte, um Befehle und Abfragen zu registrieren:

Befehls- und Abfragehandler:

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

In-Memory-Event-Handler:

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

Beispielprojekt

Erforschen Sie ein Beispielprojekt, das zeigt, wie Neobus verwendet wird:

Probe zur Verwendung von Neobus

Einrichten von Kafka mit Docker Compose

Um Kafka lokal zu betreiben, folgen Sie folgenden Anweisungen:

1. Installieren Sie Docker auf Ihrem lokalen Computer.
2. Laden Sie die Datei docker-compose-kafka.yml aus der Projektlösung herunter.
3. Öffnen Sie Ihr Terminal als Administrator.
4. Navigieren Sie zum Verzeichnis, das die Datei docker-compose-kafka.yml enthält.
5. Führen Sie den folgenden Befehl aus:

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

Jetzt ist Kafka in einem Docker -Container in Betrieb.

Erfahren Sie mehr

Weitere Informationen zu Neobus und seinen Anwendungen finden Sie in Betracht, die folgenden Artikel zu lesen:

1. EventBus -Anwendung und Einführung des Neobus -Pakets
2. کاربرetter Eventbus و معرفی پکیج Neobus (Persisch)

Erforschen Sie diese Ressourcen, um Ihr Verständnis von Neobus und seinen Fähigkeiten zu verbessern.