RabbitMQ - Wie um zu prüfen, ob queue leer ist?

Ich habe eine web-service-Schnittstelle, die abstracts ein RabbitMQ-server (fragt mich nicht warum, ich weiss es ist ein unnötiger Schritt, aber ich muss). Das ist, ich Umfrage die Nachrichten aus der Warteschlange über einen web-service aufrufen, nicht direkt über amqp.

Konsum über basic.consumer blockiert die Ausführung Gewinde bis gibt es Nachrichten in der queue. Dies macht die web-service nicht zurück.

Code für die Abbildung:

    $connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
    $channel = $connection->channel();

    $channel->queue_declare(QUEUE_NAME, false, true, false, false);
    $ret = array('body' => '');

    $callback = function($msg) use ($channel, &$ret) {
        $ret['body'] = $msg->body;
        /*
        Here I would basic.cancel the consumer if there were no messages in the queue
        */
    };

    $channel->basic_consume(QUEUE_NAME, 'tag', false, true, false, false, $callback);

    if (count($channel->callbacks)) {
        $channel->wait(); //blocks here...
    }

    return $ret;
InformationsquelleAutor Ahmed Khalaf | 2015-09-08
  1. 6

    Wenn Sie möchten, um die Größe der Warteschlange sind, können Sie anrufen queue_declare mit php-amqlib, das zweite argument von return ist die Anzahl der Nachrichten in der Warteschlange.

      list($queue, $messageCount, $consumerCount) = $channel->queue_declare(QUEUE_NAME, true);

    Es ist wichtig, um die $passiv-argument auf true, wenn Sie rufen Sie die queue_declare () - Methode

    InformationsquelleAutor Arno
  2. 3

    Was ich tun wollte, ist erreicht basic.get.

    In php-amqlib:

    $channel->basic_get(QUEUE_NAME, true); //the second arg is no_ack.

    Das zweite argument kennzeichnet, dass keine Bestätigung erwartet wird, für die Nachricht. Das heißt, Sie müssen nicht "Flagge", eine Nachricht als gelesen für RabbitMQ, um sicher zu entfernen Sie es. Ohne es (es = false) Ergebnisse in nicht knallen die top-Nachricht.

    Warum all diese Mühe?

    War ich die Verpackung des RabbitMQ-code, der in eine http-web-service. Und das ist keine gute Idee (zumindest für meinen Anwendungsfall). Als wenn der web-service liefert und damit die rabbitmq-Verbindung beendet, die nicht (noch nicht) anerkannt Nachricht ist requeued zurück in die Warteschlange. Also, wenn Sie haben zu verfolgen eine http-wrapper, stellen Sie sicher, Sie isolieren die Lebensdauer der rabbitmq-Verbindung vom http-request-lieftime. Allerdings habe ich nicht versuchen, diese.

    • in Fall, dass Sie waren immer noch wollen, um die Größe der Warteschlange, wenn Sie erklären, exchange, gibt es eine Datenstruktur, die die aktuelle queue-Größe
    • AMQP-Referenz enthält: "Wenn dieses Feld gesetzt ist der server nicht erwarten, dass Bestätigungen für die Nachrichten. Das heißt, wenn eine Nachricht an den client, der server davon ausgegangen, dass die Lieferung erfolgreich sein wird, und sofort aus der Warteschlange entfernt es. Diese Funktionalität kann die Leistung erhöhen, aber auf Kosten der Zuverlässigkeit. Nachrichten können verloren gehen, wenn ein client stirbt, bevor Sie ausgeliefert werden an die Anwendung.". Wenn Sie ihn nicht eingestellt haben, müssen Sie ack die Nachricht, die Sie erhalten.
    • Ich verstehe nicht, die zweite Hälfte der Antwort (unter der überschrift). Empfehlen, Bearbeiten oder löschen, wenn es irrelevant für die Antwort.
    InformationsquelleAutor Ahmed Khalaf
Schreibe einen Kommentar