| 信号 | 队列积压、处理延迟、资源水位 |
|---|---|
| 手段 | 消费者拉取模式、动态调节生产速率、分区暂停 |
| 兜底 | 超过上限时明确拒绝并告警,避免无限积压 |
- 入口层:令牌桶或漏桶限流,超容量请求快速拒绝
- 链路层:消费者拉模式,按自身处理能力领取任务
- 队列层:设置积压水位与上限,触发暂停或扩容
- 反馈层:返回 503 加 Retry-After,或协议级流控信号
- 观测层:积压量、积压时长与拒绝率纳入监控
| 协议与框架支持 | TCP 滑动窗口、Reactive Streams 的 request(n)、gRPC 流控、消息队列消费配额 |
|---|---|
| 拒绝策略 | 明确 429 与 503 语义并给出退避建议,让上游感知节奏而非静默堆积 |
| 组合使用 | 入口限流保护自身,背压反馈保护下游,两者按链路分层配置 |
无界队列属于伪背压:积压只是被隐藏,延迟无上限增长,最终集中爆发。