Spring多租户项目中@Scheduled定时方法如何实现事务操作？

报错根因 #

你使用的多租户动态数据源路由依赖租户上下文（通常用ThreadLocal存储）获取当前租户ID作为数据源lookup key。@Scheduled定时任务独立于web请求运行，默认没有设置租户上下文，所以路由数据源时拿到的key为null，直接抛出无法找到目标数据源的异常。

解决方法 #

你需要在定时任务中主动遍历所有租户，逐个设置租户上下文后再执行事务方法，执行完清理上下文避免线程复用导致租户串扰。

步骤1：确认租户上下文持有类 #

你的项目中一定有存储当前租户ID的工具类，通常结构如下：

public class TenantContextHolder {
    private static final ThreadLocal<String> TENANT_ID = new ThreadLocal<>();

    public static void setCurrentTenantId(String tenantId) {
        TENANT_ID.set(tenantId);
    }

    public static String getCurrentTenantId() {
        return TENANT_ID.get();
    }

    public static void clear() {
        TENANT_ID.remove();
    }
}

步骤2：改造定时调度类 #

@Service
public class UsageServiceScheduler {

    @Autowired
    private UsageService usageService;
    // 注入租户配置类，获取所有租户ID
    @Autowired
    private TenantDataSourceProperties tenantDataSourceProperties;

    // 原cron是每周日凌晨1点，需要13点执行请改为 0 0 13 * * SUN
    @Scheduled(cron = "0 0 13 * * SUN")
    public void callScheduledTask() {
        // 获取所有已配置的租户ID
        Set<Object> allTenantIds = tenantDataSourceProperties.getDataSources().keySet();
        for (Object tenantId : allTenantIds) {
            try {
                // 为当前线程设置租户上下文
                TenantContextHolder.setCurrentTenantId(tenantId.toString());
                // 调用带事务的业务方法，此时事务获取数据源时就能拿到正确的租户key
                usageService.createNewCapacities();
            } catch (Exception e) {
                // 单个租户执行失败打日志即可，不影响其他租户运行
                e.printStackTrace();
            } finally {
                // 必须清理上下文，定时任务线程池是复用的，不清理会出现租户串扰
                TenantContextHolder.clear();
            }
        }
    }
}

注意事项 #

• createNewCapacities方法的@Transactional要保证是public修饰，且是通过Spring代理调用，不要在类内部自调用，否则事务不生效。
• 事务是按租户维度独立生效的，单个租户执行异常不会影响其他租户的事务提交。
• 如果你的数据源lookup key不是String类型，把tenantId.toString()换成对应类型的转换逻辑即可。

内容的提问来源于stack exchange，提问作者ShaxoLudoz