HarakaMQ

- ขณะนี้คิวข้อความไม่ทำงานในขณะที่ฉันกำลังแก้ไข ฉันกำลังทำงานในสาขานี้ https://github.com/Rotvig/HarakaMQ/tree/add_unit_tests ?

HarakaMQ

มิดเดิลแวร์เน้นข้อความที่เชื่อถือได้ซึ่งใช้ UDP

การค้ำประกัน

• การส่งข้อความ
• ลำดับของข้อความระหว่างนายหน้าแบบกระจาย
• ความสอดคล้องในที่สุด

การพัฒนา

• ล้มเหลวเมื่อนายหน้าหยุดทำงานในการตั้งค่าคลัสเตอร์
• การกระทบยอดเมื่อนายหน้ากลับเข้าร่วมคลัสเตอร์อีกครั้ง
• การค้นพบอัตโนมัติของนายหน้าและไคลเอนต์ในการตั้งค่าคลัสเตอร์
• เพิ่มโบรกเกอร์ใหม่โดยไม่ต้องรีสตาร์ทคลัสเตอร์

นูเก็ต

HarakaMQ.ลูกค้า

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 ( ) ;
}

ทดสอบซื้อคืน

https://github.com/Rotvig/HarakaMQ-Benchmark