HarakaMQ

? La cola de mensajes no funciona actualmente. Estoy trabajando para solucionarlo. Estoy trabajando en esta rama https://github.com/Rotvig/HarakaMQ/tree/add_unit_tests?

HarakaMQ

Middleware confiable orientado a mensajes basado en UDP

Garantías

• Entrega de mensajes
• Orden de mensajes entre corredores distribuidos
• Consistencia final

Desarrollo

• Conmutación por error cuando un corredor deja de funcionar en una configuración de clúster
• Conciliación cuando un corredor se reincorpora a un clúster
• Descubrimiento automático de intermediarios y clientes en una configuración de clúster
• Agregar un nuevo corredor sin reiniciar un clúster

Nuget

HarakaMQ.Cliente

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

Agente de mensajes

Inicie el Broker creando el proyecto MessageBroker y ejecútelo con el comando "dotnet HarakaMQ.MessageBroker.dll". Cuando se ejecuta en una configuración de clúster, tenga una carpeta separada con los archivos DLL creados para cada corredor que tenga. Recuerde agregar un archivo "settings.json" en el directorio de ejecución con este contenido:

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

Suscribir

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

Repositorio de prueba

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