java - 同步块(synchronized block)抛出 DuplicateKeyException

Question

下面是我在线程 Spring 执行器下的类(class)。根据源/服务的类型 TAXP、TAXS、TAXT 方法被调用。
逻辑是如果“taxInfo.getGroupingId()”已经存在于主税表中，则不要插入，否则插入主表。
插入所有二级和三级表记录。 TAXP、TAXS、TAXT 是主题，它们随时接收数据。可能存在毫秒间隙，或者同时发送数据，以便同步块(synchronized block)。

所有 3 个方法都是从 3 个不同的线程执行器调用的。

executor1.insertPrimaryTaxInfo(taxInfo);
executor2.insertSecTaxInfo(taxInfo);
executor3.insertTerTaxInfo(taxInfo);

@Service
@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
public class TaxServiceImpl implements TaxService {
private static final Logger LOG = LogManager.getLogger(ScanServiceImpl.class);
// TAXP
@Override
    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = TaxServiceException.class)
    public void insertPrimaryTaxInfo(TaxInfo taxInfo) throws TaxServiceException {
        String taxId = null;
        try {

            synchronized (this) {
                taxId = taxMapper.checkExists(taxInfo.getGroupingId());             
                if (taxId == null) {
                    taxMapper.insertTaxInfo(taxInfo);   // primary tax table
                }
            }

            LOG.info("tax id --  " + taxId);
        } catch (Exception ex) {
            LOG.error("Error inserting txId for " + taxInfo.getGroupingId()
                    + ex);
            throw new TaxServiceException(ex);
        }
    }


// TAXS
@Override
    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = TaxServiceException.class)
    public void insertSecTaxInfo(TaxInfo taxInfo) throws TaxServiceException {
        String taxId = null;
        try {

            synchronized (this) {
                taxId = taxMapper.checkExists(taxInfo.getGroupingId());             
                if (taxId == null) {
                    taxMapper.insertTaxInfo(taxInfo);   // primary tax table
                }
            }
            taxMapper.insertIntoSecTable(taxInfo); // secondary tax table
            LOG.info("tax id --  " + taxId);
        } catch (Exception ex) {
            LOG.error("Error inserting txId for " + taxInfo.getGroupingId()
                    + ex);
            throw new TaxServiceException(ex);
        }
    }


// TAXT
@Override
    @Transactional(propagation = Propagation.REQUIRED, rollbackFor = TaxServiceException.class)
    public void insertTerTaxInfo(TaxInfo taxInfo) throws TaxServiceException {
        String taxId = null;
        try {

            synchronized (this) {
                taxId = taxMapper.checkExists(taxInfo.getGroupingId());             
                if (taxId == null) {
                    taxMapper.insertTaxInfo(taxInfo);   // primary tax table
                }
            }
            taxMapper.insertIntoSecTable(taxInfo);  // secondary tax table
            taxMapper.insertIntoTerTable(taxInfo);  // Tertiary tax table
            LOG.info("tax id --  " + taxId);
        } catch (Exception ex) {
            LOG.error("Error inserting txId for " + taxInfo.getGroupingId()
                    + ex);
            throw new TaxServiceException(ex);
        }
    }

}

问题是当TAXP、TAXS、TAXT同时获取数据时，上述3个方法同时调用。以毫秒的差异，一个线程插入到主表中，另一个线程试图做同样的事情，但发现表中已经存在一条记录并抛出重复的键异常。

我得到以下异常:

"com.data.exception.TaxServiceException: org.springframework.dao.DuplicateKeyException: 
### Error updating database.  Cause: java.sql.SQLIntegrityConstraintViolationException: ORA-00001: unique constraint (TAXDB2.TAX_PK) violated

同步块(synchronized block)的原因是为了克服这个异常。上面的代码有什么问题？

Answer 1

看起来您可能正在尝试在应用程序中生成非基于 guid 的主键，而不是让数据库生成它们并遇到冲突。

尝试在应用程序中同步数据库访问是一场失败的战斗。您应该让数据库通过其现有机制来管理并发。更多信息请引用 ACID .此外，在您的数据库实现中查找当前隔离级别以及与其他隔离级别相比它的作用非常有指导意义。例如 SQL Server 文档 Understanding Isolation Levels