Neobus هي مكتبة قوية تمكنك من إرسال الأوامر والاستعلامات والأحداث باستخدام نمط CQRS في .NET. إنه يبسط تنفيذ الأنظمة الموزعة والبنية التي تعتمد على الأحداث من خلال الاندماج بسلاسة مع كافكا. إذا وجدت 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 ( ) ) ;
للأحداث الموزعة باستخدام كافكا ، قم بتسجيل الخدمات اللازمة على النحو التالي:
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.yml
من داخل حل المشروع.docker-compose-kafka.yml
.docker-compose -f docker-compose-kafka.yml up
الآن كافكا تعمل في حاوية Docker.
لمزيد من المعلومات حول نيوبوس وتطبيقاتها ، فكر في قراءة المقالات التالية:
لا تتردد في استكشاف هذه الموارد لتعزيز فهمك لـ Neobus وقدراتها.