File d'attente vraiment durable dans RabbitMQ

Question

J'ai vérifié la partie "Durabilité du message" de RabbitMQ tutorial. Mais il a cette note:

Marquer les messages comme persistants ne garantit pas entièrement qu'un message ne sera pas perdu. Bien qu'il dise à RabbitMQ de sauvegarder le message sur le disque, il y a encore une petite fenêtre temporelle quand RabbitMQ a accepté un message et ne l'a pas encore enregistré. En outre, RabbitMQ ne fait pas fsync (2) pour chaque message - il peut être juste sauvé en cache et pas vraiment écrites sur le disque

Mais si je dois vraiment file d'attente durable? Quelles sont les meilleures pratiques que je peux utiliser? Dois-je avoir "queue" dans la base de données et un certain "resender" par cron si, par exemple, le message n'a pas été ACK dans 2 minutes? Y a-t-il de meilleures solutions?

En outre, que se passe-t-il si mon consommateur s'est brisé après avoir traité le message et avant il a envoyé ACK? UPD: ma question a été marquée comme "possible duplicate" de la question de clustering. Je ne sais pas comment les grappes peuvent aider à résoudre ces problèmes.

Answer 1

S'il vous plaît lire here à propos livraison garantie avec Tx

L'éditeur utiliserait quelque chose comme:

ch.txSelect(); 
ch.basicPublish("", QUEUE_NAME,MessageProperties.PERSISTENT_BASIC,"nop".getBytes()); 
ch.txCommit(); 

Note: Ceci peut tuer votre application de performance!

EDIT

Lire aussi "Editeur Confirme" https://www.rabbitmq.com/confirms.html comme suggesgted par @old_sound

Answer 2

Jetez un oeil à Confirme Publisher qui sont faits pour résoudre le problème de savoir si RabbitMQ a persisté/répliquées votre message ou non: https://www.rabbitmq.com/confirms.html