RabbitMQ Warten, bis eine Meldung mit einem timeout

Ich würde gerne eine Nachricht senden, die eine RabbitMQ-server und warten dann auf eine Antwort-Nachricht (auf eine "reply-to" - Warteschlange). Natürlich, ich will nicht ewig warten, falls die Anwendung die Verarbeitung dieser Nachrichten ist down - muss es ein timeout. Es klingt wie eine sehr einfache Aufgabe sein, doch ich kann nicht einen Weg finden, dies zu tun. Ich habe jetzt dieses problem mit Java-API.

InformationsquelleAutor Sameek Mishra | 2010-09-21
  1. 2

    Den RabbitMQ-Java-client-Bibliothek jetzt unterstützt eine timeout-argument, um Ihre QueueConsumer.nextDelivery() Methode.

    Beispielsweise die RPC tutorial verwendet den folgenden code:

    channel.basicPublish("", requestQueueName, props, message.getBytes());

while (true) {
    QueueingConsumer.Delivery delivery = consumer.nextDelivery();
    if (delivery.getProperties().getCorrelationId().equals(corrId)) {
        response = new String(delivery.getBody());
        break;
    }
}

    Nun können Sie consumer.nextDelivery(1000) zu warten, für maximal eine Sekunde. Wenn das timeout erreicht ist, gibt die Methode null.

    channel.basicPublish("", requestQueueName, props, message.getBytes());

while (true) {
    //Use a timeout of 1000 milliseconds
    QueueingConsumer.Delivery delivery = consumer.nextDelivery(1000);

    //Test if delivery is null, meaning the timeout was reached.
    if (delivery != null &&
        delivery.getProperties().getCorrelationId().equals(corrId)) {
        response = new String(delivery.getBody());
        break;
    }
}
    InformationsquelleAutor Jean-Sébastien Pédron
  2. 1

    com.rabbitmq.client.QueueingConsumer hat eine nextDelivery(long timeout) Methode, die tun, was Sie wollen. Dies wurde jedoch abgelehnt.
    Schreiben Sie Ihre eigene timeout ist nicht so schwer, obwohl es vielleicht besser sein, um einen Laufenden thread und eine Liste von in-time IDS, anstatt das hinzufügen und entfernen von Verbrauchern und damit verbundenen timeout-threads die ganze Zeit.

    Bearbeiten, um hinzuzufügen: Bemerkt, das Datum, an diese nach der Beantwortung!

    InformationsquelleAutor Dan
  3. 0

    Näherte ich mich diesem problem mit Hilfe von C# durch das erstellen eines Objekts zu verfolgen, die Reaktion auf eine bestimmte Nachricht. Setzt es eine eindeutige Antwort-queue eine Nachricht, und abonniert Sie. Wenn die Antwort nicht empfangen wird, in einem festgelegten Zeitrahmen, einen countdown-timer, kündigt das Abonnement, das löscht die Warteschlange. Unabhängig davon habe ich Methoden, die synchron von meinem Haupt-thread (verwendet eine semaphore) oder asynchron (mit einem callback zu nutzen diese Funktionalität.

    Grundsätzlich, die Umsetzung sieht wie folgt aus:

    //Synchronous case:
//Throws TimeoutException if timeout happens
var msg = messageClient.SendAndWait(theMessage);

//Asynchronous case
//myCallback receives an exception message if there is a timeout
messageClient.SendAndCallback(theMessage, myCallback);
    InformationsquelleAutor theMayer
  4. -1

    Gibt es ähnliche Frage. Obwohl es die Antworten von java nicht verwendet, vielleicht können Sie einige Hinweise.

    Warten auf eine Einzel-RabbitMQ-Meldung mit einem timeout

    InformationsquelleAutor Curry
Schreibe einen Kommentar