背压（Backpressure）

定义

背压(Backpressure,又译反压)是数据流系统中的一种流量控制机制:当下游消费速度跟不上上游生产速度时,压力沿数据流向上游传导,迫使上游减速或暂停发送,从而避免内存无限膨胀或数据被迫丢弃。

实现方式

• 拉取模型:消费者主动按能力拉取(如 Kafka 消费者),天然自带背压;
• 信用/请求配额:下游预先授予上游可发送的数量,用完即停,响应式流(Reactive Streams)规范的 request(n) 与 Flink 的网络缓冲区信用机制都属此类;
• 阻塞写入:有界队列写满即阻塞生产线程,是最朴素的形式。

权衡

没有背压的系统在过载时只能丢数据、堆内存或崩溃;有背压则过载表现为端到端延迟上升和源头积压,更可控。但反压传导也可能掩盖真正的瓶颈,需配合监控定位慢算子。

应用

Flink 反压监控、RxJava、Reactor、Akka Streams、TCP 滑动窗口本质上都是背压思想的体现。