代码之家  ›  专栏  ›  技术社区  ›  tsar2512

从springwebflux内部进行异步http调用

  •  0
  • tsar2512  · 技术社区  · 6 年前

    我们有一个基于springwebflux的应用程序,它返回一个flux响应。应用程序本身对下游服务进行阻塞调用,基本上充当聚合器。每个下游请求都是一个阻塞的httppost请求,并且可能需要可变的时间量(几秒钟的顺序)。

    我们目前遵循的模式是:

    Mono.fromCallable(() -> {
    
    //client code for the blocking call
    
    }).subscribeOn(Schedulers.boundedElastic()).flux()
    

    使用AsyncHTTPClient会更好吗?它将使用NIO从常规操作中发出非阻塞请求。有谁能举个例子来说明这种方法是如何工作的吗?这种方法可能有哪些优点/缺点?

    0 回复  |  直到 6 年前