Spring Boot多数据源数据复制：detached entity异常排查与优化

错误原因 #

你遇到的PersistentObjectException核心问题如下：

• 主数据源事务执行完成后，joinPoint.proceed()返回的result对象已脱离主EntityManager上下文，成为**游离态（detached）**对象，且已拥有数据库生成的ID。
• 你通过原entity的ID是否为null判断新增操作，但此时result已被主数据源赋值ID，用副EntityManager的persist()方法操作这个带ID的游离对象会触发异常——persist()仅支持保存**瞬时态（transient，无ID）**对象，不接受已关联过其他EntityManager的游离对象。
• 另外，EntityManager注入存在冲突：@PersistenceContext(unitName = "replication")用于获取指定持久化单元的EntityManager，而@Qualifier("secondaryEntityManagerFactory")是注入EntityManagerFactory，两者不能混用。

修正后的切面代码 #

方案1：统一使用merge()处理游离态对象 #

merge()方法可自动处理游离态对象：副数据源中无对应ID记录则执行新增，有则执行更新，无需判断操作类型：

@Aspect
@Component
public class ReplicatorAspect {
    // 仅保留@PersistenceContext指定副数据源的持久化单元
    @PersistenceContext(unitName = "replication")
    private EntityManager replicationManager;

    // 使用REQUIRES_NEW传播行为，确保副事务在主事务提交后独立执行
    @Transactional(value = "secondTxManager", propagation = Propagation.REQUIRES_NEW)
    @Around("execution(* com.demo.repository.*.save*(..)) && args(entity)")
    public Object replicateEntity(ProceedingJoinPoint joinPoint, Object entity) throws Throwable {
        // 先执行主数据源的保存逻辑
        Object result = joinPoint.proceed();
        
        // 用merge处理游离态对象，自动适配新增/更新
        replicationManager.merge(result);
        replicationManager.flush();
        
        return result;
    }
}

方案2：手动控制事务（适合精细异常处理） #

如果需要自定义事务提交/回滚逻辑，可手动管理副数据源事务：

@Aspect
@Component
public class ReplicatorAspect {
    @PersistenceContext(unitName = "replication")
    private EntityManager replicationManager;

    @Around("execution(* com.demo.repository.*.save*(..)) && args(entity)")
    public Object replicateEntity(ProceedingJoinPoint joinPoint, Object entity) throws Throwable {
        Object result = joinPoint.proceed();

        // 手动管理副数据源事务
        EntityTransaction tx = replicationManager.getTransaction();
        try {
            tx.begin();
            replicationManager.merge(result);
            replicationManager.flush();
            tx.commit();
        } catch (Exception e) {
            if (tx.isActive()) {
                tx.rollback();
            }
            // 根据迁移需求决定是否抛出异常（比如允许副数据源失败不影响主操作）
            throw e;
        }
        return result;
    }
}

更优实现方案 #

1. 数据库级同步（推荐） #

迁移场景下，代码级同步的性能和可靠性不如数据库原生同步方案：

• MySQL：主从复制、GTID同步
• Oracle：GoldenGate、Data Guard
• PostgreSQL：流复制、逻辑复制
  这种方式无需修改代码，性能更高，且能保证数据一致性。

2. 自定义Repository实现 #

放弃切面，直接在Repository层实现双数据源保存，逻辑更直观，减少切面的"黑盒"操作：

// 自定义Repository接口
public interface TestEntityCustomRepository {
    <S extends TestEntity> S save(S entity);
}

// 实现类
@Repository
public class TestEntityRepositoryImpl implements TestEntityCustomRepository {
    @Autowired
    private TestEntityRepository mainRepository;
    @Autowired
    @Qualifier("secondaryTestEntityRepository")
    private TestEntityRepository secondaryRepository;
    @Autowired
    @Qualifier("secondTxManager")
    private PlatformTransactionManager secondaryTxManager;

    @Transactional("mainTxManager")
    @Override
    public <S extends TestEntity> S save(S entity) {
        S saved = mainRepository.save(entity);
        
        // 用TransactionTemplate开启独立事务执行副数据源保存
        TransactionTemplate txTemplate = new TransactionTemplate(secondaryTxManager);
        txTemplate.execute(status -> {
            secondaryRepository.save(saved);
            return null;
        });
        
        return saved;
    }
}

3. 事件驱动异步同步 #

如果迁移不需要强实时一致性，可采用事件驱动实现异步同步，避免阻塞主业务流程：

// 定义保存事件
public class EntitySavedEvent<T> extends ApplicationEvent {
    private final T entity;

    public EntitySavedEvent(T entity) {
        super(entity);
        this.entity = entity;
    }

    public T getEntity() {
        return entity;
    }
}

// 业务层发布事件
@Service
public class TestEntityService {
    @Autowired
    private TestEntityRepository mainRepository;
    @Autowired
    private ApplicationEventPublisher eventPublisher;

    @Transactional
    public TestEntity save(TestEntity entity) {
        TestEntity saved = mainRepository.save(entity);
        eventPublisher.publishEvent(new EntitySavedEvent<>(saved));
        return saved;
    }
}

// 监听器处理副数据源同步
@Component
public class EntityReplicationListener {
    @Autowired
    @Qualifier("secondaryTestEntityRepository")
    private TestEntityRepository secondaryRepository;

    @Transactional("secondTxManager")
    @EventListener
    public void onEntitySaved(EntitySavedEvent<TestEntity> event) {
        secondaryRepository.save(event.getEntity());
    }
}

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