Spring StateMachine狀態(tài)機引擎在項目中的應用(八)-靈活指定引擎實例狀態(tài)

一直以來靠瞎,總覺得ssm不夠靈活,主要原因是沒找到為狀態(tài)機指定狀態(tài)的方式,也就意味著狀態(tài)機引擎實例必須要跟對應的業(yè)務數(shù)據(jù)一起持久化志笼,雖然ssm提供了多重持久化的方式,依然覺得有點不爽把篓。
最近又回過頭去啃了下文檔和源碼纫溃,無意中在AbstractStateMachine類中看到了setCurrentState方法,如下:

void setCurrentState(State<S, E> state, Message<E> message, Transition<S, E> transition, boolean exit, StateMachine<S, E> stateMachine) {
    this.setCurrentState(state, message, transition, exit, stateMachine, (Collection)null, (Collection)null);
}

void setCurrentState(State<S, E> state, Message<E> message, Transition<S, E> transition, boolean exit, StateMachine<S, E> stateMachine, Collection<State<S, E>> sources, Collection<State<S, E>> targets) {
    this.setCurrentStateInternal(state, message, transition, exit, stateMachine, sources, targets);
}

private void setCurrentStateInternal(State<S, E> state, Message<E> message, Transition<S, E> transition, boolean exit, StateMachine<S, E> stateMachine, Collection<State<S, E>> sources, Collection<State<S, E>> targets) {
  ...
}

emmm韧掩,貌似有門兒紊浩,于是做了以下嘗試。

搭個項目框架

為了簡單疗锐,用springboot基于maven搭了個簡單的項目(http://start.spring.io)

pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.8.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>com.example</groupId>
    <artifactId>demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>demo</name>
    <description>Demo project for Spring Boot</description>

    <properties>
        <java.version>1.8</java.version>
        <spring-statemachine.version>2.1.3.RELEASE</spring-statemachine.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.statemachine</groupId>
            <artifactId>spring-statemachine-core</artifactId>
            <version>${spring-statemachine.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.8</version>
        </dependency>

    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

可以看到坊谁,只需要引入spring-statemachine-core就可以了,當然夾帶點私貨滑臊,順手扔上去了lombok口芍。

States & Events
package com.example.demo;

public enum States {
    SI, S1, S2, S3;
}
package com.example.demo;

public enum Events {
    E1, E2, E3;
}
spring statemachine config

定義了一些configure & listener

package com.example.demo;

import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.Message;
import org.springframework.statemachine.config.EnableStateMachine;
import org.springframework.statemachine.config.EnumStateMachineConfigurerAdapter;
import org.springframework.statemachine.config.builders.StateMachineConfigurationConfigurer;
import org.springframework.statemachine.config.builders.StateMachineStateConfigurer;
import org.springframework.statemachine.config.builders.StateMachineTransitionConfigurer;
import org.springframework.statemachine.listener.StateMachineListener;
import org.springframework.statemachine.listener.StateMachineListenerAdapter;
import org.springframework.statemachine.state.State;
import org.springframework.statemachine.transition.Transition;

import java.util.EnumSet;
import java.util.Optional;

@Configuration
@EnableStateMachine
public class StateMachineConfig
        extends EnumStateMachineConfigurerAdapter<States, Events> {

    @Override
    public void configure(StateMachineConfigurationConfigurer<States, Events> config)
            throws Exception {
        config
                .withConfiguration()
                .autoStartup(true)
                .listener(listener());
    }

    @Override
    public void configure(StateMachineStateConfigurer<States, Events> states)
            throws Exception {
        states
                .withStates()
                .initial(States.SI)
                .states(EnumSet.allOf(States.class));
    }

    @Override
    public void configure(StateMachineTransitionConfigurer<States, Events> transitions)
            throws Exception {
        transitions
                .withExternal()
                .source(States.SI).target(States.S1).event(Events.E1)
                .and()
                .withExternal()
                .source(States.S1).target(States.S2).event(Events.E2)
                .and()
                .withExternal()
                .source(States.S2).target(States.S3).event(Events.E3);
    }


    private StateMachineListener<States, Events> listener() {
        return new StateMachineListenerAdapter<States, Events>() {
            @Override
            public void transition(Transition<States, Events> transition) {
                System.out.println("move from:{" + ofNullableState(transition.getSource()) + "} " +
                        "to:{" + ofNullableState(transition.getTarget()) + "}");
            }

            @Override
            public void stateChanged(State<States, Events> from, State<States, Events> to) {

                if (null != from) {
                    System.out.println("State change from " + from.getId() + " to " + to.getId());
                } else {
                    System.out.println("State change to " + to.getId());
                }

            }

            @Override
            public void eventNotAccepted(Message<Events> event) {
                System.err.println("event not accepted: {" + event + "}");
            }

            private Object ofNullableState(State s) {
                return Optional.ofNullable(s)
                        .map(State::getId)
                        .orElse(null);
            }
        };
    }

/*    @Bean
    public StateMachineListener<States, Events> listener() {
        return new StateMachineListenerAdapter<States, Events>() {
            @Override
            public void stateChanged(State<States, Events> from, State<States, Events> to) {
                System.out.println("State change to " + to.getId());
            }
        };
    }*/

}
Stringboot Application
package com.example.demo;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.statemachine.StateMachine;

@SpringBootApplication
public class DemoApplication implements CommandLineRunner {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }

    @Autowired
    private StateMachine<States, Events> stateMachine;

    @Override
    public void run(String... args) throws Exception {

        stateMachine.sendEvent(Events.E1);
        stateMachine.sendEvent(Events.E2);
    }


}
執(zhí)行結(jié)果

mvn clean install

Java -jar *.jar

move from:{null} to:{SI}
State change to SI
2019-09-17 23:10:14.374  INFO 71833 --- [           main] o.s.s.support.LifecycleObjectSupport     : started S3 SI S2 S1  / SI / uuid=eb612bb8-d97f-4505-b8af-4106320b3073 / id=null
move from:{SI} to:{S1}
State change from SI to S1
move from:{S1} to:{S2}
State change from S1 to S2

可以看到,可以通過sendEvent來觸發(fā)狀態(tài)機引擎的狀態(tài)流轉(zhuǎn)

setCurrentState

上面只是一個常規(guī)的demo雇卷,那么怎么直接設(shè)置當前狀態(tài)呢鬓椭?

還是回到上面的AbstractStateMachine類中setCurrentState方法定義:

void setCurrentState(State<S, E> state, Message<E> message, Transition<S, E> transition, boolean exit, StateMachine<S, E> stateMachine) 
State<S, E> state:需要設(shè)置的狀態(tài)

Message<E> message:需要攜帶的message,這里先不用

Transition<S, E> transition:對應節(jié)點关划,可以先不用小染,畢竟還需要構(gòu)造

boolean exit:?是否可以exit祭玉,默認走false

StateMachine<S, E> stateMachine:具體的狀態(tài)機引擎實例

應該是需要提供寫一個工具類氧映,屏蔽掉上游調(diào)用的復雜度。而SpringStateMachine中本身就提供了一個工具類StateMachineUtils脱货,直接基于它擴展吧岛都,畢竟很多上下文的東西構(gòu)造起來還是挺麻煩律姨。

StateMachineUtils工具類
package org.springframework.statemachine.support;

import org.springframework.statemachine.StateMachine;
import org.springframework.statemachine.state.State;

public abstract class MyStateMachineUtils extends StateMachineUtils {

    public static <S, E> void setCurrentState(StateMachine<S, E> stateMachine, S state) {
        if (stateMachine instanceof AbstractStateMachine) {
            setCurrentState((AbstractStateMachine<S, E>) stateMachine, state);

            System.out.println("StateMachine Current:" + stateMachine);
        } else {
            throw new IllegalArgumentException("Provided StateMachine is not a valid type");
        }
    }

    public static <S, E> void setCurrentState(AbstractStateMachine<S, E> stateMachine, S state) {
        stateMachine.setCurrentState(findState(stateMachine, state), null, null, false, stateMachine);
    }

    private static <S, E> State<S, E> findState(AbstractStateMachine<S, E> stateMachine, S stateId) {
        for (State<S, E> state : stateMachine.getStates()) {
            if (state.getId() == stateId) {
                return state;
            }
        }

        throw new IllegalArgumentException("Specified State ID is not valid");
    }
}

注意:

1、這里的包名是org.springframework.statemachine.support臼疫,因為setCurrentState是default的scope择份,不放在同一個包里無法直接操作

2、這里findState是從stateMachine實例中獲取目標state

修改DemoApplication
        @Override
    public void run(String... args) throws Exception {

        //        stateMachine.sendEvent(Events.E1);

        MyStateMachineUtils.setCurrentState(stateMachine,States.S1);

        stateMachine.sendEvent(Events.E2);

    }

執(zhí)行下看結(jié)果:

move from:{null} to:{SI}
State change to SI
2019-09-17 23:21:14.788  INFO 72337 --- [           main] o.s.s.support.LifecycleObjectSupport     : started S1 S3 SI S2  / SI / uuid=801118a8-0115-48e1-95e7-a8ba67e5d30f / id=null
State change from SI to S1
StateMachine Current:S1 S3 SI S2  / S1 / uuid=801118a8-0115-48e1-95e7-a8ba67e5d30f / id=null
move from:{S1} to:{S2}
State change from S1 to S2

可以看到烫堤,直接把stateMachine的狀態(tài)從SI遷移到了S1荣赶,done!

注意:這里如果spring-statemachine.version=2.1.3.RELEASE是正常的鸽斟,但是如果是使用3.0.0.M1版本拔创,則狀態(tài)一直未生效,應該是新版本還有缺陷富蓄。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末剩燥,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子立倍,更是在濱河造成了極大的恐慌灭红,老刑警劉巖,帶你破解...
    沈念sama閱讀 218,941評論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件口注,死亡現(xiàn)場離奇詭異变擒,居然都是意外死亡,警方通過查閱死者的電腦和手機寝志,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,397評論 3 395
  • 文/潘曉璐 我一進店門娇斑,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人澈段,你說我怎么就攤上這事悠菜〗⒃埽” “怎么了败富?”我有些...
    開封第一講書人閱讀 165,345評論 0 356
  • 文/不壞的土叔 我叫張陵,是天一觀的道長摩窃。 經(jīng)常有香客問我兽叮,道長,這世上最難降的妖魔是什么猾愿? 我笑而不...
    開封第一講書人閱讀 58,851評論 1 295
  • 正文 為了忘掉前任鹦聪,我火速辦了婚禮,結(jié)果婚禮上蒂秘,老公的妹妹穿的比我還像新娘泽本。我一直安慰自己,他們只是感情好姻僧,可當我...
    茶點故事閱讀 67,868評論 6 392
  • 文/花漫 我一把揭開白布规丽。 她就那樣靜靜地躺著蒲牧,像睡著了一般。 火紅的嫁衣襯著肌膚如雪赌莺。 梳的紋絲不亂的頭發(fā)上冰抢,一...
    開封第一講書人閱讀 51,688評論 1 305
  • 那天,我揣著相機與錄音艘狭,去河邊找鬼挎扰。 笑死,一個胖子當著我的面吹牛巢音,可吹牛的內(nèi)容都是我干的遵倦。 我是一名探鬼主播,決...
    沈念sama閱讀 40,414評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼官撼,長吁一口氣:“原來是場噩夢啊……” “哼骇吭!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起歧寺,我...
    開封第一講書人閱讀 39,319評論 0 276
  • 序言:老撾萬榮一對情侶失蹤燥狰,失蹤者是張志新(化名)和其女友劉穎,沒想到半個月后斜筐,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體龙致,經(jīng)...
    沈念sama閱讀 45,775評論 1 315
  • 正文 獨居荒郊野嶺守林人離奇死亡,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,945評論 3 336
  • 正文 我和宋清朗相戀三年顷链,在試婚紗的時候發(fā)現(xiàn)自己被綠了目代。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 40,096評論 1 350
  • 序言:一個原本活蹦亂跳的男人離奇死亡嗤练,死狀恐怖榛了,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情煞抬,我是刑警寧澤霜大,帶...
    沈念sama閱讀 35,789評論 5 346
  • 正文 年R本政府宣布,位于F島的核電站革答,受9級特大地震影響战坤,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜残拐,卻給世界環(huán)境...
    茶點故事閱讀 41,437評論 3 331
  • 文/蒙蒙 一途茫、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧溪食,春花似錦囊卜、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,993評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽袱衷。三九已至,卻和暖如春笑窜,著一層夾襖步出監(jiān)牢的瞬間致燥,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,107評論 1 271
  • 我被黑心中介騙來泰國打工排截, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留嫌蚤,地道東北人。 一個月前我還...
    沈念sama閱讀 48,308評論 3 372
  • 正文 我出身青樓断傲,卻偏偏與公主長得像脱吱,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子认罩,可洞房花燭夜當晚...
    茶點故事閱讀 45,037評論 2 355

推薦閱讀更多精彩內(nèi)容