NeoBus

Neobus

Neobus是一个强大的库，使您可以使用.NET中的CQRS模式发送命令，查询和事件。它通过与Kafka无缝集成来简化分布式系统和事件驱动的体系结构的实现。如果您发现Neobus有帮助，请考虑给它一颗星星以表达您的支持。

安装

您可以通过Nuget Package Manager轻松安装Neobus：

 > Install-Package NeoBus

配置

要配置Neobus，请将以下设置添加到您的appsettings.json文件并指定您的KAFKA服务器地址：

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

登记

通过将Neoobus注册到Startup.cs文件中ConfigureServices将Neobus纳入您的项目：

services . AddNeoBus ( Assembly . GetExecutingAssembly ( ) ) ;

分布式事件（Kafka）

对于使用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样品

用Docker组成的Kafka

要在本地运行Kafka，请按照以下说明：

1. 在您的本地机器上安装Docker。
2. 从项目解决方案中下载docker-compose-kafka.yml文件。
3. 作为管理员打开您的终端。
4. 导航到包含docker-compose-kafka.yml文件的目录。
5. 运行以下命令：

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

现在，Kafka正在Docker容器中启动并运行。

了解更多

有关Neobus及其应用的更多信息，请考虑阅读以下文章：

1. EventBus应用和Neobus软件包的引入
2. the eventbusNeoobus（波斯语）

随时探索这些资源，以增强您对Neobus及其能力的理解。