Skip to main content
 首页 » 编程设计

java8 网路异步请求,查数据库 示例

2022年07月18日29zdz8207
/**
* @desc: 网路异步请求,查数据库 示例
* @author: 毛会懂
* @create: 2022-02-08 15:14:00
**/
public class Test5Main {
public static void main(String[] args) {
// 假设参数为userId,根据userId查询有相同爱好的人
String userId = "00001";


// 根据userId 查userId的兴趣爱好
CompletableFuture<List<String>> future = getHobbyByUserId(userId)
.thenCompose(hobby -> getUsersByHobby(hobby));
try {
List<String> result = future.get();
System.out.println("返回的结果是:" + result);
}catch (Exception ex){

}
}


// 异步查询userId的兴趣爱好
private static CompletableFuture<String> getHobbyByUserId(String userId) {
return CompletableFuture.supplyAsync(() ->{
// 根据userId查询数据库
return "爱好1";
});
}

private static CompletableFuture<List<String>> getUsersByHobby(String hobby){
return CompletableFuture.supplyAsync(() -> {
// 根据hobby查询数据库
return Arrays.asList("姓名1","姓名2");
});
}

本文参考链接:https://www.cnblogs.com/maohuidong/p/15871467.html