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也可以打在类上,这样类下面的所有方法都是异步的(被其他类调用的时候)
Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐