Wie sehen, welche Host wir

Question

verbunden

Mit RabbitMQ mit einem Cluster von Knoten, habe ich meine Fabrik und die Verbindung wie folgt auf (die .NET-Client):

var factory = new ConnectionFactory() 
{ 
    UserName = Properties.Settings.Default.RabbitMQUser, 
    Password = Properties.Settings.Default.RabbitMQPassword, 
    HostnameSelector = new RandomHostNameSelector(), 
    AutomaticRecoveryEnabled = true 
}; 
connection = factory.CreateConnection(Properties.Settings.Default.RabbitMQServers.Split(';')); 

Wo Properties.Settings.Default.RabbitMQServers eine halb- verwenden Doppelpunkt getrennte Liste von Servern:

clust01;clust02;clust03 

nach dem Anschließen ist es eine Möglichkeit, die Host es tatsächlich aufgenommen, um zu sehen und ist es eine Möglichkeit zu erkennen, wenn das könnte (ändern, weil der bestimmte Knoten abgestürzt ist, wurde gestoppt, oder neu gestartet)? factory.HostName gibt einfach localhost zurück.

Bearbeiten: Es scheint connection.Endpoint.HostName gibt Ihnen den tatsächlichen Hostnamen als @Evk und @Wally haben beide angegeben (danke). Aber gibt es eine Möglichkeit, eine Veränderung zu erkennen? Es scheint, dass IConnection hat eine ConnectionShutdown Ereignis, das Ich denke, könnte als Teil der Vermittlung von Hosts aufgerufen werden, aber es gibt keine entsprechende Start-oder Neustart-Ereignis (so nehme ich an, es würde den neuen Host noch nicht kennen) . Es gibt auch ConnectionBlocked und ConnectionUnblocked Ereignisse, aber sie sind undokumentiert, also habe ich keine Ahnung, was sie tun ...

Answer 1

Wie Hostnamen zu bekommen gefunden Sie bereits aus, wie für So erkennen Sie, wenn es sich ändert: Wenn Sie AutomaticRecoveryEnabled für Ihre Fabrik einstellen, gibt CreateConnection wirklich die Instanz AutorecoveringConnection zurück. Diese Klasse implementiert die spezielle Schnittstelle IRecoverable, für die Sie ein Ereignis benötigen. Um zu erkennen, wenn automatische Wiederherstellung geschieht, abonnieren Sie es wie folgt:

var connection = factory.CreateConnection(); 
((IRecoverable)connection).Recovery += (sender, args) => 
{ 
    // recovery happened 
}; 

Answer 2

Ich habe keine Umgebung, in der ich das testen kann, also könnte es völlig falsch sein.

Es sieht wie Sie die endpoint des connection-Objekt verwenden kann (IConnection) zurückgegeben:

(string) connection.Endpoint.HostName 

Cite: https://www.rabbitmq.com/releases/rabbitmq-dotnet-client/v1.4.0/rabbitmq-dotnet-client-1.4.0-net-2.0-htmldoc/type-RabbitMQ.Client.IConnection.html