NeoBus

Neobus

Neobus เป็นไลบรารีที่ทรงพลังที่ช่วยให้คุณสามารถส่งคำสั่งการสืบค้นและเหตุการณ์โดยใช้รูปแบบ CQRS ใน. NET มันทำให้การใช้งานระบบแบบกระจายและสถาปัตยกรรมที่ขับเคลื่อนด้วยเหตุการณ์ง่ายขึ้นโดยการรวมเข้ากับ Kafka อย่างราบรื่น หากคุณพบว่า Neobus มีประโยชน์โปรดพิจารณาให้ดาวแสดงการสนับสนุนของคุณ

การติดตั้ง

คุณสามารถติดตั้ง Neobus ผ่าน Nuget Package Manager ได้อย่างง่ายดาย:

 > Install-Package NeoBus

การกำหนดค่า

ในการกำหนดค่า neobus ให้เพิ่มการตั้งค่าต่อไปนี้ในไฟล์ appsettings.json ของคุณและระบุที่อยู่เซิร์ฟเวอร์ kafka ของคุณ:

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

การลงทะเบียน

รวม Neobus เข้ากับโครงการของคุณโดยการลงทะเบียนในไฟล์ Startup.cs ภายในวิธี ConfigureServices :

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

การตั้งค่า 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 ومعرفی neobus (เปอร์เซีย)

อย่าลังเลที่จะสำรวจทรัพยากรเหล่านี้เพื่อเพิ่มความเข้าใจของคุณเกี่ยวกับ Neobus และความสามารถของมัน