HarakaMQ

? La file d'attente des messages ne fonctionne pas actuellement et je travaille à la corriger. Je travaille sur cette branche https://github.com/Rotvig/HarakaMQ/tree/add_unit_tests ?

HarakaMQ

Middleware fiable orienté message basé sur UDP

Garanties

• Livraison des messages
• Ordre des messages sur les courtiers distribués
• Cohérence éventuelle

Développement

• Basculer lorsqu'un courtier tombe en panne dans une configuration de cluster
• Réconciliation lorsqu'un courtier rejoint un cluster
• Découverte automatique du courtier et du client dans une configuration de cluster
• Ajouter un nouveau courtier sans redémarrage d'un cluster

Nuget

HarakaMQ.Client

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

Courtier de messages

Démarrez le Broker en créant le projet MessageBroker et exécutez-le avec la commande « dotnet HarakaMQ.MessageBroker.dll ». Lors de l'exécution dans une configuration de cluster, disposez d'un dossier séparé avec les DLL construites pour chaque courtier dont vous disposez. Pensez à ajouter un fichier "settings.json" dans le répertoire en cours d'exécution avec ce contenu :

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

Publier

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

S'abonner

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

Test du dépôt

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