Spring 具有 JPA 持久性的状态机 - 存储库使用

Question

我想弄清楚如何轻松使用 spring 状态机，包括 JPA 的持久性。这是我正在处理的问题：

不兼容的数据类型 - 工厂和持久性

在程序的某个时刻，我想使用连接到用户的状态机。有用于此目的的存储库（项目 spring-statemachine-data-jpa）。首先，使用存储库检查玩家的状态机是否已经存在。如果没有，创建一个新的状态机并持久化它。

问题是我有不同类型的状态机。工厂创建一个StateMachine<UserState, UserEvent>，存储库returns一个JpaRepositoryStateMachine。它们彼此不兼容，对我来说，不清楚如何保留/创建/恢复状态机。

你能帮我解释一下吗？

@Autowired
private StateMachineRepository<JpaRepositoryStateMachine> repository;

public someMethod(User user) {

Optional<JpaRepositoryStateMachine> stateMachine = repository.findById(user.getId()); // JPA state machine

if(stateMachine.isEmpty()) {
            StateMachine<UserState, UserEvent> createdStateMachine = factory.getStateMachine(user.getId()); // spring state machine
            repository.save(createdStateMachine); // compile error
        }

// here: ready-to-use statemachine - how?

}

感谢您的帮助！

Answer 1

尝试使用 Spring 提供的 SpringStateMachineService to get a state machine instance instead of explicitly retrieving it from repository or factory. You can use default 实现：

@Bean
public StateMachineService<State, Event> stateMachineService(
        final StateMachineFactory<State, Event> stateMachineFactory,
        final StateMachinePersist<WorkflowState, WorkflowEvent, String> stateMachinePersist) {
    return new DefaultStateMachineService<>(stateMachineFactory, stateMachinePersist);
}

因此，您的代码将如下所示：

@Autowired
private StateMachineService<State, Event> stateMachineService;

public someMethod(User user) {
StateMachine<State, Event> stateMachine = stateMachineService.acquireStateMachine(user.getId(), false);

// here: ready-to-use statemachine - call stateMachine.start() for example

}

如果你进入 acquireStateMachine 方法，你可以看到它通过 id 从存储库中查询状态机，如果没有找到则创建一个新的状态机。

您可以使用 JpaPersistingStateMachineInterceptor 在每次更改时隐式保存和更新状态机实例。

@Bean
public JpaPersistingStateMachineInterceptor<State, Event, String>
        jpaPersistingStateMachineInterceptor() {
    return new JpaPersistingStateMachineInterceptor(stateMachineRepository);
}

见Persisting State Machine

Spring 具有 JPA 持久性的状态机 - 存储库使用

Spring state machine with JPA persistence- Repository usage

java

spring

spring-data-jpa

spring-boot

spring-statemachine