Springboot使用mechineState状态机

news/2025/1/11 19:50:52/

Springboot+mechineState状态机

1、引入依赖
<dependency><groupId>org.springframework.statemachine</groupId><artifactId>spring-statemachine-core</artifactId><version>2.0.1.RELEASE</version>
</dependency>
2、订单的状态机配置类
/*** 订单状态机配置*/
@Configuration
@EnableStateMachine(name = "orderStateMachine")
public class OrderStateMachineConfig extends StateMachineConfigurerAdapter<OrderStatus, OrderStatusChangeEvent> {@Overridepublic void configure(StateMachineStateConfigurer<OrderStatus, OrderStatusChangeEvent> states) throws Exception {states.withStates().initial(OrderStatus.WAIT_PAYMENT).states(EnumSet.allOf(OrderStatus.class));}/*** 配置状态转换事件关系*/@Overridepublic void configure(StateMachineTransitionConfigurer<OrderStatus, OrderStatusChangeEvent> transitions) throws Exception {transitions.withExternal().source(OrderStatus.WAIT_PAYMENT).target(OrderStatus.WAIT_DELIVER).event(OrderStatusChangeEvent.PAYED).and().withExternal().source(OrderStatus.WAIT_DELIVER).target(OrderStatus.WAIT_RECEIVE).event(OrderStatusChangeEvent.DELIVERY).and().withExternal().source(OrderStatus.WAIT_RECEIVE).target(OrderStatus.FINISH).event(OrderStatusChangeEvent.RECEIVED);}/*** 持久化配置* 实际使用中,可以配合redis等,进行持久化操作*/@Beanpublic StateMachinePersister<OrderStatus, OrderStatusChangeEvent, Order> persister(){return new DefaultStateMachinePersister<>(new StateMachinePersist<OrderStatus, OrderStatusChangeEvent, Order>() {@Overridepublic void write(StateMachineContext<OrderStatus, OrderStatusChangeEvent> context, Order order) throws Exception {//此处并没有进行持久化操作}@Overridepublic StateMachineContext<OrderStatus, OrderStatusChangeEvent> read(Order order) throws Exception {//此处直接获取order中的状态,其实并没有进行持久化读取操作return new DefaultStateMachineContext<>(order.getStatus(), null, null, null);}});}
}/*** 订单状态*/
public  enum OrderStatus {WAIT_PAYMENT, WAIT_DELIVER, WAIT_RECEIVE, FINISH;
}
/*** 订单状态改变事件*/
public  enum OrderStatusChangeEvent {PAYED, DELIVERY, RECEIVED;
}
3、添加状态变换监听
@Component("orderStateListener")
@WithStateMachine(name = "orderStateMachine")
public class OrderStateListenerImpl{@OnTransition(source = "WAIT_PAYMENT", target = "WAIT_DELIVER")public boolean payTransition(Message<OrderStatusChangeEvent> message) {Order order = (Order) message.getHeaders().get("order");order.setStatus(OrderStatus.WAIT_DELIVER);System.out.println("支付 headers=" + message.getHeaders().toString());return true;}@OnTransition(source = "WAIT_DELIVER", target = "WAIT_RECEIVE")public boolean deliverTransition(Message<OrderStatusChangeEvent> message) {Order order = (Order) message.getHeaders().get("order");order.setStatus(OrderStatus.WAIT_RECEIVE);System.out.println("发货 headers=" + message.getHeaders().toString());return true;}@OnTransition(source = "WAIT_RECEIVE", target = "FINISH")public boolean receiveTransition(Message<OrderStatusChangeEvent> message){Order order = (Order) message.getHeaders().get("order");order.setStatus(OrderStatus.FINISH);System.out.println("收货 headers=" + message.getHeaders().toString());return true;}
}
5、放到业务类中调用
@Service("orderService")
public class OrderServiceImpl implements OrderService {@Autowiredprivate OrderMapper orderMapper;@Autowiredprivate StateMachine<OrderStatus, OrderStatusChangeEvent> orderStateMachine;@Autowiredprivate StateMachinePersister<OrderStatus, OrderStatusChangeEvent, Order> persister;private int id = 1;private Map<Integer, Order> orders = new HashMap<>();@Overridepublic Order creat() {Order order = new Order();order.setStatus(OrderStatus.WAIT_PAYMENT);order.setId(id++);orders.put(order.getId(), order);return order;}@Overridepublic Order pay(int id) {Order order = orders.get(id);System.out.println("threadName=" + Thread.currentThread().getName() + " 尝试支付 id=" + id);Message message = MessageBuilder.withPayload(OrderStatusChangeEvent.PAYED).setHeader("order", order).build();if (!sendEvent(message, order)) {System.out.println("threadName=" + Thread.currentThread().getName() + " 支付失败, 状态异常 id=" + id);}return orders.get(id);}@Overridepublic Order deliver(int id) {Order order = orders.get(id);System.out.println("threadName=" + Thread.currentThread().getName() + " 尝试发货 id=" + id);if (!sendEvent(MessageBuilder.withPayload(OrderStatusChangeEvent.DELIVERY).setHeader("order", order).build(), orders.get(id))) {System.out.println("threadName=" + Thread.currentThread().getName() + " 发货失败,状态异常 id=" + id);}return orders.get(id);}@Overridepublic Order receive(int id) {Order order = orders.get(id);System.out.println("threadName=" + Thread.currentThread().getName() + " 尝试收货 id=" + id);if (!sendEvent(MessageBuilder.withPayload(OrderStatusChangeEvent.RECEIVED).setHeader("order", order).build(), orders.get(id))) {System.out.println("threadName=" + Thread.currentThread().getName() + " 收货失败,状态异常 id=" + id);}return orders.get(id);}@Overridepublic Map<Integer, Order> getOrders() {return orders;}/*** 发送订单状态转换事件*/private synchronized boolean sendEvent(Message<OrderStatusChangeEvent> 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;}
}

参考:https://docs.spring.io/spring-statemachine/docs/1.0.0.M3/reference/htmlsingle/#sm-statecontext

https://blog.csdn.net/u012129558/article/details/90519577


http://www.ppmy.cn/news/1062958.html

相关文章

【网络云盘客户端】——项目简介

项目简介 网络云盘客户端时基于QT/C框架实现了一个网络云盘客户端软件&#xff0c;主要功能包括用户的注册&#xff0c;登录&#xff0c;显示用户的个人文件列表&#xff0c;以及文件的上传&#xff0c;下载&#xff0c;删除&#xff0c;共享文件。 登录界面 主窗口界面 文件…

关于feign传参以及方法名称的理解

Springcloud中Feign传递参数&#xff08;总结&#xff09;_feign传递多个参数_^布丁的博客-CSDN博客 上面是参数问题 还有一件事就是我们方法名称是可以自己定义的&#xff0c;不用非得和我们微服务调用端一样。 FeignClient(value "userservice") public interfa…

SpringBoot简单上手

spring boot 是spring快速开发脚手架&#xff0c;通过约定大于配置&#xff0c;优化了混乱的依赖管理&#xff0c;和复杂的配置&#xff0c;让我们用java-jar方式,运行启动java web项目 入门案例 创建工程 先创建一个空的工程 创建一个名为demo_project的项目&#xff0c;并且…

DB2的系统数据表空间,用户数据表空间,系统临时表空间,用户临时表空间详解

可以参考DB2 information center的官方文档&#xff1a;https://www.ibm.com/docs/zh/db2/10.5?topicspaces-table-system-user-temporary-data 每个数据库都必须要有最小的一组表空间&#xff0c;这些表空间用于存储系统数据、用户数据和临时数据。 一个数据库至少必须包含三…

C++友元的三种实现

生活中你的家有客厅(Public)&#xff0c;有你的卧室(Private) 客厅所有来的客人都可以进去&#xff0c;但是你的卧室是私有的&#xff0c;也就是说只有你能进去 但是呢&#xff0c;你也可以允许你的好闺蜜好基友进去。 在程序里&#xff0c;有些私有属性 也想让类外特殊的一…

什么是缓存雪崩,什么是缓存穿透,什么是缓存击穿,如何解决 ?

目录 1. 什么是缓存雪崩&#xff1f;如何解决 &#xff1f; 2. 什么是缓存穿透&#xff1f;如何解决 &#xff1f; 3. 什么是缓存击穿&#xff1f;如何解决 &#xff1f; 1. 什么是缓存雪崩&#xff1f;如何解决 &#xff1f; 缓存雪崩是指在短时间内&#xff0c;有大量的缓存…

关于Java中@Transient主键的作用的一些介绍

Transient主下面是关于Transient主键的使用方法、代码案例以及与transient关键字的区别&#xff0c;以及一些实用场景的详细介绍。 1. Transient主键的作用 在实体类中&#xff0c;通常需要将某些字段标记为主键&#xff0c;并将其映射到数据库中的主键字段。但是&#xff0c…

2023年 Java 面试八股文下(20w字)

目录 1.1 面试过程最关键的是什么&#xff1f; 1.2 面试时该怎么说&#xff1f; 1.3 面试技巧 1.3.1 六个常见问题 1.3.2 两个注意事项 1.3.3 自我介绍&#xff08;控制在4分半以内&#xff0c;不超过5分钟&#xff09; 手写代码 2.1 冒泡排序&#xff08;Bubble Sort&…