RabbitMQ Work-Queue pour la messagerie FanOut

Question

J'essaie d'étendre un système de messagerie RabbitMQ. Le système actuel est très simple - le producteur envoie un message à un échange de fanout et le message est géré par plusieurs consommateurs - routage en éventail classique.

J'ai plusieurs consommateurs de différents types (par exemple: un qui imprime à l'écran, un qui se connecte au fichier, un qui enregistre dans la base de données, ...). Mon défi - Je ne sais pas quelle est la meilleure façon d'élargir les consommateurs. Si j'ajoute d'autres consommateurs du même type, j'obtiendrai des doubles journaux ou des doubles entrées dans la base de données. ... (pensez à deux consommateurs de DB consommant à partir du même échange de fanout).

Je suppose que je peux créer un consommateur qui publie dans une file d'attente mais je me demande s'il existe une meilleure solution "intégrée" dans rabbitmq.

merci à l'avance, zf

Answer 1

Si vous avez besoin à l'échelle des consommateurs afin de consommer plus rapidement tous les messages provenant de l'échange de sortance dont vous avez besoin; consommatrice competive Vous avez donc besoin de plus de consommateurs attachés à la même file d'attente liée à l'échange de fanout.
De cette façon, chaque consommateur consommera un lot de messages indépendamment des autres. Le nombre de messages à l'intérieur du lot est défini à l'aide de la propriété comptage de prélecture (http://www.rabbitmq.com/consumer-prefetch.html).
De cette façon, dans votre cas, vous devriez être en mesure de faire évoluer les consommateurs en évitant les doubles journaux et les doubles entrées dans la base de données.