HelloWorld-Beispiel zum senden eines Objekts über RabbitMQ über EasyNetQ zwischen zwei verschiedenen Anwendungen

Soweit ich weiß, die Standard Einstellung der EasyNetQ erfordert den Typ des serialisierten Objekts konsistent zwischen den Anwendungen. Zum Beispiel, können Sie schicken jedem bekannt .NET einfach, wie String:

 bus.Publish<String>("Excellent.");

und es wird glücklich sein auf beide Projekte.

Können Sie Ihre eigene Mitteilung, wenn Sie legen Sie es auf eine gemeinsamen Bibliothek (dll). Da du speziell erwähnt, dass Sie befinden sich in verschiedenen Projekten, würde ich vorschlagen, zu serialisieren und gegossene Objekte selbst.

EasyNetQ verwendet, da er intern Newtonsoft Json.NET Objekte serialisieren, wie diese. Wie Sie sehen können, wurde die Nachricht serialisiert bereits als:

Meldung: {"Text":"Hallo Welt"}

Dies selbst zu tun, müssen Sie noch einen Verweis hinzufügen Json.NET da EasyNetQ versteckt sich dieser Bezug durch die Verwendung ilrepack.

Sollte dies funktionieren:

bus.Publish<string>(JsonConvert.SerializeObject(new MessageA { Text = "Hello World" }));

und

bus.Subscribe<string>("", HandleClusterNodes);

private static void HandleClusterNodes(string obj)
{
    var myMessage = (MessageB)JsonConvert.DeserializeObject<MessageB>(obj);
    Console.WriteLine(myMessage.Text);
}

Aber verlieren Sie Ihre Attribut-basiertes routing mit dieser und vielleicht möchten ändern Sie Ihre Methoden.

Wenn Sie möchten, dass Sie basic Methoden, Sie können Thema, wie dieses:

bus.Publish<string>(JsonConvert.SerializeObject(new MessageA { Text = "Hello World" }), "topic.name");

bus.Subscribe<string>("", HandleClusterNodes, new Action<EasyNetQ.FluentConfiguration.ISubscriptionConfiguration>( o => o.WithTopic("topic.name")));

Aber komplette Steuern, müssen Sie verwenden Erweiterte API;

var yourMessage = new Message<string>(JsonConvert.SerializeObject(new MessageA { Text = "Hello World" }));
bus.Advanced.Publish<string>(new Exchange("YourExchangeName"), "your.routing.key", false, false, yourMessage);

und auf dem Abonnenten-Teil:

IQueue yourQueue = bus.Advanced.QueueDeclare("AnotherTestMessagesQueue");
IExchange yourExchange = bus.Advanced.ExchangeDeclare("YourExchangeName", ExchangeType.Topic);
bus.Advanced.Bind(yourExchange, yourQueue, "your.routing.key");
bus.Advanced.Consume<string>(yourQueue, (msg, info) => HandleClusterNodes(msg.Body));

ist das fast gleiche wie das original RabbitMQ C# Client-API.

Detaillierte Analyse:

Das Hauptproblem ist diese Ausnahme:

EasyNetQ.EasyNetQException: kann Nicht finden, geben Sie EasyNetQSample.ProgramA+MessageA:EasyNetQSample

Diese wird ausgelöst durch EasyNetQ, weil es nicht finden können, die der besonderen Klasse auf dem endpoint.

Wenn wir uns an der Quelle-code der TypeNameSerializer.cs, werden Sie sehen,

var type = Type.GetType(nameParts[0] + ", " + nameParts[1]);
            if (type == null)
            {
                throw new EasyNetQException(
                    "Cannot find type {0}",
                    typeName);
            }

dies ist, wo es versucht, zu finden EasyNetQSample.ProgramA.NachrichtEine Typ auf zweiten Projekt, wenn Sie nur weiß, EasyNetQSample.ProgramB.NachrichtB.

Alternativ können Sie roll-out Ihrer eigenen ISerializer oder einen ITypeNameSerializer in der Standard - serializer aber ich habe nicht versucht, diese.

Furkan ist richtig, dass dein problem ist, dass der Teilnehmer Zugriff auf die Bedürfnisse MessageA Art definiert sich durch Ihren Verleger, so dass es Deserialisieren der Nachricht zu geben. Aus der EasyNetQ docs

Wenn Nachrichten serialisiert werden, EasyNetQ speichert die message-Typ name in der Type-Eigenschaft des message-Eigenschaften. Diese Metadaten gesendet, zusammen mit Ihrer Nachricht an alle Abonnenten, die können dann verwenden, um die Meldung Deserialisieren.

Diese Beträge, die zu einem engen gemeinsamen Vertrag zwischen publisher und consumer. Wenn Sie möchten, um Sie zu lockern, dass bis dann es gibt ein paar Dinge, die Sie tun können:

• Können Sie veröffentlichen und abonnieren basiert auf einer Schnittstelle (z.B. IMessage, aus denen Sie ableiten können MessageA). Sie werden immer noch Zugriff auf die MessageA geben, um die Besetzung der empfangenen Nachricht, aber Sie können veröffentlichen und abonnieren Sie ohne die Angabe eines bestimmten abgeleiteten Typ.

• Können Sie erstellen, die einen einzigen, gemeinsamen "container" - Typ (z.B. MessageContainer) und dann serialisieren/Deserialisieren Ihres Typs in eine Instanz des container-Typs als XML, JSON, was auch immer. Ihre Abonnenten können ziehen Sie die Daten aus dem container und analysiert werden, doch es will. Man könnte auch ein schema oder version info in den container-header zu geben, einige Hinweise auf den Abonnenten über, wie man die Daten analysieren. Der Punkt, dass Sie nie schalten Sie es in einen definierten Typ und brauchen deshalb keinen Zugriff auf einen Haufen von Typen, die nur auf die MessageContainer geben, so können Sie bei den serialisierten Inhalt.