🧭 Statechart и Spring State Machine: когда FSM уже недостаточно

/ Перечисления для состояний и событий enum States { IDLE, PROCESSING, PROCESSING_INITIALIZING, PROCESSING_EXECUTING, PROCESSING_FINALIZING, COMPLETED, ERROR } enum Events { START, INITIALIZE_DONE, EXECUTE_DONE, FINALIZE_DONE, SUCCESS, FAIL, RESET }

@Configuration @EnableStateMachine public class RequestStateMachineConfig extends StateMachineConfigurerAdapter<States, Events> { @Override public void configure(StateMachineConfigurationConfigurer<States, Events> config) throws Exception { config .withConfiguration() .autoStartup(true) .listener(new StateMachineListener()); // Добавим слушателя для логирования } @Override public void configure(StateMachineStateConfigurer<States, Events> states) throws Exception { states .withStates() .initial(States.IDLE) .state(States.COMPLETED) .state(States.ERROR) .state(States.PROCESSING, processingActions()) // Действия для родительского состояния PROCESSING .end(States.COMPLETED) // Конечные состояния для ветки .end(States.ERROR) .and() .withStates() .parent(States.PROCESSING) // Определяем вложенные состояния .initial(States.PROCESSING_INITIALIZING) .state(States.PROCESSING_EXECUTING) .state(States.PROCESSING_FINALIZING); } @Override public void configure(StateMachineTransitionConfigurer<States, Events> transitions) throws Exception { transitions .withExternal() .source(States.IDLE).target(States.PROCESSING).event(Events.START) .action(startProcessingAction()) .and() .withExternal() .source(States.PROCESSING_INITIALIZING).target(States.PROCESSING_EXECUTING) .event(Events.INITIALIZE_DONE) .action(initializeDoneAction()) .and() .withExternal() .source(States.PROCESSING_EXECUTING).target(States.PROCESSING_FINALIZING).event(Events.EXECUTE_DONE) .action(executeDoneAction()) .and() .withExternal() .source(States.PROCESSING_FINALIZING).target(States.COMPLETED).event(Events.FINALIZE_DONE) .action(finalizeDoneAction()) .and() .withExternal() .source(States.PROCESSING).target(States.ERROR).event(Events.FAIL) // Переход из родительского состояния .action(failAction()) .and() .withExternal() .source(States.COMPLETED).target(States.IDLE).event(Events.RESET) .action(resetAction()) .and() .withExternal() .source(States.ERROR).target(States.IDLE).event(Events.RESET) .action(resetAction()); } // Действия (Actions) public Action<States, Events> startProcessingAction() { return context -> System.out.println("Entering PROCESSING state from IDLE."); } public Action<States, Events> initializeDoneAction() { return context -> System.out.println("Processing: Initializing done. Moving to EXECUTING."); } // .... // Логирование состояний static class LoggingStateStateMachineListener extends StateMachineListenerAdapter<States, Events> { @Override public void stateChanged(State<States, Events> from, State<States, Events> to) { if (from != null) { System.out.println("Transition: " + from.getId() + " -> " + to.getId()); } else { System.out.println("Initial state: " + to.getId()); } } } }

@SpringBootApplication public class SpringFsmDemoApplication implements CommandLineRunner { @Autowired private StateMachine<States, Events> stateMachine; public static void main(String[] args) { SpringApplication.run(SpringFsmDemoApplication.class, args); } @Override public void run(String... args) throws Exception { System.out.println("Current state: " + stateMachine.getState().getId()); stateMachine.sendEvent(Events.START); System.out.println("Current state: " + stateMachine.getState().getId()); // Должно быть PROCESSING_INITIALIZING stateMachine.sendEvent(Events.INITIALIZE_DONE); System.out.println("Current state: " + stateMachine.getState().getId()); // Должно быть PROCESSING_EXECUTING stateMachine.sendEvent(Events.EXECUTE_DONE); System.out.println("Current state: " + stateMachine.getState().getId()); // Должно быть PROCESSING_FINALIZING stateMachine.sendEvent(Events.FINALIZE_DONE); System.out.println("Current state: " + stateMachine.getState().getId()); // Должно быть COMPLETED stateMachine.sendEvent(Events.RESET); System.out.println("Current state: " + stateMachine.getState().getId()); // Должно быть IDLE } }