如何从运行时构建的上下文中还原状态机？

Question

我有一个状态机

@EnableStateMachine
@Configuration
public class StateMachineConfiguration extends EnumStateMachineConfigurerAdapter<Status, Event> {
    @Override
    public void configure(StateMachineStateConfigurer<Status, Event> states) throws Exception {
        states.withStates()
                .initial(Status.DRAFT)
                .states(EnumSet.allOf(Status.class));
    }

    @Override
    public void configure(StateMachineTransitionConfigurer<Status, Event> transitions) throws Exception {
        transitions

                .withExternal()
                .target(Status.INVITATION).source(Status.DRAFT)
                .event(Event.INVITED)
                .guard(new Guard())
                .action(new ActionInvited())
                .and()

                .withExternal()
                .target(Status.DECLINED).source(Status.INVITATION)
                .event(Event.DECLINED)
                .action(new ActionDeclined());
    }

    @Override
    public void configure(StateMachineConfigurationConfigurer<Status, Event> config) throws Exception {
        config.withConfiguration().autoStartup(true);
    }
}

我有一个模型，例如 Order 。模型保留在DB中。我从数据库中提取模型，现在我的模型处于状态Order.status == INVITATION。我想继续使用状态机处理模型，但是状态机的实例将以初始状态 DRAFT 开始处理，但是我需要从状态
INVITATION 继续处理。换句话说我要执行

stateMachine.sendEvent(MessageBuilder
  .withPayload(Event.DECLINED)
  .setHeader("orderId", order.id)
  .build()
)

并执行动作ActionDeclined()。我不想在DB中保留状态机的上下文。我想将stateMachine的状态设置为运行时模型的状态。我怎样才能正确地做到这一点？使用DefaultStateContext构造函数还是还有其他更漂亮的方法？

Answer 1

一种可行的方法是StateMachine即时创建并使用的状态从数据库中重新补充状态机Order。在这种情况下，您需要执行以下步骤：

• 重设StateMachine所有地区
• Order从数据库加载状态
• 新建DefaultStateMachineContext并相应地填充

假设您有一个build方法，该方法返回用于处理订单事件的新状态机（使用StateMachineFactory），但是对于现有订单，它将从数据库中重新补充状态。

StateMachine<Status, Event> build(long orderId) {
  orderService.getOrder(orderId) //returns Optional
  .map(order -> {
     StateMachine<Status, Event> sm = stateMachineFactory.getStateMachine(Long.toString(orderId));
     sm.stop();
     rehydrateState(sm, sm.getExtendedState(), order.getStatus());
     sm.start();
     return sm;
   })
  .orElseGet(() -> createNewStateMachine(orderId);
}


void rehydrateState(StateMachine<Status, Event> newStateMachine, ExtendedState extendedState, Status orderStatus) {
  newStateMachine.getStateMachineAccessor().doWithAllRegions(sma ->
   sma.resetStateMachine(new DefaultStateMachineContext<>(orderStatus, null, null, extendedState));
  });
}