Wie kann sichergestellt werden, dass Nachrichten zugestellt werden?

Question

Wie stellen Sie sicher, dass Nachrichten mit Pika geliefert werden? Standardmäßig wird Ihnen kein Fehler angezeigt, wenn die Nachricht nicht erfolgreich zugestellt wurde.

In diesem Beispiel können mehrere Nachrichten gesendet werden, bevor Pika bestätigt, dass die Verbindung unterbrochen wurde.

import pika 

connection = pika.BlockingConnection(pika.ConnectionParameters(
     host='localhost')) 
channel = connection.channel() 
channel.queue_declare(queue='hello') 
for index in xrange(10): 
    channel.basic_publish(exchange='', routing_key='hello', 
          body='Hello World #%s!' % index) 
    print('Total Messages Sent: %s' % x) 
connection.close() 

Answer 1

Bei der Verwendung von Pika die channel.confirm_delivery() Flag gesetzt werden muss, bevor Sie veröffentlichen Nachrichten beginnen. Dies ist wichtig, damit Pika bestätigen kann, dass jede Nachricht erfolgreich gesendet wurde, bevor die nächste Nachricht gesendet wird. Dies erhöht jedoch die Zeit, die zum Senden von Nachrichten an RabbitMQ benötigt wird, da die Zustellung bestätigt werden muss, bevor das Programm mit der nächsten Nachricht fortfahren kann.

channel.confirm_delivery() 

try: 
    for index in xrange(10): 
     channel.basic_publish(exchange='', routing_key='hello', 
           body='Hello World #%s!' % index) 
     print('Total Messages Sent: %s' % x) 
except pika.exceptions.ConnectionClosed as exc: 
    print('Error. Connection closed, and the message was never delivered.') 

basic_publish ein Boolean je zurück, wenn die Nachricht gesendet wurde oder nicht. Es ist jedoch wichtig, potenzielle Ausnahmen zu erfassen, falls die Verbindung während der Übertragung geschlossen wird, und sie entsprechend zu behandeln. In diesen Fällen unterbricht die Ausnahme den Ablauf des Programms.