Quando rabbitmq usa la contropressione tcp?

Question

Secondo il Pika documentation "il broker RabbitMQ utilizza TCP Backpressure per rallentare il client se recapita i messaggi troppo velocemente." Ho registrato una richiamata di retropressione e deve ancora essere chiamata. La mia coda ha più di 40 milioni di messaggi e sta crescendo. Impostando il moltiplicatore di backpressure su -1, è possibile richiamare la mia callback su ogni messaggio, ma è utile solo per il debug.

Answer 1

Non è vero quando "il tuo cliente ... recapita i messaggi troppo velocemente", ma quando un cliente invia messaggi troppo velocemente.

RabbitMQ monitora la quantità di memoria che sta utilizzando ed eserciterà una contropressione quando supera una certa frazione della memoria fisica sulla macchina. Per impostazione predefinita questa frazione è 0.4, ma può essere modificata. Vedi http://www.rabbitmq.com/memory.html per maggiori dettagli.