NeoBus

Neobus

Neobus adalah perpustakaan yang kuat yang memungkinkan Anda untuk mengirim perintah, pertanyaan, dan acara menggunakan pola CQRS di .net. Ini menyederhanakan implementasi sistem terdistribusi dan arsitektur berbasis peristiwa dengan mengintegrasikan dengan kafka. Jika Anda merasa neobus bermanfaat, silakan pertimbangkan untuk memberikan bintang untuk menunjukkan dukungan Anda.

Instalasi

Anda dapat dengan mudah menginstal Neobus melalui Nuget Package Manager:

 > Install-Package NeoBus

Konfigurasi

Untuk mengonfigurasi neobus, tambahkan pengaturan berikut ke file appsettings.json Anda dan tentukan alamat server kafka Anda:

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

Pendaftaran

Memasukkan neobus ke dalam proyek Anda dengan mendaftarkannya di file Startup.cs dalam metode ConfigureServices :

services . AddNeoBus ( Assembly . GetExecutingAssembly ( ) ) ;

Acara Terdistribusi (Kafka)

Untuk acara terdistribusi menggunakan kafka, daftarkan layanan yang diperlukan sebagai berikut:

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

Jika Anda menggunakan versi yang lebih rendah dari 1.2.0, gunakan kode berikut untuk mendaftar dan mendaftarkan perintah dan pertanyaan secara manual:

services . AddNeoBus ( ) ;

Mendaftarkan Perintah, Kueri, dan Acara dalam memori

Untuk mendaftarkan perintah dan pertanyaan, ikuti langkah -langkah ini:

Command and Query Handlers:

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

Penangan acara dalam memori:

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

Proyek Sampel

Jelajahi proyek sampel yang menunjukkan cara menggunakan neobus:

Sampel untuk penggunaan neobus

Menyiapkan Kafka dengan Docker Compose

Untuk menjalankan Kafka secara lokal, ikuti instruksi ini:

1. Instal Docker di mesin lokal Anda.
2. Unduh file docker-compose-kafka.yml dari dalam solusi proyek.
3. Buka terminal Anda sebagai administrator.
4. Arahkan ke direktori yang berisi file docker-compose-kafka.yml .
5. Jalankan perintah berikut:

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

Sekarang Kafka sudah habis dan berjalan dalam wadah Docker.

Pelajari lebih lanjut

Untuk informasi lebih lanjut tentang Neobus dan aplikasinya, pertimbangkan untuk membaca artikel berikut:

1. Aplikasi Eventbus dan Pengenalan Paket Neobus
2. کاربرد eventbus و معرفی پکیج neobus (Persia)

Jangan ragu untuk mengeksplorasi sumber daya ini untuk meningkatkan pemahaman Anda tentang neobus dan kemampuannya.