java代码我这样的场景如何异步转同步？

Question

控制器方法被调用后，发了一条消息到MQ，MQ消费后写入redis处理结果。
现在想要在控制器方法被调用后返回处理结果，目前的做法是死循环轮询判断redis有无结果，感觉好傻，有没有其他优雅的方案。

Answer 1

1.单任务处理

 CompletableFuture.supplyAsync(() -> {        // 处理逻辑结果返回给局部变量（集合） }}, threadPool).whenComplete((v, e) -> {        // 执行完成返回局部变量（集合）结果 }

2.多任务处理

1.CompletableFuture<?>[] futures = list的处理结果// 阻塞list结果返回2.CompletableFuture.allOf(futures).join(); 

Answer 2

在这个场景中，要实现从异步到同步的转换，一种可能的解决方案是使用Java的CompletableFuture。CompletableFuture是Java 8引入的一个功能，它允许你以非阻塞的方式编写异步代码，并提供了优雅的方法来处理异步操作的结果。

下面是一个示例代码，展示了如何使用CompletableFuture来异步发送消息到MQ，并在接收到处理结果后同步返回：

import java.util.concurrent.CompletableFuture;import java.util.concurrent.ExecutionException;public class AsyncToSyncExample {    // 假设有一个方法用于向MQ发送消息并返回一个CompletableFuture    public static CompletableFuture<String> sendMessageToMQ(String message) {        // 模拟异步发送消息到MQ        return CompletableFuture.supplyAsync(() -> {            // 模拟处理时间            try {                Thread.sleep(3000); // 假设处理需要3秒钟            } catch (InterruptedException e) {                throw new RuntimeException("Interrupted while processing message", e);            }            // 模拟处理结果            return "Processed result: " + message;        });    }    // 控制器方法，异步发送消息并同步返回处理结果    public static String controllerMethod(String inputMessage) throws ExecutionException, InterruptedException {        CompletableFuture<String> future = sendMessageToMQ(inputMessage);        // 使用CompletableFuture的get方法阻塞等待结果        return future.get();    }    public static void main(String[] args) throws Exception {        String result = controllerMethod("Hello MQ");        System.out.println("Result: " + result);    }}

在上面的示例中，sendMessageToMQ方法模拟了异步发送消息到MQ的操作，并返回一个CompletableFuture。controllerMethod方法在调用sendMessageToMQ后，通过调用CompletableFuture的get方法来阻塞等待结果。这种方式可以实现从异步到同步的转换，同时避免了轮询Redis的笨拙做法。