Khi nào thỏmq sử dụng backcure tcp?

Question

Theo Pika documentation "nhà môi giới RabbitMQ sử dụng áp dụng TCP Backpressure để làm chậm ứng dụng khách của bạn nếu nó đang gửi thư quá nhanh". Tôi đã đăng ký một callback backpressure và nó vẫn chưa được gọi. Hàng đợi của tôi có hơn 40 triệu tin nhắn và nó đang phát triển. Bằng cách thiết lập hệ số backpressure thành -1 Tôi có thể nhận được callback của mình để được gọi trên mọi thông báo xuất bản, nhưng điều đó chỉ hữu ích để gỡ lỗi.

Answer 1

Không thực sự khi "khách hàng của bạn ... đang phân phối thư quá nhanh", nhưng khi bất kỳ khách hàng nào đang gửi thư quá nhanh.

RabbitMQ giám sát dung lượng bộ nhớ đang sử dụng và sẽ gây ấn tượng khi nó vượt qua một phần nhất định bộ nhớ vật lý trên máy. Theo mặc định, phân số này là 0,4, nhưng nó có thể thay đổi. Xem http://www.rabbitmq.com/memory.html để biết thêm chi tiết.