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