Domanda

Secondo il Pika documentazione "il broker RabbitMQ usa TCP contropressione a rallentare il vostro cliente se è la consegna dei messaggi troppo in fretta." Ho registrato un callback contropressione e deve ancora essere chiamato. La mia coda ha più di 40 milioni di messaggi e sta crescendo. Impostando il moltiplicatore contropressione a -1 posso ottenere il mio callback di essere chiamato su ogni messaggio di pubblicare, ma che è utile solo per il debug.

È stato utile?

Soluzione

Non è proprio quando "il vostro cliente ... è la consegna dei messaggi troppo veloce", ma quando tutto il cliente è la consegna dei messaggi troppo veloce.

monitor RabbitMQ la quantità di memoria che sta utilizzando ed eserciterà contropressione quando passa sopra una certa frazione della memoria fisica del computer. Per impostazione predefinita, questa frazione è 0.4, ma può essere modificato. Per ulteriori informazioni, vedere http://www.rabbitmq.com/memory.html .

Autorizzato sotto: CC-BY-SA insieme a attribuzione
Non affiliato a StackOverflow
scroll top