NeoBus

ネオブス

Neobusは、.NETのCQRSパターンを使用してコマンド、クエリ、およびイベントを送信できる強力なライブラリです。カフカとシームレスに統合することにより、分散システムとイベント駆動型アーキテクチャの実装を簡素化します。 Neobusが役立つと思う場合は、サポートを示すためにスターを与えることを検討してください。

インストール

Nugetパッケージマネージャーを介してNeobusを簡単にインストールできます。

 > Install-Package NeoBus

構成

neobusを構成するには、次の設定をappsettings.jsonファイルに追加し、kafkaサーバーアドレスを指定します。

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

登録

ConfigureServicesメソッド内のStartup.csファイルに登録することにより、プロジェクトに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の使用方法を示すサンプルプロジェクトを探索します。

ネオブを使用するためのサンプル

Docker Composeで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. کاربردeventbus陳esbusفیネオブス（ペルシャ語）

これらのリソースを自由に調査して、Neobusとその能力の理解を高めてください。