تنزيل HarakaMQ - تنزيل كود مصدر HarakaMQ

HarakaMQ

فئات أخرى

vert to netstandard and added more usability to the messagebroker

تنزيل

؟ قائمة انتظار الرسائل لا تعمل حاليًا وأنا أعمل على إصلاحها. أنا أعمل في هذا الفرع https://github.com/Rotvig/HarakaMQ/tree/add_unit_tests؟

HarakaMQ

برمجيات وسيطة موثوقة موجهة للرسائل تعتمد على UDP

الضمانات

تسليم الرسالة
ترتيب الرسائل عبر الوسطاء الموزعين
الاتساق في نهاية المطاف

تطوير

فشل عندما يتعطل الوسيط في إعداد المجموعة
التسوية عندما ينضم الوسيط مرة أخرى إلى المجموعة
الاكتشاف التلقائي للوسيط والعميل في إعداد المجموعة
إضافة وسيط جديد دون إعادة تشغيل الكتلة

نوجيت

HarakaMQ.Client

https://www.nuget.org/packages/HarakaMQ.Client/

وسيط الرسائل

قم بتشغيل الوسيط من خلال بناء مشروع messageBroker، وتشغيله باستخدام الأمر "dotnet HarakaMQ.MessageBroker.dll". عند التشغيل في مجموعة إعداد، يكون لديك مجلد منفصل يحتوي على ملفات dll المضمنة لكل وسيط لديك. تذكر إضافة ملف "settings.json" في الدليل قيد التشغيل بهذا المحتوى:

{  
   "BrokerPort" : 11100 ,
   "PrimaryNumber" : 1 ,
   "AntiEntropyMilliseonds" : 1000 ,
   "RunInCLusterSetup" : false ,
   "Brokers" :[]
}

نشر

 var factory = new ConnectionFactory { HostName = "127.0.0.1" , ListenPort = 11000 , Port = 11100 } ;
using ( var connection = factory . CreateConnection ( ) )
using ( var channel = connection . CreateModel ( ) )
{
    channel . QueueDeclare ( "hello" ) ;
    channel . BasicPublish ( "hello" , Encoding . UTF8 . GetBytes ( "Hello world" ) ) ;

    Console . WriteLine ( " Press [enter] to exit." ) ;
    Console . ReadLine ( ) ;
}

يشترك

 var factory = new ConnectionFactory { HostName = "127.0.0.1" , ListenPort = 12000 , Port = 11100 } ;
using ( var connection = factory . CreateConnection ( ) )
using ( var channel = connection . CreateModel ( ) )
{
    channel . QueueDeclare ( "hello" ) ;
    var consumer = new DefaultBasicConsumer ( channel ) ;
    consumer . Received += ( model , ea ) =>
    {
        Console . WriteLine ( Encoding . UTF8 . GetString ( ea . Body ) ) ;
    } ;
    channel . BasicConsume ( "hello" , consumer ) ;

    Console . WriteLine ( " Press [enter] to exit." ) ;
    Console . ReadLine ( ) ;
}