作者:纪志鹏大利集客_776 | 来源:互联网 | 2023-09-07 11:55
SpringBoot异步执行方法,在接口调用时开启一个新线程做一些操作,这个操作结果,不影响返回值项目启动类或者任意被Spring容器管理的类,必须要有一个@EnableAsyn
SpringBoot 异步执行方法,在接口调用时开启一个新线程做一些操作,这个操作结果,不影响返回值
项目启动类或者任意被Spring容器管理的类,必须要有一个@EnableAsync
注解,标识项目开启异步功能
然后在需要异步执行的方法或类上加上@Async
注解,在类上加上这个注解标识这个类里面的所有方法都是异步方法,在被其他类调用时会启动一个线程进行该方法的执行。
代码示例:
package com.yxh.www.template.mas;import com.yxh.www.common.redis.RedisListService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.stereotype.Component;
@Slf4j
@Component
@EnableAsync
public class MasSmsRedisService {private final RedisListService redisListService;public MasSmsRedisService(RedisListService redisListService) {this.redisListService = redisListService;}public void reportSmsMessage(ReportStatusModel reportStatusModel){redisListService.putListRight("ReportStatusModel",reportStatusModel,86400L);}public void upSmsMessage(UpSmsMessageModel upSmsMessageModel){redisListService.putListRight("UpSmsMessageModel",upSmsMessageModel,86400L);}
}
异步方法调用示例:
@PostMapping("/reportStatus")public void reportSmsMessage(@RequestBody ReportStatusModel reportStatusModel){log.info("收到响应:{}", JSON.toJSONString(reportStatusModel));masSmsRedisService.reportSmsMessage(reportStatusModel);}
注意事项
- 必须要加@EnableAsync注解
- 不能在同一类下调用@Async注解的方法,比如A类下有a和b方法,b方法有- @Async注解,不能直接这样a调用b,要把b放到其他类中
- @Async也可以打在类上,这样类下面的所有方法都是异步的(被其他类调用的时候)