Java 中并发请求多个接口怎样才能效率最高呢？

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 1711 天前的主题，其中的信息可能已经有所发展或是发生改变。

在 Java 中并发的请求多个接口，把请求来的数据做个聚合然后返回，如果是调用了 api1 然后再调用 api2 再调用 api3，这种方式可能大多数时间都在网络 IO 上了，而且随着接口的变多性能不断下降如果是在 go 中直接用协成就可以了，请求五个 api 和请求一个 api 耗时可能差不多（前提 api 平均耗时都一样）

java 中该如何编写代码呢？使用线程池的话肯定提高效率有限，因为线程不是协成，数量不会太多，并发量大了都在线程池里排队了

使用 NIO httpclient 可能效果好些，但是都必须写 callback，怎么判断所有的 api 都把结果成功返回了，然后我们要聚合接口，callback 写起来有些难受

java 中这种场景应该很多见，一般会怎么处理呢？

API

Java

请求

线程池

43 条回复 • 2020-05-23 16:39:23 +08:00

guyeu

2020-03-26 16:23:43 +08:00

线程池+CompletableFuture+聚合操作

pursuer

2020-03-26 16:26:16 +08:00

使用 Kotlin,C#的 async await，使用 Java Promise 库自己封装或者等待 Project Loom

guyeu

2020-03-26 16:28:15 +08:00

CompletableFuture 自带一个线程池，自己写的话可能比协程别扭一点，但是效率差不多

xuanbg

2020-03-26 17:12:44 +08:00

其实还是前端直接调各个接口拿数据效率高，前端 JS 天然就是异步模式的。

coer

2020-03-26 18:01:21 +08:00

callback+CompletableFuture ？

jamlee

2020-03-26 18:14:02 +08:00

RxJava 比较适合这种事情吧

areless

2020-03-26 18:22:13 +08:00 via Android

nginx lua 抗下大半

Artiano

2020-03-26 18:29:22 +08:00

RxJava zip，用 Kotlin async/await 特别爽

123444a

2020-03-26 18:32:59 +08:00 via Android

肯定是 callback 丫大哥，多线程不需要加锁

123444a

2020-03-26 18:48:48 +08:00 via Android

callback 都是在 io 线程的，然后唤醒工作线程在工作线程判断收完 response 没，然后记得设置超时也要 callback

CoderGeek

2020-03-26 18:52:48 +08:00

Future rx

araaaa

2020-03-26 18:53:18 +08:00 via iPhone

rxjava spring reactor

th00000

2020-03-26 18:55:30 +08:00

异步可解

xhinliang

2020-03-26 18:57:23 +08:00

CountDownLatch

gz911122

2020-03-26 19:00:24 +08:00

rxjava 了解一下

或者 kotlin 协程

Kipp

2020-03-26 19:10:43 +08:00 via iPhone

最近也同样遇到这个问题 mark

yeqizhang

2020-03-26 21:50:16 +08:00 via Android

futuretask 短板是时间最长的那个接口

liuliuluk

2020-03-26 21:53:16 +08:00

以往项目中是用 Future，mark 一下 JDK8 新特性

micean

2020-03-26 22:07:37 +08:00

java 的 vertx 可以这么用

CompositeFuture.all(请求 1，请求 2...)
.compose(结果集 -> 处理结果集，返回最终结果)
.setHandler(成功时的处理最终结果，至少一项请求失败时处理异常)

和 java 自带的 CompletableFuture 相比，只用了 1 个线程，无阻塞。

mosliu

2020-03-26 23:54:10 +08:00

jdk8
CompletableFuture allof

Macolor21

2020-03-27 00:04:27 +08:00 via iPhone

以前做个类似场景，用创建个线程池，然后用 CountdownLatch 。看楼上似乎 8 的特性也支持。建议楼主写多个版本，做下 benchmark

noble4cc

2020-03-27 00:22:00 +08:00

@guyeu 线程池在并发量大的情况下不如协成吧
感觉线程池的原理是使用多线程进行 http 请求，比如 5 个 api，开 5 线程，然后聚合，但是每个线程在执行的时候 io 是阻塞的，大部分的线程时间都浪费在阻塞上了，如果我们这种聚合 api 数据的请求特别多，比如 1000qps，复用五个线程或者多开点 20 个，相当于 1000 个要请求 5000 次后端 api，在线程池里排队处理的话太慢吧

tairan2006

2020-03-27 08:40:57 +08:00 via Android

这不是基本功么，开线程等待完成，CountDownLatch 啊

Seawalker

2020-03-27 09:06:37 +08:00 via Android

标记一下看看有没有好方案

shaoyijiong

2020-03-27 09:16:14 +08:00

一楼标准答案

yc8332

2020-03-27 09:17:16 +08:00

只是聚合请求，干嘛不搞个现成的 api 网关就好了。。

piglovesx

2020-03-27 09:19:51 +08:00

小白一枚，很好奇协程是从哪个英文单词翻译过来的，是 channel 吗？

guolaopi

2020-03-27 09:31:28 +08:00

C#：Task.WaitAll();
（滑稽

LosLord

2020-03-27 09:46:07 +08:00

CompletableFuture.allOf(List<CompletableFuture>)

noble4cc

2020-03-27 10:20:05 +08:00

@tairan2006 老哥我说过多线程方案性能肯定不行
200 qps 访问 5 个 api 不能开 1000 个线程吧，线程复用一个机器 8core 开 16 个工作线程的话，每次并发的请求后端 api 是 16，每个 api 平均耗时 10ms 的话，第 200 个请求得等到什么时候呢？量少了确实没什么问题，java 类似的工具包确实也多如牛毛

noble4cc

2020-03-27 10:22:48 +08:00

@micean 这个本质上确实是 io 多路复用的原理吧，开起来挺方便的，vert.x 不太熟，netty 到是经常用，我一开始想的是用 netty 封装个 httpclient，但是感觉搞起来太麻烦了，是不是 vert.x 就是用 netty 实现了 http 协议了

lscexpress

2020-03-27 10:34:03 +08:00

@piglovesx Coroutine 翻译为协程，通常来说 java 不用协程。channel 在书中的翻译多为信道或者通道

piglovesx

2020-03-27 11:07:32 +08:00

@lscexpress 谢谢 :)

guyeu

2020-03-27 11:13:24 +08:00

@noble4cc #22 是的，线程池在并发量大的情况下不如协程。所以这种情况下会做一些设计，比如把发消息和收消息分开，一个线程池专门发，一个线程池专门处理收消息，也就是 NIO 的思路。。

hpeng

2020-03-27 11:14:44 +08:00 via iPhone

看一楼的

aguesuka

2020-03-27 12:00:54 +08:00 via Android

@noble4cc vertx 底层就是 netty

buliugu

2020-03-27 15:27:09 +08:00

java 大量 API 请求可以用 Quasar，现成的纤程库

elevation

2020-03-30 15:47:12 +08:00

不知道你现在怎么样，我觉得用 diruptor,环形数组线程分发，可以降低消耗，自己写底层实现，工厂，资源调用。比较方便；

xiaoidea

2020-03-31 17:27:30 +08:00

目前用的是线程池+guava ListenableFuture 、Futures 工具类，确实很多线程堵在 IO 上了，线程池要开多大需要压测
看到有其他项目用 Spring webflux 的，对这个不熟

monkeyWie

2020-04-03 18:31:05 +08:00

NIO httpclient + CountDownLatch 不就行了吗
主线程还是得阻塞的啊，阻塞到 api 全部 callback 完

RRRSSS

2020-04-08 19:51:03 +08:00

Completable<Void> f = CompletableFuture.allOf(task1, task2, task3); // 这里注意要使用线程池
f.get(); // 这里消耗的时间是 task1 、task2 、task3 的最大值

Stream.of(future1, future2, future3).forEach(dd -> dd.thenAccept(e -> {
// 处理数据
}));

guisheng

2020-05-23 15:41:14 +08:00

楼主最后使用了什么方式呢？我目前采用的是 spring webclient 的 Mono.zip 来组合请求发送。

noble4cc

2020-05-23 16:39:23 +08:00

@guisheng NIO 的 httpclient+队列吧，编写起来也不太麻烦，毕竟不是 golang