NeoBus

Néobus

Neobus est une bibliothèque puissante qui vous permet d'envoyer des commandes, des requêtes et des événements en utilisant le modèle CQRS dans .NET. Il simplifie la mise en œuvre de systèmes distribués et d'architectures axées sur les événements en intégrant de manière transparente à Kafka. Si vous trouvez Neobus utile, envisagez de lui donner une star pour montrer votre soutien.

Installation

Vous pouvez facilement installer Neobus via Nuget Package Manager:

 > Install-Package NeoBus

Configuration

Pour configurer Neobus, ajoutez les paramètres suivants dans votre fichier appsettings.json et spécifiez votre adresse de serveur Kafka:

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

Inscription

Incorporez Neobus dans votre projet en l'enregistrant dans le fichier Startup.cs dans la méthode ConfigureServices :

services . AddNeoBus ( Assembly . GetExecutingAssembly ( ) ) ;

Événements distribués (Kafka)

Pour les événements distribués à l'aide de Kafka, enregistrez les services nécessaires comme suit:

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

Si vous utilisez une version inférieure à 1.2.0, utilisez le code suivant pour enregistrer et enregistrer manuellement les commandes et les requêtes:

services . AddNeoBus ( ) ;

Enregistrement des commandes, des requêtes et des événements en mémoire

Pour enregistrer les commandes et les requêtes, suivez ces étapes:

Commands et gestionnaires de requête:

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

Handleurs d'événements en mémoire:

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

Échantillon de projet

Explorez un exemple de projet qui montre comment utiliser Neobus:

Échantillon pour une utilisation Neobus

Configuration de Kafka avec Docker Compose

Pour exécuter Kafka localement, suivez ces instructions:

1. Installez Docker sur votre machine locale.
2. Téléchargez le fichier docker-compose-kafka.yml à partir de la solution de projet.
3. Ouvrez votre terminal en tant qu'administrateur.
4. Accédez au répertoire contenant le fichier docker-compose-kafka.yml .
5. Exécutez la commande suivante:

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

Maintenant, Kafka est opérationnel dans un conteneur Docker.

Apprendre encore plus

Pour plus d'informations sur Neobus et ses applications, envisagez de lire les articles suivants:

1. Application EventBus et introduction du package Neobus
2. کاربرد Eventbus و معرفی پکیج Neobus (persan)

N'hésitez pas à explorer ces ressources pour améliorer votre compréhension de Neobus et de ses capacités.