问题描述
我想从数据库中检索不同类型的数据,并在Spring Boot服务的HTTP结果中返回给用户。因为每个数据库检索都花费大量时间,所以我正在使用CompletableFuture异步进行这些数据库调用。与同步执行相比,我的模式有效并且节省了时间,但是我认为可以并且应该以更简洁的方式进行布局。
我编辑了代码,将类型更改为'PartA','PartB','PartC',但是这是原来的样子。当前,该服务接受不同类型(PartA,PartB,PartC)的列表,创建每个列表的Completable未来类型,并调用其自己的调用数据库的CompletableFuture方法,并为每个构建一个 generic 列表的CompleteableFutures类型,“获取”通用列表,然后将每个“将来”列表的所有内容添加到传递到服务的列表中。
这是Service方法的编码方式:
Service.java:
public void metadata(final List<PartA> partAs,final List<PartB> partBs,final List<PartC> partCs,String prefix,String base,String suffix) throws Exception {
try {
CompletableFuture<List<PartA>> futurePartAs = partACompletableFuture(prefix,base,suffix).thenApply(list -> {
logger.info("PartA here");
return list;
});
CompletableFuture<List<PartB>> futurePartBs = partBCompletableFuture(prefix,suffix).thenApply(list -> {
logger.info("PartBs here");
return list;
});
CompletableFuture<List<PartC>> futurePartCs = partCCompletableFuture(prefix,suffix).thenApply(list -> {
logger.info("PartCs here");
return list;
});
CompletableFuture<?> combinedFuture = CompletableFuture.allOf(CompletableFuture.allOf(futurePartAs,futurePartBs,futurePartCs));
combinedFuture.get();
partAs.addAll(futurePartAs.get());
partBs.addAll(futurePartBs.get());
partCs.addAll(futurePartCs.get());
} catch (Exception e) {
logger.error("Exception: ",e);
throw e;
}
}
@Async("asyncExecutor")
public CompletableFuture<List<PartA>> partACompletableFuture(String prefix,String suffix) {
return CompletableFuture.supplyAsync(() -> {
try {
logger.info("start PartA");
return getPartAs(prefix,suffix);
} catch (Exception e) {
logger.error("Exception: ",e);
throw e;
}
});
}
@Async("asyncExecutor")
public CompletableFuture<List<PartB>> partBCompletableFuture(String prefix,String suffix) {
return CompletableFuture.supplyAsync(() -> {
try {
logger.info("start B");
return getPartBs(prefix,e);
throw e;
}
});
}
@Async("asyncExecutor")
public CompletableFuture<List<PartC>> partCCompletableFuture(String prefix,String suffix) {
return CompletableFuture.supplyAsync(() -> {
try {
logger.info("start PartC");
return getPartCs(prefix,e);
throw e;
}
});
}
如果您想查看控制器和响应类型:
Controller.java
@GetMapping(value="/parts/metadata",produces = { MediaType.APPLICATION_JSON_VALUE })
public ResponseEntity<MetadataResponse> metadata (@ApiParam(name="prefix",value = "Prefix value for a part",required = false)
@RequestParam(required=false) String prefix,@ApiParam(name="base",value = "Base value for a part",required= true)
@RequestParam String base,@ApiParam(name="suffix",value = "Suffix value for a part",required=false)
@RequestParam(required=false) @NotBlank String suffix ) throws Exception {
final List<PartA> partAs = new ArrayList<>();
final List<PartB> partBs = new ArrayList<>();
final List<PartC> partCs = new ArrayList<>();
service.metadata(partAs,partBs,partCs,prefix,suffix);
MetadataResponse.MetadataResponseResult res = MetadataResponse.MetadataResponseResult.builder()
.partAs(partAs)
.partBs(partBs)
.partCs(partCs)
.build();
return ResponseEntity.ok(MetadataResponse.result(res,MetadataResponse.class));
}
MetadataResponse.java
@ApiModel(value = "MetadataResponse",parent = BaseBodyResponse.class,description = "Part A,B,C")
public class MetadataResponse extends BaseBodyResponse<MetadataResponse.MetadataResponseResult> {
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
@ApiModel(value = "MetadataResponseResult",description = "This Model holds Part As,Bs,Cs")
public static class MetadataResponseResult {
List<PartA> partAs;
List<PartB> partBs;
List<PartC> partCs;
}
}
解决方法
- 在这种情况下,我不完全理解为什么需要将所有这些列表作为参数传递:
public void metadata(final List<PartA> partAs,final List<PartB> partBs,final List<PartC> partCs,String prefix,String base,String suffix) throws Exception
您可以修改此方法以返回已经拥有的MetadataResponseResult
类,并使用列表中的直接将ComparableFutures - 我将删除
thenApply
方法,因为您只记录了一条语句,实际上并没有改变结果。 - 除了使用三种方法(
partACompletableFuture
,partABCompletableFuture
,partCCompletableFuture
)之外,您还可以使用一种方法来接收供应商作为参数。
@Async("asyncExecutor")
public <T> CompletableFuture<T> partCompletableFuture(Supplier<T> supplier) {
return CompletableFuture.supplyAsync(() -> {
try {
logger.info("start Part");
return supplier.get();
} catch (Exception e) {
logger.error("Exception: ",e);
throw e;
}
});
}
以后,您可以按以下方式使用它:
CompletableFuture<List<PartA>> futurePartAs = partCompletableFuture(() ->
getPartAs(prefix,base,suffix));
它应该更清洁。希望对您有所帮助!