HarakaMQ

? Очередь сообщений в настоящее время не работает, я работаю над ее исправлением. Я работаю над этой веткой https://github.com/Rotvig/HarakaMQ/tree/add_unit_tests?

ХаракаMQ

Надежное промежуточное программное обеспечение, ориентированное на сообщения, на основе UDP

Гарантии

• Доставка сообщений
• Порядок сообщений между распределенными брокерами
• Окончательная согласованность

Разработка

• Отработка отказа при выходе брокера из строя в настройке кластера
• Согласование при повторном присоединении брокера к кластеру
• Автоматическое обнаружение брокера и клиента в настройке кластера
• Добавить нового брокера без перезапуска кластера

Нугет

ХаракаMQ.Клиент

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