RabbitMQ: die Injektion der Verbindung Fabrik

Ich bin versuchen, RabbitMQ für ein paar Windows-Dienste, die ich Schreibe, zur Erleichterung der Kommunikation zwischen Ihnen auf eine schnelle und zuverlässige Art und Weise. Allerdings bin ich im laufen in ein problem, wenn die versuchen, die wichtigsten windows-Dienst-Motoren, die brauchen, um verbindungen zu der RabbitMQ-server Ihr Ding machen.

Grundsätzlich die ConnectionFactory Objekt in RabbitMQ ist .NET-client ist nicht Abstrakt und implementiert keine Schnittstelle. Ich kann nicht sehen, eine offensichtliche Weg, um zu injizieren, diese Klasse mit einem IoC-container wie StructureMap. Auch die code-Beispiele in der Dokumentation zeigen nur krass newing it up, etwa so:

 ConnectionFactory factory = new ConnectionFactory();
 factory.Uri = "amqp://user:pass@hostName:port/vhost";
 IConnection conn = factory.CreateConnection();

Die Lösung, die sich mir stellt ist, schieben Sie die ganze Fabrik in den Dienst der Haupt - OnStart und OnStop Funktionen, die wirklich schwierig zu testen, und nicht von großem Interesse sowieso. Jedoch, lässt mich mit einem einzigen IConnection für den service, also, wenn eine Verbindung unterbrochen wird, in irgendeiner Weise hat der Dienst keine Möglichkeit, sich zu erholen und muss einfach beenden. Wenn die Hauptmaschine hatte Sicht auf die Fabrik, es könnte einfach produzieren ein neuer Anschluss und weiter. Aber wenn ich Spritzen, dass es keine Möglichkeit zum testen der Hauptmaschine, ohne eine Verbindung zu einem vorhandenen server!

Gibt es irgendetwas, was ich hier vermisst? Eine andere option bin ich nicht in Betracht? Wie kann ich mich über die Injektion dieser Fabrik, und wenn ich nicht kann, wie kann ich den Schaden begrenzen?

EDIT: Auch, im Nachhinein, bin ich vollkommen glücklich zu machen, eine Veränderung zu RabbitMQ ist .NET-client eine Schnittstelle implementieren, wenn jemand eine gute Idee hat, wie empfänglich der Haupt-dev-team wäre, um eine änderung wie diese. Ich würde gerne dazu beitragen, aber das Letzte, was ich will zu tun ist, haben meine Programme funktioniert auf einigen custom-version von RabbitMQ, wodurch der Hauptvorteil der Verwendung einer Drittanbieter-Bibliothek in den ersten Platz.

InformationsquelleAutor tmesser | 2012-11-01
  1. 5

    Der schwierige Teil ist, es sieht aus wie nach dem Dokumentation ConnectionFactory nicht implementieren Schnittstellen.

    Du bist also wirklich gelassen mit der Umsetzung Ihrer eigenen, so etwas wie

    public interface IConnectionFactory
{
    ConnectionFactory Get();
    ConnectionFactory Get(string uri);
}

public class ConnectionFactoryCreator : IConnectionFactory
{
    public ConnectionFactory Get(
        string uri = "amqp://user:pass@hostName:port/vhost")
    {
        return new ConnectionFactory
        {
            Uri = uri
        };
    }
}

    Für die Klasse, wo Sie landen, es zu benutzen,

    public class RabbitMQUserClass
{
    public ConnectionFactory ConnectionFactory {get; private set;}
    public RabbitMQUserClass(IConnectionFactory connectionFactory)
    {
        ConnectionFactory = connectionFactory.Get();
    }
}
    • Ich will es auch auf Platte, die ich nicht mag diese Lösung sehr stark aber Sie sind absolut richtig, dass es die einzige Möglichkeit, die ich habe mit der situation, wie Sie ist. Ich Schätze Ihre Zeit und vielen Dank für deine Hilfe.
    InformationsquelleAutor M Afifi
  2. 6

    Den RabbitMQ-C# - client ist ein low-level-pureish AMQP Umsetzung, würden Sie wahrscheinlich wollen, um wickeln Sie es in etwas höheren Ebene der Abstraktion, und dann zu registrieren, dass Sie mit der IoC-container.

    EasyNetQ, eine höhere Ebene der Abstraktion, die über den basic-client implementiert einen persistenten AMQP-Verbindung wieder her, nachdem eine Verbindung unterbrochen wurde (entweder über Netzwerk oder einen server bounce), und erstellt alle aktuellen Abonnements. Sie sind willkommen, nehmen an, dass der code, den Sie nützlich finden.

    Kurz, es ist eine Frage der Verpackung connection-management in eine Art PersistentConnection Klasse, und dann die Registrierung jedes Abonnement mit etwas code, um neu zu erstellen, nach einem erfolgreichen reconnect.

    Habe ich geschrieben ein blog-post auf die Verkabelung bis EasyNetQ, Windsor IoC-container und TopShelf. Ich habe diese Technik erfolgreich für den Aufbau RabbitMQ basiert die windows-Dienste.

    • Ich werde eifrig untersucht dieses. Wenn es so gut ist, wie ich hoffe, ich werde mich ändern, die akzeptierten Antworten mehr hier, mit Entschuldigungen zu M Afifi, natürlich.
    • Beim Versuch, die Installation über die NuGet-Paket, EasyNetQ darauf besteht ich bin bereits verweisen auf eine neuere version von RabbitMQ.Client, obwohl ich beseitigte die alte Referenz vollständig. Irgendeine Idee warum?
    • "EasyNetQ darauf besteht ich bin bereits verweisen auf eine neuere version." Kannst du ein bisschen genauer sein? Ist es eine runtime-assembly binding-problem, oder ist NuGet beschweren?
    • Sorry - NuGet ist, sich zu beschweren. Die spezifische Leistung, die ich sehe ist: Successfully installed 'RabbitMQ.Client 2.8.6'. Successfully installed 'Newtonsoft.Json 4.5.10'. Successfully installed 'EasyNetQ 0.8.1.37'. Install failed. Rolling back... Already referencing a newer version of 'RabbitMQ.Client'.
    • Es ist bemerkenswert, (Nachhinein, dass Sie einfach auf mich), dass es ein paar vergleichbare Baugruppen, NuGet ist die Installation ohne Beanstandung. Es installiert Fuchsbau ganz gut, zum Beispiel. Ich Bau in meinem Projekt als eine Notlösung, aber es sieht aus wie EasyNetQ hat mehr Zeug, das ich gerne verwenden würde.
    • Ich würde versuchen, entfernen alle NuGet Sachen, die Pakete.config-Datei von jedem Ihrer Projekte-und den Packages-Ordner von Ihrem root-Lösung. Dann Feuer NuGet und fügen Sie alles wieder.
    • Bingo, dass es aussortiert. Zeit zum starten basteln. Danke!

    InformationsquelleAutor Mike Hadlow
Schreibe einen Kommentar