用于数据持久性的BusinessCode强制约束

Question

我目前正在实现一个基于 JavaEE 的应用程序，其结构大致如下：

RestService
├── BusinessService
    ├── ServiceDAO

webservice接收请求并将它们转发给实际的业务服务，然后业务服务通过DAO执行多个操作。重要的是，BusinessService必须使用只能通过业务代码表达的约束，而不是通过SQL约束(我们不希望实现复杂的数据库触发器或存储过程)来对照现有记录检查数据。在这种情况下，约束是没有两个数据集可能具有重叠有效性。

对于最小方案，代码如下所示：

@Table
public class DataEntity {
    @Id
    public int id;

    @Column("validFrom")
    public Instant validFrom;

    @Column("validTo")
    public Instant validTo;
}

@Path("/rest-service-path")
public class RestService {
    @Inject
    private BusinessService businessService;

    @POST
    @Path("add")
    public void addData(DataEntity data) {
        businessService.addData(data);
    }
}

@Stateless
public class BusinessService {
    @Inject
    private ServiceDAO serviceDAO;

    public void addData(DataEntity data) {
        List<DataEntity> overlappingData =
            serviceDAO.findOverlapping(data.getValidFrom(), data.getValidTo());
        if (!overlappingData.isEmpty()) {
            throw new IllegalStateException("Cannot have time overlaps");
        }
        serviceDAO.save(data);
    }
}

@Stateless
public class ServiceDAO {
    @Inject
    private EntityManager entityManager;

    public List<DataEntity> findOverlapping(Instant from, Instant to) {
        // finds records that have their validity interval overlap with the supplied one
    }

    public void save(DataEntity data) {
        entityManager.persist(data);
    }
}

如果我正确理解了 EJB，则上述代码具有以下隐式行为：

• @Stateless注释将BusinessService和ServiceDAO，转换为EJB
• 默认情况下，BusinessService和ServiceDAO具有容器并发管理功能。
• 默认情况下，BusinessService#addData和ServiceDAO#addData的事务类型为“必需”，因为它们是公共EJB方法。
• 因为＜code＞BusinessService#addData

我面临的问题是，对< code >/rest-service-path/add 的两个并发调用打开了两个独立的事务，这也将并发执行验证检查。如果两个数据集都通过了检查，但两个数据集合在一起会违反约束，则它们仍会被添加到数据库中，因为由于单独的事务，它们看不到彼此。

我目前的解决方法（我不太有信心）是使业务服务成为@Singleton。这将隐式地给出添加数据锁定类型.WRITE，这意味着没有两个对addData的调用可以同时运行。这有以下问题：

• 如果我们有两个或多个单独的java进程运行该服务，则没有帮助，因为锁定仅适用于每个EJB。
• 它阻止了不会相互干扰的数据实体的并发处理，这是我们的大多数情况。这会导致性能更差

到目前为止，我对这一切的理解正确吗？如何安全、更优雅地实施业务代码中定义的约束，如上面所述？我同意在DAO中抛出异常，只要它保持一致性。

Answer 1

我不认为你会绕过一个单例实例，但你可以通过不将EJB设置为单例，而是引入另一个管理已经处理的数据的服务来最小化影响。

本质上，它将包含正在检查的DataEntity的集合。如果它们不重叠，可以同时检查它们，因此您可以通过首先检查新候选者和队列中的候选者之间的重叠来最大化并发。

如果要添加 DataEntity，但已经检查了一个重叠的实体，则必须等到该检查完成（毕竟，可能无法添加前一个实体，但可以添加最近的实体）。为此，您需要一种机制来稍后触发排队检查。