Spring使用@Async和Future实现SQL并行查询

背景：首页存在多个耗时SQL时，导致加载速度较慢，可将SQL并行，减少等待时间。方案：使用@Async、Future实现

因查询需要返回结果，所以需要Future来接收；

1. 准备工作：applicationContext.xml 中添加以下配置

xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="
http://www.springframework.org/schema/task
http://www.springframework.org/schema/task/spring-task-xxx.xsd"
<task:annotation-driven/>

3. 原有方法

Map<String,Object> initNumMap =
(Map<String,Object>)baseDao.queryForObjectBySql("customManagerIndex."+allNumSql, initMap);
Map<String,Object> currentNumMap =
(Map<String,Object>)baseDao.queryForObjectBySql("customManagerIndex."+allNumSql, currentMap);

4. 使用Future接收
   （1）不能和调用方法放到同一个类，需要将方法单独放到一个类中

@Component
@Lazy
public class FutureMap extends BasicServiceImpl{
@Async
public Future<Map<String,Object>> doTaskOne(String allNumSql, Map<String,Object> initMap) throws Exception {
return new AsyncResult<>((Map<String,Object>)baseDao.queryForObjectBySql("customManagerIndex."+allNumSql, initMap));
}
@Async
public Future<Map<String,Object>> doTaskTwo(String allNumSql,Map<String,Object> currentMap) throws
Exception{
return new AsyncResult<>((Map<String,Object>)baseDao.queryForObjectBySql("customManagerIndex."+allNumSql, currentMap));
}
}

（2）方法调用

@Autowired
private FutureMap futureMap;
Future<Map<String,Object>> initNumMap = null;
Future<Map<String,Object>> currentNumMap = null;
try {
initNumMap
=
futureMap.doTaskOne(allNumSql,initMap);
currentNumMap =
futureMap.doTaskTwo(allNumSql,currentMap);
} catch (Exception e) {
e.printStackTrace();
}
while(true) {
//isDone 执行结果回调函数，判断是否执行完成
if (initNumMap.isDone() && currentNumMap.isDone()) {
// 2个任务都调用完成，退出循环等待
break;
}
Thread.sleep(100);
}
//对于 initNumMap
、currentNumMap 的结果，可以使用get()获取
Integer result= (Integer)initNumMap.get().get("XXXXXX");

问题记录：
1. 在未使用@Lazy注解时出现BeanCurrentlyInCreationException循环依赖异常；
2. @Lazy跟@Autowired一起用时，项目出现NoSuchBeanDefinitionException找不到实例对象，需将@Lazy放到存在@Async的类上；

问题1分析：https://blog.51cto.com/u_15081050/2593337
@Lazy介绍：https://blog.csdn.net/paohui001lqp/article/details/97111701

最后

以上就是可耐小懒虫为你收集整理的Spring使用@Async和Future实现SQL并行查询的全部内容，希望文章能够帮你解决Spring使用@Async和Future实现SQL并行查询所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。