Spring状态机的介绍与使用
1.什么是Spring的状态机[*]Spring 状态机（Spring State Machine）是 Spring Framework 提供的一个模块，用于支持有限状态机（Finite State Machine，FSM）的实现。有限状态机是一个数学模型，描述了一个系统在不同状态之间的转换以及触发这些转换的事件。
[*]Spring 状态机主要用于处理对象的状态变化和状态之间的转换。它提供了一种以声明性的方式定义状态和状态之间转换的机制，并能够处理各种事件触发的状态迁移。这在某些应用中非常有用，比如工作流、订单处理、游戏引擎等领域。
[*]Spring StatsMachine主要涉及到两个重要的概念，一个是State(状态)、一个是Event(事件)。
https://img2024.cnblogs.com/blog/2222048/202401/2222048-20240109143027767-1428057866.png
2.Spring 状态机的使用
[*]场景：商城项目中对于订单状态的层层转换。
1.使用Spring状态机先引入它的Maven依赖
<dependency>
<groupId>org.springframework.statemachine</groupId>
<artifactId>spring-statemachine-starter</artifactId>
<version>2.2.0.RELEASE</version>
</dependency>
<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) {<br> // 创建订单逻辑
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) {<br> //从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://img2024.cnblogs.com/blog/2222048/202401/2222048-20240109145704596-11646131.png
结论：在一些工作流、订单处理的时候可以使用状态机这种设计模式，将状态和事件进行绑定，然后对状态改变进行监听，最后只需要在监听内部对业务代码进行处理。
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！
页:
[1]