SpringBoot 启用异步任务 Async

前言:
异步任务在合适的业务逻辑情况下是比同步任务要快了很多时间的。异步任务是指无序上一个任务处理完毕便可处理下一个任务,而同步任务是指任务一步接着异步执行。在大量重复的数据请求状态下同步请求显得有些无力招持,即使开启了数据库缓存,甚至Redis(业务量太复杂)也显得捉襟见肘。因此,异步任务的合理运用在数据请求方面也有很大的优势。

Application注解:

在SpringBoot的启动Application添加@EnableAysnc即可。

业务类注解:

我们假设 UserRepository存在一个这样的抽象方法,这个方法作用是装配一个普通的查询语句(例如select * from user)并将其映射到普通的泛型集合(例如将上述语句的结果集映射为一个List<User>)里面。在Impl里面我们只需在重写方法上面添加@Aysnc注解,该类即可支持异步处理。
示例:

    @Async
    @Override
    public List<User> findAllAsync() {
        List<User> userList;
        SqlSessionFactory factory= MySqlSessionFactory.getSqlSessionFactory();
        SqlSession session = factory.openSession();
        UserMapper mapper = session.getMapper(UserMapper.class);
        userList = mapper.findAll();
        session.close();
        return userList;
    }

测试:

准备两个controller,一个为sync,一个为async,里面均查询相同的数据三次。示例如下:

@RequestMapping(value = "/sync", method = RequestMethod.GET)
public void findSyncController() {
    long startTime = System.currentTimeMillis();
    System.out.println("------> SYNC TASK NOW: " + startTime);
    userService.findAll();
    userService.findAll();
    userService.findAll();
    long endTime = System.currentTimeMillis();
    System.out.println("------> SYNC TASK END: " + endTime);
    System.out.println("------> SYNC TASK TIME: " + (endTime - startTime) + " ms");

}

@RequestMapping(value = "/async", method = RequestMethod.GET)
public void findAsyncController() {
    long startTime = System.currentTimeMillis();
    System.out.println("------> ASYNC TASK NOW: " + startTime);
    userService.findAllAsync();
    userService.findAllAsync();
    userService.findAllAsync();
    long endTime = System.currentTimeMillis();
    System.out.println("------> ASYNC TASK END: " + endTime);
    System.out.println("------> ASYNC TASK TIME: " + (endTime - startTime) + " ms");
}

测试结果:

------> ASYNC TASK NOW: 1628865614117
------> ASYNC TASK END: 1628865614122
------> ASYNC TASK TIME: 5 ms
------> SYNC TASK NOW: 1628865617684
------> SYNC TASK END: 1628865617696
------> SYNC TASK TIME: 12 ms
------> SYNC TASK NOW: 1628865628404
------> SYNC TASK END: 1628865628413
------> SYNC TASK TIME: 9 ms
------> SYNC TASK NOW: 1628865631388
------> SYNC TASK END: 1628865631395
------> SYNC TASK TIME: 7 ms
------> SYNC TASK NOW: 1628865635529
------> SYNC TASK END: 1628865635538
------> SYNC TASK TIME: 9 ms
------> ASYNC TASK NOW: 1628865642993
------> ASYNC TASK END: 1628865642994
------> ASYNC TASK TIME: 1 ms

可以明显看到,异步(ASYNC)任务的事件处理量远比同步小了很多。


版权声明:本文为kicinio原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。