带多线程的Spring引导异步

Question

我有一个spring boot微服务，我们在其中调用多个服务（比如服务a和服务B）。我试图根据某些条件在多个线程上异步调用这两个服务，一旦处理完成，我想合并服务A和服务B的响应。

我知道我们可以使用@Async异步运行一个进程，并使用ExecutorService为一个服务启动多个线程。

但是我不确定如何把所有的东西放在一起。所以在这里寻找任何建议？

              @Async
              Service A(thread1,thread2) \
MicroService /                             (Merge from Response of ServiceA and ServiceB)
             \ @Async
              Service B(thread1,thread2) /

我知道这在上面主要是理论上解释的，但我尝试了跟随/浏览多个网站，但大多数文章要么解释了Aync或Multithread，但不确定如何在多个线程中等待和运行Async中的两个进程，并在这两个服务调用完成后继续执行！

感谢任何建议或线索！TIA：）

Answer 1

您可以展望java的完整未来。ComplitableFuture允许合并多个异步任务（也是CompletableFuture），并等待所有CompletableFuture的结果。我不确定它是否完全适合你的情况，但它可能会有所帮助。https://www.baeldung.com/java-completablefuture#Multiple

Answer 2

您需要使用spring的AsyncResult类包装结果，然后使用其方法。completable（）返回CompletableFuture对象。

合并未来对象时，使用CompletableFuture.thenCompose（）和CompletableFuture.thenApply（）方法合并数据，如下所示：

CompletableFuture<Integer> result = futureData1.thenCompose(fd1Value -> 
                futureData2.thenApply(fd2Value -> 
                        merge(fd1Value, fd2Value)));

以下是一个基本示例：

用EnableSync注释Spring boot主类

@SpringBootApplication
@EnableAsync
public class StackOverflowApplication {

    public static void main(String[] args) {
        SpringApplication.run(StackOverflowApplication.class, args);
    }

}

创建一个将返回CompletableFuture的示例服务

A服务。Java语言

@Service
public class Aservice {

    @Async
    public CompletableFuture<Integer> getData() throws InterruptedException {
        Thread.sleep(3000); // sleep for 3 sec
        return new AsyncResult<Integer>(2).completable(); // wrap integer 2
    }
}

b服务。Java语言

@Service
public class Bservice {

    @Async
    public CompletableFuture<Integer> getData() throws InterruptedException {
        Thread.sleep(2000); // sleep for 2 sec
        return new AsyncResult<Integer>(1).completable(); // wrap integer 1
    }
}

创建另一个将合并其他两个服务数据的服务

结果服务。Java语言

@Service
public class ResultService {

    @Autowired
    private Aservice aservice;
    @Autowired
    private Bservice bservice;

    public CompletableFuture<Integer> mergeResult() throws InterruptedException, ExecutionException {
        CompletableFuture<Integer> futureData1 = aservice.getData();
        CompletableFuture<Integer> futureData2 = bservice.getData();

        // Merge futures from Aservice and Bservice
        return futureData1.thenCompose(
            fd1Value -> futureData2.thenApply(fd2Value -> fd1Value + fd2Value));
    }
}

创建用于测试的示例控制器

结果控制器。Java语言

@RestController
public class ResultController {

    @Autowired
    private ResultService resultService;

    @GetMapping("/result")
    CompletableFuture<Integer> getResult() throws InterruptedException, ExecutionException {
        return resultService.mergeResult();
    }

}