马老师过滤器监听器
生产者流控
1)commitLog 文件被锁时间超过 osPageCacheBusyTimeOutMills 时,参数默认为1000ms,发生流控。
2)如果开启 transientStorePoolEnable = true,且Broker为异步刷盘的主机,且transientStorePool中资源不足,拒绝当前send请求,发生流控。
注意:生产者流控,不会尝试消息重投。
Broker每隔10ms检查send请求队列头部请求的等待时间,如果超过 waitTimeMillsInSendQueue,默认200ms,拒绝当前send请求,发生流控。
Broker通过拒绝 send 请求方式实现流量控制。