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状态机内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

SpringBoot集成FTP与SFTP连接池流程
在项目开发中，一般文件存储很少再使用SFTP服务，但是也不排除合作伙伴使用SFTP来存储项目中的文件或者通过SFTP来实现文件数据的交互，这篇文章主要介绍了SpringBoot集成FTP与SFTP连接池
2022-12-12
SpringBoot读取外部配置文件的方法
这篇文章主要介绍了SpringBoot读取外部配置文件的方法,以端口配置为例，本文通过示例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-02-02
MybatisPlus3.3.0没有MybatisPlusInterceptor类问题的解决方法
项目使用的是mybatis-plus-extension3.3.0依赖,然后在我使用分页插件的时候,发现无法导入MybatisPlusInterceptor类所以本文给大家介绍了MybatisPlus3.3.0没有MybatisPlusInterceptor类问题的解决方法,需要的朋友可以参考下
2023-12-12
Spring循环依赖的解决方案详解
这篇文章将用实例为大家详细介绍了介绍如何解决Spring的循环依赖问题，文中的示例代码讲解详细，对我们学习Spring有一定的帮助，需要的可以参考一下
2022-07-07
SpringBoot Actuator埋点和监控及简单使用
最近做的项目涉及到埋点监控、报表、日志分析的相关知识，于是捣鼓的一番，下面把涉及的知识点及SpringBoot Actuator埋点和监控的简单用法，给大家分享下，感兴趣的朋友一起看看吧
2021-11-11
SpringBoot、mybatis返回树结构的数据实现
本文主要介绍了SpringBoot、mybatis返回树结构的数据实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-04-04
Java定时调用.ktr文件的示例代码(解决方案)
这篇文章主要介绍了Java定时调用.ktr文件的示例代码,本文给大家分享遇到问题及解决方法，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2021-04-04
教你用Java GUI实现文本文件的读写
今天带大家来学习怎么用JavaSwing实现实现文本文件读写,文中有非常详细的代码示例,对正在学习java的小伙伴们有很好的帮助,需要的朋友可以参考下
2021-05-05
Mybatis中实体类属性与数据列表间映射方法介绍
这篇文章主要介绍了Mybatis中实体类属性与数据列表间映射方法介绍，一共四中方法，供大家参考。
2017-10-10
Java中对List去重 Stream去重的解决方法
这篇文章主要介绍了Java中对List去重, Stream去重的问题解答，文中给大家介绍了Java中List集合去除重复数据的方法，需要的朋友可以参考下
2018-04-04

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

目录

什么是状态机

使用示例

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具