HarakaMQ

？目前，消息队列无法正常工作，我正在努力修复它。我正在这个分支上工作 https://github.com/Rotvig/HarakaMQ/tree/add_unit_tests ？

HarakaMQ

基于UDP的可靠消息中间件

保证

• 消息传递
• 分布式代理之间的消息顺序
• 最终一致性

发展

• 当代理在集群设置中出现故障时进行故障转移
• 代理重新加入集群时的协调
• 集群设置中的代理和客户端自动发现
• 添加新代理而无需重新启动集群

努盖特

HarakaMQ.客户端

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

消息代理

通过构建 MessageBroker 项目来启动 Broker，并使用命令“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