我在单独的线程中有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();
    }

07-28 03:05
查看更多