Download HarakaMQ - Download do código-fonte HarakaMQ

HarakaMQ

Outras categorias

vert to netstandard and added more usability to the messagebroker

Baixar

? A fila de mensagens não está funcionando no momento, estou trabalhando para corrigi-la. Estou trabalhando neste ramo https://github.com/Rotvig/HarakaMQ/tree/add_unit_tests ?

HarakaMQ

Middleware confiável orientado a mensagens baseado em UDP

Garantias

Entrega de mensagens
Ordem das mensagens entre corretores distribuídos
Consistência eventual

Desenvolvimento

Failover quando um agente fica inativo em uma configuração de cluster
Reconciliação quando um corretor ingressa novamente em um cluster
Descoberta automática de agente e cliente em uma configuração de cluster
Adicione um novo agente sem reiniciar um cluster

Nuget

HarakaMQ.Cliente

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

Corretor de mensagens

Inicie o Broker construindo o projeto MessageBroker e execute-o com o comando "dotnet HarakaMQ.MessageBroker.dll". Ao executar em uma configuração de cluster, tenha uma pasta separada com as DLLs construídas para cada corretor que você possui. Lembre-se de adicionar um arquivo “settings.json” no diretório em execução com este conteúdo:

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

Publicar

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

Inscrever-se

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