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及其能力的理解。