SpringBoot异步调用（有例子）

旧城等待， 2022-12-23 09:37 162阅读 0赞

### SpringBoot异步调用 ###

*   *  1、异步调用简介
     *  2、@Async的使用
     *   *  1.使用@Async注解之前，需要在入口类添加注解@EnableAsync开启异步调用
         *  2.在需要使用异步调用的方法加上@Async
         *  3.测试

## 1、异步调用简介 ##

异步调用是相对于同步调用而言的，同步调用是指程序按预定顺序一步步执行，每一步都得上一步执行完后才能执行，而一步调用无需等待上一步执行完成即可执行。在项目中想让程序并行执行，除了可以使用多线程来并行地处理任务，也可以使用Spring Boot提供的异步处理方式@Async来处理。在springboot框架中，只需要添加@Async注解就能将普通的同步任务改为异步调用任务。

## 2、@Async的使用 ##

### 1.使用@Async注解之前，需要在入口类添加注解@EnableAsync开启异步调用 ###

代码：

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.web.servlet.ServletComponentScan;
    import org.springframework.context.annotation.ImportResource;
    import org.springframework.retry.annotation.EnableRetry;
    import org.springframework.scheduling.annotation.EnableAsync;
    
    @SpringBootApplication
    @ServletComponentScan
    @ImportResource(locations = { "classpath:spring-mvc.xml"})
    @EnableRetry
    @EnableAsync   //开启异步调用
    public class DemojpaApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(DemojpaApplication.class, args);
        }
    
    }

@EnableAsync 是要加的，其他除了@SpringBootApplication可以不用

### 2.在需要使用异步调用的方法加上@Async ###

具体代码：

@Override
        @Async
        public Future<List<AyUser>> findAsynAll() { 
            try{ 
                logger.info("开始做任务！");
                Long start = System.currentTimeMillis();
                List<AyUser> ayUserList = ayUserRepository.findAll();
                Long end = System.currentTimeMillis();
                logger.info("总共消耗："+(end-start)+"毫秒");
                return new AsyncResult<List<AyUser>>(ayUserList);
            }catch (Exception e){ 
                logger.error("method [findAll] error",e);
                return new AsyncResult<List<AyUser>>(null);
            }
        }

### 3.测试 ###

测试代码：

@Test
        public void testAsync2() throws InterruptedException { 
            Long startTime = System.currentTimeMillis();
            logger.info("第一次查询用户！");
            Future<List<AyUser>> ayUserList = ayUserService.findAsynAll();
            logger.info("第二次查询用户！");
            Future<List<AyUser>> ayUserList2 = ayUserService.findAsynAll();
            logger.info("第三次查询用户！");
            Future<List<AyUser>> ayUserList3 = ayUserService.findAsynAll();
            while(true){ 
                if (ayUserList.isDone()&&ayUserList2.isDone()&&ayUserList3.isDone()){ 
                    break;
                }else { 
                    Thread.sleep(10);
                }
            }
            Long endTime = System.currentTimeMillis();
            logger.info("总共消耗："+(endTime-startTime)+"毫秒");
        }

运行截图：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzUyMDY3MA_size_16_color_FFFFFF_t_70_pic_center]  
可以看出，三个方法是并行执行的。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzUyMDY3MA_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/056b0c524e1a4e77a78ddb1545381583.png