SpringBoot 异步执行方法,接口异步调用方法
SpringBoot 异步执行方法,在接口调用时开启一个新线程做一些操作,这个操作结果,不影响返回值项目启动类或者任意被Spring容器管理的类,必须要有一个`@EnableAsync`注解,标识项目开启异步功能然后在需要异步执行的方法或类上加上`@Async`注解,在类上加上这个注解标识这个类里面的所有方法都是异步方法,在被其他类调用时会启动一个线程进行该方法的执行。
·
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;
/**
* Mas回调状态报告信息保存到Redis
* 为了防止云Mas平台因为Redis阻塞导致状态报告推送超时,接口调用失败,所以保存Redis信息异步执行
*
* @author yangxiaohui
*/
@Slf4j
@Component
@EnableAsync
public class MasSmsRedisService {
private final RedisListService redisListService;
public MasSmsRedisService(RedisListService redisListService) {
this.redisListService = redisListService;
}
/**
* 移动云Mas短信发送状态报告回调地址
*/
public void reportSmsMessage(ReportStatusModel reportStatusModel){
redisListService.putListRight("ReportStatusModel",reportStatusModel,86400L);
}
/**
* 移动云Mas上行短信回调地址
*/
public void upSmsMessage(UpSmsMessageModel upSmsMessageModel){
redisListService.putListRight("UpSmsMessageModel",upSmsMessageModel,86400L);
}
}
异步方法调用示例:
/**
* 移动云Mas短信发送状态报告回调地址
*/
@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也可以打在类上,这样类下面的所有方法都是异步的(被其他类调用的时候)
更多推荐
已为社区贡献1条内容
所有评论(0)