V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
jooks
V2EX  ›  Java

请教个问题,背压(backpressure)是如何体现在 Webflux 的呢?

  •  
  •   jooks · 2022-07-22 02:06:55 +08:00 · 1938 次点击
    这是一个创建于 857 天前的主题,其中的信息可能已经有所发展或是发生改变。

    我对背压的理解是下游可以控制上游的下发速率。

    那么当 Webflux 的收到一个 HTTP 请求后,是怎么控制上游的流速的呢?

    或者说 webflux 的背压只是在内部的?

    6 条回复    2022-07-22 12:29:06 +08:00
    ymmud
        1
    ymmud  
       2022-07-22 07:49:09 +08:00
    参考 akka 的,是从 tcp 开始。不知道 webflux 是咋整的
    qwerthhusn
        2
    qwerthhusn  
       2022-07-22 09:27:54 +08:00
    TCP 协议里面有个滑动窗口机制,如果下面的请求处理不了,WebFlux 就不会再读取数据,这时候 OS 通过调整窗口阻止客户端继续发送数据。我瞎猜的
    frank1256
        3
    frank1256  
       2022-07-22 10:55:35 +08:00
    这个问题我也想知道,落实到代码的话,调用的是
    public interface Subscription {
    public void request(long n);
    public void cancel();
    }
    的 request 方法。我理解的应该是在内部代码层面。你是控制不了其他服务给你发 http 的速度的。
    mgcnrx11
        4
    mgcnrx11  
       2022-07-22 11:25:25 +08:00   ❤️ 1
    一个 HTTP 一般包含 HTTP Header 头和 HTTP Body 内容体,WebFlux 要处理一个请求,需要先解析(完整读取) Header 头的内容,最起码第一行 URL 地址要读完,这样 WebFlux 才知道要构建一条怎样的 Pipeline 来处理这个请求。

    说个简单的情况假设请求的 Body 是一个 JSON 格式的数据,可能 pipeline 流水线就这么简单:

    request -> json parser -> response

    在构建完 Pipeline 之后,触发 subscribe 的是最下游 response 的 write ,response 响应要知道要写什么内容返回,那就会 request 上游获取完整的请求的 JSON 的数据(这时候可能只是 request(1),它只需要一个 JSON ),那上游获取 JSON 数据的假设是一个 JSON Parser ,它自己内部应该就可以控制每次请求多少字节的数据来做 parse 了,这里就可以控制 request 每次的量。通过每次的量和次数,就能控制上游 读取 request 的速率了。但是这个读取速率都是从缓冲区读,不能控制对方给你发的速率的,那是 TCP 层的事情了。
    bxb100
        5
    bxb100  
       2022-07-22 12:27:30 +08:00 via Android   ❤️ 2
    如果你用的是 netty 的话,是通过 tcp 流控制来减速,如果是用 rssocket 的话,是请求端控制
    jooks
        6
    jooks  
    OP
       2022-07-22 12:29:06 +08:00
    @mgcnrx11 原来如此,这个跟 grpc 有点像,grpc 是控制 http2 的流控窗口
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   4697 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 23ms · UTC 04:04 · PVG 12:04 · LAX 20:04 · JFK 23:04
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.