NeoBus

Необ

Neobus - это мощная библиотека, которая позволяет вам отправлять команды, запросы и события, используя шаблон CQRS в .NET. Он упрощает реализацию распределенных систем и архитектур, управляемых событиями, путем беспрепятственной интеграции с Kafka. Если вы найдете Neobus полезным, пожалуйста, подумайте о том, чтобы дать ему звезду, чтобы показать вашу поддержку.

Установка

Вы можете легко установить Neobus через диспетчер пакетов Nuget:

 > Install-Package NeoBus

Конфигурация

Чтобы настроить Neobus, добавьте следующие настройки в свой файл appsettings.json и укажите адрес сервера KAFKA:

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

Регистрация

Включите Neobus в ваш проект, зарегистрировав его в файле Startup.cs в методе ConfigureServices :

services . AddNeoBus ( Assembly . GetExecutingAssembly ( ) ) ;

Распределенные события (Кафка)

Для распределенных событий, используя Kafka, зарегистрируйте необходимые услуги следующим образом:

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

Если вы используете версию ниже 1.2.0, используйте следующий код для регистрации и вручную зарегистрировать команды и запросы:

services . AddNeoBus ( ) ;

Зарегистрирование команд, запросов и событий в памяти

Чтобы зарегистрировать команды и запросы, выполните следующие действия:

Запрашиватели команды и запросов:

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

Художники событий в памяти:

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

Образец проекта

Исследуйте образец проекта, который демонстрирует, как использовать Neobus:

Образец для использования Neobus

Настройка Kafka с Docker Compose

Чтобы запустить кафку на местном уровне, следуйте этим инструкциям:

1. Установите Docker на локальную машину.
2. Загрузите файл docker-compose-kafka.yml из решения проекта.
3. Откройте свой терминал в качестве администратора.
4. Перейдите к каталогу, содержащему файл docker-compose-kafka.yml .
5. Запустите следующую команду:

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

Теперь Кафка работает в контейнере Docker.

Узнать больше

Для получения дополнительной информации о Neobus и его приложениях, рассмотрите возможность прочитать следующие статьи:

1. Eventbus Применение и введение пакета Neobus
2. کاربرد eventbus و معرفی پکیج neobus (персидский)

Не стесняйтесь исследовать эти ресурсы, чтобы улучшить свое понимание Небуса и его возможностей.