springboot状态机模式

链接: 状态机和工作流的区别.
链接: 状态机引擎选型.
链接: 彻底搞懂Spring状态机原理，实现订单与物流解耦.
链接: spring statemachine收录.
链接: spring statemachine的企业可用级开发指南.
链接: Spring Statemachine 简介.
链接: 实现一个状态机引擎，教你看清DSL的本质.
链接: COLA下的cola-statemachine状态机.
链接: 爱奇艺团队-领域驱动设计框架Axon实践.
链接: COLA 4.0：应用架构的最佳实践.
链接: 阿里高级技术专家谈开源DDD框架：COLA4.1，分离架构和组件（下）.
链接: 【架构设计】无状态状态机在代码中的实践.

状态机框架

• Spring Statemachine （重量级选手）1.2k+ star.
• squirrel-foundation（松鼠）1.8k+ star.
• cola-statemachine （可乐）6.6k+ star.

springboot合cola-statemachine 4.0.1

cola-statemachine（阿里出品）

github链接: cola-components.
gitcode链接: cola-components.

<dependency>
    <groupId>com.alibaba.cola</groupId>
    <artifactId>cola-component-statemachine</artifactId>
    <version>4.0.1</version>
    <type>jar</type>
</dependency>

package com.zm;

import com.alibaba.cola.statemachine.Action;
import com.alibaba.cola.statemachine.Condition;
import com.alibaba.cola.statemachine.StateMachine;
import com.alibaba.cola.statemachine.StateMachineFactory;
import com.alibaba.cola.statemachine.builder.StateMachineBuilder;
import com.alibaba.cola.statemachine.builder.StateMachineBuilderFactory;
import lombok.extern.slf4j.Slf4j;
import org.junit.jupiter.api.Test;


@Slf4j
public class StateMachineTest {

    static String MACHINE_ID = "TestStateMachine";

    static enum States {
        /**
         * 申请
         */
        APPLY,
        /**
         *初审
         */
        FIRST_TRIAL,
        /**
         *终审
         */
        FINAL_JUDGMENT,
        /**
         *移出
         */
        REMOVE
    }

    static enum Events {
        /**
         * 保存申请
         */
        SAVE_APPLICATION,
        /**
         * 提交申请
         */
        SUBMIT_APPLICATION,
        /**
         * 审核通过
         */
        AUDIT_PASS,
        /**
         * 审核退回
         */
        AUDIT_REJECT
    }

    /**
     * 参数
     */
    static class Context{
        String operator = "flw";
        String entityId = "7758258";
        String name = "zhoumin";
    }


    /**
     * State：状态
     * Event：事件，状态由事件触发，引起变化
     * Transition：流转，表示从一个状态到另一个状态
     * External Transition：外部流转，两个不同状态之间的流转
     * Internal Transition：内部流转，同一个状态之间的流转
     * Condition：条件，表示是否允许到达某个状态
     * Action：动作，到达某个状态之后，可以做什么
     * StateMachine：状态机
     * ————————————————
     * 版权声明：本文为CSDN博主「张建飞（Frank）」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
     * 原文链接：https://blog.csdn.net/significantfrank/article/details/104996419
     */
    @Test
    public void testExternalTransitionNormal(){
        // 第一步：生成一个状态机builder
        StateMachineBuilder<States, Events, Context> builder = StateMachineBuilderFactory.create();
        // 第二步：设置一个外部状态转移类型的builder，并设置from\to\on\when\perform
        builder.externalTransition()    // 外部状态流转
                .from(States.APPLY)     // 起始状态：申请
                .to(States.FIRST_TRIAL)        // 目的状态：初审
                .on(Events.SUBMIT_APPLICATION)       // 事件：提交申请
                .when(checkCondition()) // 流转需要校验的条件，校验不通过不会进行doAction
                .perform(doAction());   // 执行流转操作 这个action 我们可以按自己所需修改，比如这种Action<R,T> service的方法Service::method
        // 第三步：设置状态机的id和ready，并在StateMachineFactory中的stateMachineMap进行注册
        builder.build(MACHINE_ID);
        // 第四步：触发状态机
        StateMachine<States, Events, Context> stateMachine = StateMachineFactory.get(MACHINE_ID);
        stateMachine.showStateMachine();
        // 通过状态机执行 待审核状态执行审核操作，
        States target1 = stateMachine.fireEvent(States.APPLY, Events.SUBMIT_APPLICATION, new Context());

    }

    /**
     * 状态在申请时 可以进行保存
     */
    @Test
    public void testInternalNormal(){
        StateMachineBuilder<States, Events, Context> builder = StateMachineBuilderFactory.create();
        // 内部流转 internal transition
        // 假设现在只是用户补全资料，只需要进行一些更新数据操作，不需要状态流转。这种需求可以通过内部状态流转实现
        builder.internalTransition()
                .within(States.APPLY)
                .on(Events.SAVE_APPLICATION)
                .when(checkCondition())
                .perform(doAction());
        StateMachine<States, Events, Context> stateMachine = builder.build(MACHINE_ID);
        // 打印状态机里面的流程流转图谱
        stateMachine.showStateMachine();
        // 通过状态机执行 待审核状态执行审核操作，
        States target = stateMachine.fireEvent(States.APPLY, Events.SAVE_APPLICATION, new Context());

    }


    /**
     * 只要退回则回到申请箱的状态
     */
    @Test
    public void testExternalTransitionsNormal(){
        StateMachineBuilder<States, Events, Context> builder = StateMachineBuilderFactory.create();
        // external transitions 任意一个状态
        builder.externalTransitions()
                .fromAmong(States.FIRST_TRIAL, States.FINAL_JUDGMENT)
                .to(States.APPLY)
                .on(Events.AUDIT_REJECT)
                .when(checkCondition())
                .perform(doAction());
        StateMachine<States, Events, Context> stateMachine = builder.build(MACHINE_ID);
        // 打印状态机里面的流程流转图谱
        stateMachine.showStateMachine();
        // 通过状态机执行 待审核状态执行审核操作，
        States target1 = stateMachine.fireEvent(States.FIRST_TRIAL, Events.AUDIT_REJECT, new Context());
        States target2 = stateMachine.fireEvent(States.FINAL_JUDGMENT, Events.AUDIT_REJECT, new Context());
    }



    /**
     * 条件，表示是否允许到达某个状态
     */
    private Condition<StateMachineTest.Context> checkCondition() {
        return (ctx) -> true; // 默认返回true
    }

    /**
     * 动作，到达某个状态之后，可以做什么
     */
    private Action<StateMachineTest.States, StateMachineTest.Events, StateMachineTest.Context> doAction() {
        return (from, to, event, ctx)-> log.info(ctx.operator+" is operating "+ctx.entityId+" from:"+from+" to:"+to+" on:"+event+";"+ctx.name);
    }

}

springboot合Spring Statemachine 2.x

待续~