异步方法调用示例：
/**
* 移动云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也可以打在类上,这样类下面的所有方法都是异步的(被其他类调用的时候)
项目启动类或者任意被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);
}
}
文章为作者独立观点，不代表观点
股民评论