baiyang

> @chenbay Could you describe the use case of these new options? @wwbmmm 两个节点间多个streams protocol通过一个socket连接传输数据，handler里消费速度跟不上，数据堆积在_consumer_queue里，因为streams数量我们使用的没法限制，所以想加到socket上限制。

> > > @chenbay Could you describe the use case of these new options? > > > > > > @wwbmmm 两个节点间多个streams protocol通过一个socket连接传输数据，handler里消费速度跟不上，数据堆积在_consumer_queue里，因为streams数量我们使用的没法限制，所以想加到socket上限制。 > > 感觉好像没必要在Socket上限制。如果每个Stream都设置了max_buf_size，当数据堆积在_consumer_queue到一定程度，发送端自然会限流，每个Stream都会被限住，那么Socket上自然就限住了。 而且如果有部分Stream消费地比较快的话，那么这部分Stream的发送端还可以继续发送。但如果在Socket层面限流的话，就会导致这部分Stream也被限制发送了，造成不必要的限制。 max_buf_size只能限制单个stream的buffer size，我们两个节点间stream数量可能很多，希望能限制这些streams的总buffer大小，控制内存占用，目前考虑的是通过socket来限制（因为socket就是端到端），socket内的多个streams就让他们自己竞争，有一个min_buf_size也保证了stream不会饿死。