极客观点
项目管理
HarmonyOS
控制器方法被调用后，发了一条消息到MQ，MQ消费后写入redis处理结果。
现在想要在控制器方法被调用后返回处理结果，目前的做法是死循环轮询判断redis有无结果，感觉好傻，有没有其他优雅的方案。
java代码我这样的场景如何异步转同步？
java阅读 2.5k
AI BotBETA在这个场景中，要实现从异步到同步的转换，一种可能的解决方案是使用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的笨拙做法。
1.单任务处理
CompletableFuture.supplyAsync(() -> {
// 处理逻辑结果返回给局部变量（集合）
}}, threadPool).whenComplete((v, e) -> {
// 执行完成返回局部变量（集合）结果
}2.多任务处理
1.CompletableFuture<?>[] futures = list的处理结果
// 阻塞list结果返回
2.CompletableFuture.allOf(futures).join(); 
撰写回答
你尚未登录，登录后可以
- 和开发者交流问题的细节
- 关注并接收问题和回答的更新提醒
- 参与内容的编辑和改进，让解决方法与时俱进
推荐问题
小网站有必要将图片放到阿里云OSS存储吗？
网站有涉及到图片的请求，买了阿里云服务，我想将图片放在云服务上的某个目录下，然后通过nginx代理请求图片资源，不知道这么做是否可行？还是说需要将图片放在OSS上存储，但是OSS需要收费？哪个方案更好一些？13 回答6.1k 阅读
post http重定向到https会改变 请求的method类型吗?
这种场景是怎样的?2 回答3.2k 阅读✓ 已解决
Mybatis+查询的结果集难道还要经过二次处理？不会吧？怎么优化？
能不能把另一个表（deparment）的字段dname，放到和用户表（Users）的字段id、name、did同级的地方？？？？代码如下：* {代码...} {代码...} {代码...} {代码...} {代码...} {代码...} 文件结构3 回答7k 阅读✓ 已解决
在计算机中如何翻译`pattern`？
我们知道学习正则表达式的时候，经常遇到pattern 这个单词，一般是怎么翻译它的呢？比如：A query consists of one or more patterns3 回答3k 阅读✓ 已解决
Spring中的两个疑惑?
使用注解的写法是否违背了Spring诞生的初衷？看了很多Spring教程，在讲述为什么要使用Spring的时候，都提出了一个很重要的原因就是，以前的5 回答4.6k 阅读
Redis 如何有效防止缓存穿透、击穿和雪崩问题？
Redis怎么解决缓存穿透、击穿、雪崩想看看大佬是怎么解决的4 回答2.3k 阅读
springboot业务代码能否动态加载和更新？
目前的问题是业务模块会持续增加，每个模块的开发不影响其他任何部分代码，所以我想的是，是否可以jvm启动一个主进程,主进程是一个springboot项目，只是没有各个业务模块的功能。然后各个业务模块可以以插件的形式动态加载和更新。3 回答4.7k 阅读
宣传栏
首先我觉得轮询也并不是不能接受的方案，很多时候外部程序就是没办法回调，这种情况下轮询也没什么不好。
然后来到你这个场景，我理解你应该是想优雅地实现一个异步过程的回调。我猜你现在的做法是控制器发消息到MQ后，控制器的线程持续轮询redis看是否有结果，直到有结果或超时才返回。这种情况下，可以考虑让当前线程阻塞，通过消费者的行为通知到本地，比如使用redis的pub/sub，或者消费者写一个处理完成的消息到MQ，再由消费到这个消息的线程唤起阻塞线程。
我之前做过一个异步过程是本地程序另起一个http接口用来接收完成消息，控制器启动异步过程后让线程阻塞在一个对象上，异步过程结束的最后会通过这个额外的接口接收成功消息。等另起的接口收到请求后，找到之前用来阻塞的那个对象，唤醒阻塞在对象上的线程即可。