使用spring正确注释Transaction中的传播和隔离

Question

我编写了一个任务调度程序作业，它每 30 分钟为符合条件的患者生成账单。在这里，我很困惑我保持的传播和隔离级别是否按照标准是正确的。我应该始终使用 REQUIRES_NEW 作为传播的一部分吗？

关于以下部分的任何建议。

private void startBilling() throws Exception {
    List<Integer> patientIds = null;
    try {
        patientIds = getPatientsForBilling();
        if(null != patientIds) {
            for(Integer patient : patientIds) {
                updatePatientDetails(patient, "STARTED", jdbcTemplate);
                makeBillForPatient(patient, jdbcTemplate);
                updatePatientDetails(patient, "COMPLETED", jdbcTemplate);
            }
        }
    } catch (Exception e) {
         //LOG HERE
         updatePatientDetails(patient, "TERMINATED", jdbcTemplate);
    }
}

@Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class,isolation = Isolation.SERIALIZABLE)
private void makeBillForPatient(Integer patient, JdbcTemplate jdbcTemplate2) {
    // A bill for the patient will be generated and printed
}

@Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class,isolation = Isolation.SERIALIZABLE)
private void updatePatientDetails(Integer patient,
        String status, JdbcTemplate jdbcTemplate) {
    // Update the patient billing status STARTED
}

@Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class,isolation = Isolation.SERIALIZABLE)
private List<Integer> getPatientsForBilling() {
    return new ArrayList<Integer>();
}

这是我实现的逻辑

1. 一旦任务调度程序启动，它将获取所有符合条件的患者进行计费（即出院的患者）
2. 它会将状态更新为已启动。
3. 它将生成账单
4. 它会将状态更新为 COMPLETED

任何想法将不胜感激。

Answer 1

其实这取决于你的逻辑。据我了解，您将患者标记为已开始，然后执行一些可能需要长时间运行的复杂任务（创建账单），然后释放患者。

这些操作应该是隔离的，因此您需要为每个操作单独事务，在这种情况下 REQUIRES_NEW 就可以了。

但是您的逻辑（显示在发布的代码中）有一些漏洞。

想象一下 makeBillForPatient() 方法调用会引发异常。你遇到的麻烦：

1. 患者类型卡在 STARTED 状态。您需要以某种方式处理保持 STARTED 状态的患者以重置它们。

2. 没有处理所有其余患者，因为您在异常发生时离开了循环。

这样的代码

    patientIds = getPatientsForBilling();
    if(null != patientIds) {
        for(Integer patient : patientIds) {
            try {
                updatePatientDetails(patient, "STARTED", jdbcTemplate);
                try {
                    makeBillForPatient(patient, jdbcTemplate);
                    updatePatientDetails(patient, "COMPLETED", jdbcTemplate);
                } catch (Exception e) {
                    //print something in the log here and reset patient status
                    updatePatientDetails(patient, "INITIAL", jdbcTemplate);
                }
            } catch (Exception e) {
                //print something in the log here
            }
        }
    }

也不要留下空的 catch 块。万一出现问题，真的很难找到源头。至少在日志中打印一些内容。