Spring StateMachine实现状态机使用示例详解

更新时间：2025年07月12日 14:28:34 作者：混的Java

本文介绍SpringStateMachine实现状态机的步骤,包括依赖导入、枚举定义、状态转移规则配置、上下文管理及服务调用示例,重点解析状态同步、事件触发与数据持久化机制,感兴趣的朋友跟随小编一起看看吧

什么是状态机

状态机是计算机科学中的核心建模工具，用于描述对象在其生命周期内状态变化的逻辑模型。它通过定义有限状态集合、状态转移规则和触发事件，精确控制系统的行为逻辑。

本文主要讲Spring StateMachine实现的状态机

使用示例

导入maven依赖

        <dependency>
            <groupId>org.springframework.statemachine</groupId>
            <artifactId>spring-statemachine-core</artifactId>
            <version>4.0.0</version>
        </dependency>

创建订单状态枚举类

public enum OrderStatusEnum {
    WAITING_PAYMENT,//待支付
    WAITING_RECEIVE,//待取货
    FINISHED,//已完成
    CANCELED;//已取消
}

创建订单转悠事件枚举类

public enum OrderEvent {
    CREATE_ORDER,//创建订单
    PAY_ORDER,//支付订单
    RECEIVE_ORDER,//取货
    CANCEL_ORDER,//取消订单
    FINISH_ORDER//完成订单
}

添加状态机实例并添加状态转移规则

@Configuration
@EnableStateMachine(name="orderStateMachine")
public class OrderStateMachineConfig {
    @Bean
    public StateMachine<OrderStatusEnum, OrderEvent> orderStateMachine() throws Exception {
        StateMachineBuilder.Builder<OrderStatusEnum, OrderEvent> builder = StateMachineBuilder.builder();
        // 配置状态
        builder.configureStates()
                .withStates()
                .initial(OrderStatusEnum.WAITING_PAYMENT) // 初始状态
                .states(EnumSet.allOf(OrderStatusEnum.class));// 配置所有状态
        // 配置状态转换 规则
        builder.configureTransitions()
                // 订单待支付 -> 待取货
                .withExternal()
                .source(OrderStatusEnum.WAITING_PAYMENT).target(OrderStatusEnum.WAITING_RECEIVE)
                .event(OrderEvent.PAY_ORDER)
                .and()
                // 订单待取货 -> 已完成
                .withExternal()
                .source(OrderStatusEnum.WAITING_RECEIVE).target(OrderStatusEnum.FINISHED)
                .event(OrderEvent.FINISH_ORDER)
                .and()
                // 订单待支付 -> 已取消
                .withExternal()
                .source(OrderStatusEnum.WAITING_PAYMENT).target(OrderStatusEnum.CANCELED)
                .event(OrderEvent.CANCEL_ORDER);
        return builder.build();
    }
}

注入上下文bean，方法作用后面会说

@Bean
    public DefaultStateMachinePersister persister(){
        return new DefaultStateMachinePersister<>(new StateMachinePersist<Object, Object, Order>() {
            @Override
            public void write(StateMachineContext<Object, Object> context, Order order) throws Exception {
                //此处并没有进行持久化操作
                System.out.println("订单状态持久化：" + context.getState());
            }
            @Override
            public StateMachineContext<Object, Object> read(Order order) throws Exception {
                //此处直接获取order中的状态，其实并没有进行持久化读取操作
                return new DefaultStateMachineContext(order.getStatus(), null, null, null);
            }
        });
    }

创建调用示例服务

@Service
@RequiredArgsConstructor
public class OrderService {
    private final StateMachine<OrderStatusEnum, OrderEvent> orderStateMachine;
    private final DefaultStateMachinePersister persister;
    // 1、事件： 支付
    // 2、状态转换：待支付 → 待发货\
     public Order pay() {
         Order order = Order
                 .builder()
                 .orderId("1")
                 .status(OrderStatusEnum.WAITING_RECEIVE)
                 .build();
         System.out.println("线程名称：" + Thread.currentThread().getName() + " 尝试支付，订单号：" + order.getOrderId());
        Message message = MessageBuilder.withPayload(OrderEvent.PAY_ORDER).setHeader("order", order).build();
        if (!sendEvent(message, order)) {
            System.out.println("线程名称：" + Thread.currentThread().getName() + " 支付失败, 状态异常，订单号：" + order.getOrderId());
        }
        System.out.println("线程名称：" + Thread.currentThread().getName() + " 支付成功，订单号：" + order.getOrderId());
        return order;
    }
    /**
     * 发送订单状态转换事件
     *
     * @param message
     * @param order
     * @return
     */
    private synchronized boolean sendEvent(Message<OrderEvent> message, Order order) {
        boolean result = false;
        try {
            orderStateMachine.start();
            //尝试恢复状态机状态
            persister.restore(orderStateMachine, order);
            //添加延迟用于线程安全测试
            Thread.sleep(1000);
            result = orderStateMachine.sendEvent(message);
            //持久化状态机状态
            persister.persist(orderStateMachine, order);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            orderStateMachine.stop();
        }
        return result;
    }
}

代码解析：

创建订单示例模拟数据库实际订单信息，基于当前订单状态变换的流转与事件创建对应message消息，同时添加head信息。调用sendEvent方法使用状态机判断。

public Order pay() {
         Order order = Order
                 .builder()
                 .orderId("1")
                 .status(OrderStatusEnum.WAITING_RECEIVE)
                 .build();
         System.out.println("线程名称：" + Thread.currentThread().getName() + " 尝试支付，订单号：" + order.getOrderId());
        Message message = MessageBuilder.withPayload(OrderEvent.PAY_ORDER).setHeader("order", order).build();
        if (!sendEvent(message, order)) {
            System.out.println("线程名称：" + Thread.currentThread().getName() + " 支付失败, 状态异常，订单号：" + order.getOrderId());
        }
        System.out.println("线程名称：" + Thread.currentThread().getName() + " 支付成功，订单号：" + order.getOrderId());
        return order;
    }

判断逻辑很简单，

.start()启动状态机，

.restore()方法跟踪发现实际调用的是上面上下文bean中的read()方法，作用是恢复状态机的上下文，结果一番搜索后，博主终于明白这步的作用。首先我们要知道Spring StateMachine状态机是无状态的，每次启动都会是默认的状态，而他状态判断逻辑不会从所有规则中寻找符合的规则，而是基于状态机当前的状态与传入的事件进行判断状态流转是否正确，因此需要将当前状态与状态机中的状态进行同步

.sendEvent()方法是实际调用状态机内部的进行状态流转规则的判断，符合状态流转规则时对状态进行变换，同时符合规则转换成功时返回true，否则返回false

通过dubug追踪看到，状态变换成功，同时返回true

.persist()方法内部实际调用上下文中的write方法，可以在此进行实际的数据持久化

接着在finally中停止状态机

private synchronized boolean sendEvent(Message<OrderEvent> message, Order order) {
        boolean result = false;
        try {
            orderStateMachine.start();
            //尝试恢复状态机状态
            persister.restore(orderStateMachine, order);
            //添加延迟用于线程安全测试
            Thread.sleep(1000);
            result = orderStateMachine.sendEvent(message);
            //持久化状态机状态
            persister.persist(orderStateMachine, order);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            orderStateMachine.stop();
        }
        return result;
    }

至此，基本的状态机就顺利实现

到此这篇关于Spring StateMachine实现状态机使用示例详解的文章就介绍到这了,更多相关Spring StateMachine状态机内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

浅谈java接口的幂等性及解决方案
本文主要介绍了java接口的幂等性及解决方案，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2021-11-11
浅谈一下数据库连接池Druid德鲁伊
数据库连接池就是一个容器持有多个数据库连接，当程序需要操作数据库的时候直接从池中取出连接，使用完之后再还回去，和线程池一个道理,需要的朋友可以参考下
2023-05-05
Java实现顺序表的操作
这篇文章主要为大家详细介绍了Java实现顺序表的基本操作，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-01-01
实战指南：Java编写Flink SQL解决难题
想知道如何利用Java编写Flink SQL解决难题吗？本指南将为您揭示最实用的技巧和策略,让您轻松应对挑战,跟着我们一起探索,让Java和Flink SQL成为您问题解决的得力助手！
2023-12-12
基于java.lang.IllegalArgumentException异常报错问题及解决
这篇文章主要介绍了基于java.lang.IllegalArgumentException异常报错问题及解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-03-03
Java8深入学习之熟透Optional
这篇文章主要给大家介绍了关于Java8深入学习之熟透Optional的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用Java8具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
2019-09-09
详解maven的install的作用
这篇文章主要介绍了详解maven的install的作用,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-09-09
IDEA code template配置和参数方式
这篇文章主要介绍了IDEA code template配置和参数方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教<BR>
2024-01-01
使用BitSet位集合,一个重复校验工具
这篇文章主要介绍了使用BitSet位集合,一个重复校验工具，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-10-10
使用Mybatis-plus策略自动更新数据库时间失败问题解决
这篇文章主要介绍了使用Mybatis-plus策略自动更新数据库时间失败问题解决，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-10-10

Spring StateMachine实现状态机使用示例详解

目录

什么是状态机

使用示例

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具