spring boot中使用@Async失效

场景：在service中用户新增的方法中调用接口上传数据到其他库的接口，在新增方法上使用了@Transactional，在上传数据方法上使用了@Async，然后发现@Async注解不生效。

解决方案：不要直接在service用户新增中调用上传接口，改为在controller中即可。

代码如下：

service层

@Transactional
public User userEdit(String name,String mobile,String pwd,String ip,String type,Integer companyId,Integer roleId){

    User user = new User();

    user.setLoginKey(mobile);
    user.setLoginPwd(pwd);
    if(StringUtils.isNotBlank(name)){
        user.setName(name);
    }else {
        user.setName(mobile);
    }


    user.setUserState(Enums.UserState.Normal);
    user.setUnlockTime(null);
    user.setErrorLoginCount(0);
    user.setLastLoginIp(ip);
    user.setLastLoginTime(new Date());

    if ("Driver".equalsIgnoreCase(type)){
        user.setType(Enums.UserType.Driver);
        dao.save(user);
        Driver driver = new Driver();
        driver.setUserId(user.getId());
        driver.setCompanyId(companyId);
        driverDao.save(driver);
    }else if ("Passenger".equalsIgnoreCase(type)){
        user.setType(Enums.UserType.Passenger);
        dao.save(user);
        Passenger passenger = new Passenger();
        passenger.setUserId(user.getId());
        passenger.setPhone(mobile);
        passengerDao.save(passenger);
    }else if ("Admin".equalsIgnoreCase(type)){
        user.setType(Enums.UserType.Admin);
        user.setRoles(roleId);
        dao.save(user);
    }

    return user;
}

/**
 * 上报信息
 */
@Async
public void mocpassengerUpload(String mobile){

    boolean update = true;
    MocPassengerInfo mocPassengerInfo = passengerInfoDao.getRepo().findByPhone(mobile);
    if (mocPassengerInfo == null){
        mocPassengerInfo = new MocPassengerInfo();
        update = false;
    }
    mocPassengerInfo.setPhone(mobile);
    mocPassengerInfo.setRegister(new Date());
    mocPassengerInfo.setStatus(mocService.upload("*",mocPassengerInfo, update ? MocInfo.Action.Update : MocInfo.Action.Add));
    passengerInfoDao.save(mocPassengerInfo);

}

controller层

@PostMapping("/api/user/register")
public Result register(@Pattern(regexp = Const.REGEXP_MOBILE, message = "手机号[mobile]格式不正确") String mobile,
                       @NotBlank(message = "密码[passwd]不能为空值") String passwd,
                       @NotBlank(message = "用户类型[type]不能为空值") String type,String name,
                       Integer companyId,Integer roleId,HttpServletRequest request){
    Map<String, Object> data = new HashMap<>();
    try {
        User users = userService.findUser(mobile,type);
        if (users!=null){
            return Result.fail(206, "用户已存在！");
        }
        if (CommonKit.passwdMD5(passwd).equalsIgnoreCase(CommonKit.passwd(mobile.substring(5)))) {
            return Result.fail(206, "密码过于简单，请更换密码");
        }

        if(companyId==null){
            companyId = Integer.valueOf(company);
        }
        User user = userService.userEdit(name,mobile, CommonKit.passwdMD5(passwd), IpKit.getIpAddr(request), type, companyId,roleId);
        data.put("uid", user.getId());
        data.put("token", tokenService.generate(user.getId(), 5*24*60));
        data.put("name", user.getName());
        data.put("mobile", user.getLoginKey());
        data.put("avatar", user.getPicUrl()!=null?rootUrl + user.getPicUrl():"");
        if(type.equals("Driver")){
            data.put("cname", companyInfoService.getDao().findSnapshoot(companyId).getName());
        }
        if(type.equals("Passenger")){
            userService.mocpassengerUpload(mobile);
        }
    }catch (Exception e){
        e.printStackTrace();
        return Result.error(901,"注册失败！");
    }
    return Result.ok(data);
}

使用@Async需要配置，配置如下：

package net.web.config;

import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
    @Override
    public Executor getAsyncExecutor() {
        //线程池设置
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize( 10 );//核心线程
        taskExecutor.setMaxPoolSize( 100 );//最大线程
        taskExecutor.setQueueCapacity( 40 );//队列大小
        taskExecutor.setThreadNamePrefix( "async-service-" );
        taskExecutor.initialize();
        return taskExecutor;
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        //直接返回 祖籍 AsyncUncaughtExceptionHandler 对象
        return AsyncConfigurer.super.getAsyncUncaughtExceptionHandler();
    }
}

另外还需要在启动类上添加注解：@EnableAsync

spring boot中使用@Async失效