1.什么是Spring的状态机
- Spring 状态机(Spring State Machine)是 Spring Framework 提供的一个模块,用于支持有限状态机(Finite State Machine,FSM)的实现。有限状态机是一个数学模型,描述了一个系统在不同状态之间的转换以及触发这些转换的事件。
- Spring 状态机主要用于处理对象的状态变化和状态之间的转换。它提供了一种以声明性的方式定义状态和状态之间转换的机制,并能够处理各种事件触发的状态迁移。这在某些应用中非常有用,比如工作流、订单处理、游戏引擎等领域。
- Spring StatsMachine主要涉及到两个重要的概念,一个是State(状态)、一个是Event(事件)。
2.Spring 状态机的使用
- 场景:商城项目中对于订单状态的层层转换。
1.使用Spring状态机先引入它的Maven依赖
<!-- 状态机--> <dependency> <groupId>org.springframework.statemachine</groupId> <artifactId>spring-statemachine-starter</artifactId> <version>2.2.0.RELEASE</version> </dependency> <!-- Spring State Machine Redis --> <dependency> <groupId>org.springframework.statemachine</groupId> <artifactId>spring-statemachine-redis</artifactId> </dependency>
2.生成状态机的状态与事件:(OrderState,OrderEvents)
- OrderState:
public enum OrderState { UNPAID, // 待支付 WAITING_FOR_RECEIVE, // 待收货 DONE // 结束 }
- OrderEvents
public enum OrderEvents { PAY, // 支付 RECEIVE // 收货 }
3.将状态与事件进行绑定:(StateMachineConfig)
@Configuration @EnableStateMachine(name = "StateMachineConfig") public class StateMachineConfig extends EnumStateMachineConfigurerAdapter<TestState, TestEvents> { private Logger logger = LoggerFactory.getLogger(getClass()); //定义初始状态 @Override public void configure(StateMachineStateConfigurer<TestState, TestEvents> states) throws Exception { states .withStates() .initial(TestState.UNPAID) .states(EnumSet.allOf(TestState.class)); } //状态转换过程 触发什么事件就转换为什么状态 @Override public void configure(StateMachineTransitionConfigurer<TestState, TestEvents> transitions) throws Exception { transitions .withExternal() .source(TestState.UNPAID).target(TestState.WAITING_FOR_RECEIVE) .event(TestEvents.PAY) .and() .withExternal() .source(TestState.WAITING_FOR_RECEIVE).target(TestState.DONE) .event(TestEvents.RECEIVE); } }
4.将事件监听触发与配置类进行配置:(EventListener)
@Component @WithStateMachine(name = "StateMachineConfig") public class EventListener { private Logger logger = LoggerFactory.getLogger(getClass()); @OnTransition(target = "UNPAID") public boolean create(Message<Order> order) {
// 创建订单逻辑 logger.info("订单创建,待支付"); return true; } @OnTransition(source = "UNPAID", target = "WAITING_FOR_RECEIVE") public boolean pay(Message<Order> order) { // 支付逻辑 从redis根据order 来进行处理 logger.info("用户完成支付,待收货"); return true; } @OnTransition(source = "WAITING_FOR_RECEIVE", target = "DONE") public boolean receive(Message<Order> order) {
//从redis中根据传入的order 来查询当前订单 并业务处理 logger.info("用户已收货,订单完成"); return true; } }
最后测试:
@SpringBootApplication public class DemoApplication implements CommandLineRunner { public DemoApplication(StateMachine<TestState, TestEvents> stateMachine) { this.stateMachine = stateMachine; } public static void main(String[] args) { SpringApplication.run(DemoApplication.class, args); } private final StateMachine<TestState, TestEvents> stateMachine; @Override public void run(String... args) throws Exception { Order order=new Order("测试",0); // 使用 MessageBuilder 创建消息并设置负载和头信息 Message message = MessageBuilder .withPayload(TestEvents.PAY) .setHeader("order", order) .build(); // 发送消息给状态机 stateMachine.start(); stateMachine.sendEvent(message); } }
测试结果:
文章来源:https://www.toymoban.com/news/detail-777092.html
结论:在一些工作流、订单处理的时候可以使用状态机这种设计模式,将状态和事件进行绑定,然后对状态改变进行监听,最后只需要在监听内部对业务代码进行处理。文章来源地址https://www.toymoban.com/news/detail-777092.html
到了这里,关于Spring状态机的介绍与使用的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!