RabbitMQ asynchrone Unterstützung

Macht die RabbitMQ .NET-client haben irgendeine Art von asynchroner support? Ich möchte in der Lage, eine Verbindung herstellen und konsumieren Nachrichten asynchron, aber habe noch keinen Weg gefunden, um zu tun, entweder so weit.

(Für das konsumieren von Nachrichten, die ich verwenden können, die EventingBasicConsumer, aber das ist nicht eine komplette Lösung.)

Nur zu geben, einige Kontext ist dies ein Beispiel, wie ich arbeite mit RabbitMQ im moment (code übernommen aus meinem blog):

var factory = new ConnectionFactory() { HostName = "localhost" };

using (var connection = factory.CreateConnection())
{
    using (var channel = connection.CreateModel())
    {
        channel.QueueDeclare("testqueue", true, false, false, null);

        var consumer = new EventingBasicConsumer(channel);
        consumer.Received += Consumer_Received;
        channel.BasicConsume("testqueue", true, consumer);

        Console.ReadLine();
    }
}
  • kannst du ein wenig konkreter? was meinst du mit "asynchron" in diesem Fall? was versuchen Sie zu erreichen?
  • async/await... also ich bin auf der Suche nach Entsprechungen, die erwartbaren und zurückgeben von Aufgaben, wie System.IO hat z.B. ConnectAsync(), ReadAsync(), etc.
InformationsquelleAutor Gigi | 2015-08-12
  1. 19

    Kaninchen unterstützt versandfertig in asynchrone message-Handler durch die AsyncEventingBasicConsumer Klasse. Es funktioniert ähnlich wie die EventingBasicConsumer, sondern ermöglicht Ihnen die Registrierung einer callback-das gibt einen Task. Der callback wird ausgelöst, und die zurückgegebenen Task erwartet von der RabbitMQ-client.

    var factory = new ConnectionFactory
{
    HostName = "localhost",
    DispatchConsumersAsync = true
};

using(var connection = cf.CreateConnection())
{
    using(var channel = conn.CreateModel())
    {
        channel.QueueDeclare("testqueue", true, false, false, null);

        var consumer = new AsyncEventingBasicConsumer(model);

        consumer.Received += async (o, a) =>
        {
            Console.WriteLine("Message Get" + a.DeliveryTag);
            await Task.Yield();
        };
    }

    Console.ReadLine();
}
    • Oh, wunderbar! Ist das ein Neuzugang?
    • Ich kann nicht ganz genau feststellen, welche Version das war, aber die relevanten verpflichtet sind, ab Februar 2017.
    • Scheint, wie es seit der 5.0.0-pre3.
    • Wir haben die async-Unterstützung für die Produzenten?
    • Wir haben die async-Unterstützung für die Produzenten?
    • nicht dass ich wüsste.
    • Turner, sind Sie in der Lage, zu schauen, hier meine Frage: stackoverflow.com/questions/55284924/...? Ich glaube, es kann, ähnlich wie diese. Danke. +1.
    • Hat es funktioniert für Sie? Sie nicht haben, um die DispatchConsumersAsync - flag auf true?

    InformationsquelleAutor Paul Turner
  2. 7

    gibt es keine async/await-Unterstützung gebaut, um die RabbitMQ .NET-client an dieser Stelle. Es ist ein offenes ticket, für das auf der RabbitMQ .NET-Client-repository

    InformationsquelleAutor Derick Bailey
  3. 3

    Zusammenzufassen aktuellen async/TPL Unterstützung:

    • Wie @paul-turner erwähnt, gibt es nun eine AsyncEventingBasicConsumer Sie sich anmelden können, Veranstaltungen, für und zurückgeben Task.
    • Es gibt auch eine AsyncDefaultBasicConsumer, für die Sie überschreiben können virtuelle Methoden wie HandleBasicDeliver und zurückgeben Task. Original PR hier (wie es aussieht wurde auch eingeführt in 5.0?)
    • Pro die letzten Kommentare auf der oben genannten PR-und dieses Problem, wie es aussieht, arbeiten Sie an einer neuen, von Grund auf .NET-client, das würde mehr voll unterstützen async Betrieb, aber ich sehe keine spezifischen links zu diesen Bemühungen.
    InformationsquelleAutor Tobias J
Schreibe einen Kommentar