我在单独的线程中有20个并发用户处理订单。如何使用弹簧状态机维护状态?
我在尝试:
public class myclass extends EnumStateMachineConfigurerAdapter<OrderState, OrderEvents>
@Override
public void configure(StateMachineTransitionConfigurer<OrderState, OrderEvents> transitions)
throws Exception {
transitions
.withExternal()
.source(OrderState.A).target(OrderState.B)
.event(OrderEvents.X)
.and()
.withExternal()
.source(OrderState.A).target(OrderState.C)
.event(OrderEvents.Y)
@Override
public void configure(StateMachineConfigurationConfigurer<OrderState, OrderEvents> config) throws Exception {
config
.withConfiguration()
.autoStartup(true)
.listener(new OrderStateMachineListener());
}
但是,它告诉我状态机,而不是命令的顺序:
@Override
public void stateChanged(State<OrderState, OrderEvents> from, State<OrderState, OrderEvents> to) {
System.out.println("Order state changed to " + to.getId());
}
我对此有其他选择,但是对于每个事件,此选项看起来并不好:
stateMachine.stop();
stateMachine
.getStateMachineAccessor()
.doWithAllRegions(access -> access.resetStateMachine(new DefaultStateMachineContext<>(sourceState, null, null, null)));
stateMachine.start();
stateMachine.sendEvent(event);
最佳答案
终于奏效了。我必须在配置级别而不是@EnableStateMachine上使用@EnableStateMachineFactory,并从调用程序中使用:
@Autowired
StateMachineFactory<String, String> factory;
public void getOrderStatus(long id) {
StateMachine<String, String> stateMachine = factory.getStateMachine();
stateMachine.start();
stateMachine.sendEvent();
}