Spring Boot JPA多租户独立架构下的事务管理问题

核心问题根源 #

你遇到的问题本质是：Spring声明式事务（@Transactional）会在方法启动时就绑定一个数据库连接，后续在方法内切换TenantContext不会触发数据源重新路由——因为事务生命周期内连接是固定的，无法动态切换。

解决思路与具体实现 #

1. 拆分事务为独立单元

将跨租户的更新逻辑拆分为多个独立事务，每个租户的更新单独开启新事务，避免单个事务绑定固定数据源。可以通过声明式事务的REQUIRES_NEW传播属性实现：

// 主方法去掉@Transactional，改为协调多个子事务
public void updateUserProfile(Long id, List<Tenant> tenants, String link) {
    // 先获取基准用户资料（注意初始租户上下文需正确设置）
    UserProfile baseProfile = userProfileRepository.findById(id)
                          .orElseThrow(() -> new EntityNotFoundException("UserProfile not found"));

    // 循环更新每个租户的serviceType
    for (Tenant tenant : tenants) {
        updateTenantServiceType(baseProfile.getId(), tenant.getId());
    }

    // 更新公共/默认租户的link字段
    TenantContext.clear();
    updateProfileLink(baseProfile.getId(), link);
}

// 每个租户的更新用新事务
@Transactional(propagation = Propagation.REQUIRES_NEW)
private void updateTenantServiceType(Long profileId, String tenantId) {
    TenantContext.setTenantId(tenantId);
    // 必须从当前租户的数据源重新查询实体，不能复用外部的baseProfile
    UserProfile tenantProfile = userProfileRepository.findById(profileId)
                          .orElseThrow(() -> new EntityNotFoundException("Profile not found in tenant: " + tenantId));
    tenantProfile.setServiceType("Hans");
    userProfileRepository.save(tenantProfile);
}

// 更新link字段用新事务
@Transactional(propagation = Propagation.REQUIRES_NEW)
private void updateProfileLink(Long profileId, String link) {
    UserProfile publicProfile = userProfileRepository.findById(profileId)
                          .orElseThrow(() -> new EntityNotFoundException("Profile not found in default tenant"));
    publicProfile.setLink(link);
    userProfileRepository.save(publicProfile);
}

2. 确保数据源路由的实时性

检查你的AbstractRoutingDataSource实现，必须保证每次获取数据库连接时都能读取最新的TenantContext：

public class TenantRoutingDataSource extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        // 每次获取连接都会调用此方法，确保拿到当前租户ID
        return TenantContext.getTenantId();
    }
}

如果你的实现存在缓存逻辑（比如只在事务启动时获取一次租户ID），会导致切换TenantContext无效，必须移除这类缓存。

3. 避免持久化上下文污染

不要在不同租户的事务中复用同一个UserProfile实体对象——每个租户的实体属于各自的持久化上下文，复用会导致数据写入错误的租户Schema，甚至抛出持久化异常。必须在每个租户事务中重新查询实体。

4. 事务一致性权衡

拆分事务后，可能出现部分租户更新成功、部分失败的情况：

• 如果业务要求强一致性，需要引入分布式事务（如XA协议），但会增加系统复杂度；
• 如果允许最终一致性，可以通过记录失败租户、定时重试的方式保证数据同步。

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