摘要：目前為止，多個(gè)狀態(tài)機(jī)和多種狀態(tài)機(jī)都可以在里面實(shí)現(xiàn)了，下一章我們來(lái)解決下狀態(tài)機(jī)和實(shí)際業(yè)務(wù)間的數(shù)據(jù)傳輸問題，畢竟我們不是為了讓狀態(tài)機(jī)自個(gè)獨(dú)自玩耍，和業(yè)務(wù)數(shù)據(jù)互通有無(wú)才是企業(yè)開發(fā)的正道。
在上一章的例子中，我們實(shí)現(xiàn)了多個(gè)狀態(tài)機(jī)并存執(zhí)行，不同的訂單有各自的狀態(tài)機(jī)運(yùn)行，但只有一種狀態(tài)機(jī)，這顯然不能滿足實(shí)際業(yè)務(wù)的要求，比如我就遇到了訂單流程和公文審批流程在同一個(gè)項(xiàng)目的情況，所以我們這一章講怎么讓多種狀態(tài)機(jī)共存。
我們先把上一章的例子狀態(tài)機(jī)再?gòu)?fù)習(xí)一下，這是個(gè)訂單狀態(tài)機(jī)，流程圖如下：
定義這個(gè)狀態(tài)機(jī)我們用到了OrderEvents，OrderStates來(lái)表達(dá)狀態(tài)（states）和事件（events），用OrderStateMachineBuilder來(lái)描述初始狀態(tài)和狀態(tài)變化流程，用OrderEventConfig來(lái)描述這個(gè)流程和狀態(tài)變化過程中需要做的業(yè)務(wù)。
現(xiàn)在我們?cè)倥粋€(gè)新的狀態(tài)機(jī)流程，表單狀態(tài)機(jī)，流程圖如下：
為此，我們同樣配套了和訂單狀態(tài)機(jī)一樣的表單四件套，events，states，StateMachineBuilder和eventConfig。
public enum FormStates {
BLANK_FORM, // 空白表單
FULL_FORM, // 填寫完表單
CONFIRM_FORM, // 校驗(yàn)表單
SUCCESS_FORM// 成功表單
}
public enum FormEvents {
WRITE, // 填寫
CONFIRM, // 校驗(yàn)
SUBMIT // 提交
}
import java.util.EnumSet;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.statemachine.StateMachine;
import org.springframework.statemachine.config.StateMachineBuilder;
import org.springframework.stereotype.Component;
/**
訂單狀態(tài)機(jī)構(gòu)建器
*/
@Component
public class FormStateMachineBuilder {
private final static String MACHINEID = "formMachine";
/**
* 構(gòu)建狀態(tài)機(jī)
*
* @param beanFactory
* @return
* @throws Exception
*/
public StateMachine build(BeanFactory beanFactory) throws Exception {
StateMachineBuilder.Builder builder = StateMachineBuilder.builder();
System.out.println("構(gòu)建表單狀態(tài)機(jī)");
builder.configureConfiguration()
.withConfiguration()
.machineId(MACHINEID)
.beanFactory(beanFactory);
builder.configureStates()
.withStates()
.initial(FormStates.BLANK_FORM)
.states(EnumSet.allOf(FormStates.class));
builder.configureTransitions()
.withExternal()
.source(FormStates.BLANK_FORM).target(FormStates.FULL_FORM)
.event(FormEvents.WRITE)
.and()
.withExternal()
.source(FormStates.FULL_FORM).target(FormStates.CONFIRM_FORM)
.event(FormEvents.CONFIRM)
.and()
.withExternal()
.source(FormStates.CONFIRM_FORM).target(FormStates.SUCCESS_FORM)
.event(FormEvents.SUBMIT);
return builder.build();
}
}
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.messaging.Message;
import org.springframework.statemachine.annotation.OnTransition;
import org.springframework.statemachine.annotation.WithStateMachine;
@WithStateMachine(id="formMachine")
public class FormEventConfig {
private Logger logger = LoggerFactory.getLogger(getClass());
/**
* 當(dāng)前狀態(tài)BLANK_FORM
*/
@OnTransition(target = "BLANK_FORM")
public void create() {
logger.info("---空白表單---");
}
/**
* BLANK_FORM->FULL_FORM 執(zhí)行的動(dòng)作
*/
@OnTransition(source = "BLANK_FORM", target = "FULL_FORM")
public void write(Message message) {
logger.info("---填寫完表單---");
}
/**
* FULL_FORM->CONFIRM_FORM 執(zhí)行的動(dòng)作
*/
@OnTransition(source = "FULL_FORM", target = "CONFIRM_FORM")
public void confirm(Message message) {
logger.info("---校驗(yàn)表單---");
}
/**
* CONFIRM_FORM->SUCCESS_FORM 執(zhí)行的動(dòng)作
*/
@OnTransition(source = "CONFIRM_FORM", target = "SUCCESS_FORM")
public void submit(Message message) {
logger.info("---表單提交成功---");
}
}
從代碼可以看到深深的套路感，里面除了對(duì)流程狀態(tài)的描述不同外，另外一個(gè)不同點(diǎn)就是MACHINEID，在不同的狀態(tài)機(jī)流程中，用MACHINEID來(lái)標(biāo)識(shí)不同就能使用多種狀態(tài)機(jī)了，對(duì)比一下就很清楚。在builder里面通過MACHINEID來(lái)區(qū)分
private final static String MACHINEID = "orderMachine";
public StateMachine build(BeanFactory beanFactory) throws Exception {
StateMachineBuilder.Builder builder = StateMachineBuilder.builder();
System.out.println("構(gòu)建訂單狀態(tài)機(jī)");
builder.configureConfiguration()
.withConfiguration()
.machineId(MACHINEID)
.beanFactory(beanFactory);
...
private final static String MACHINEID = "formMachine";
public StateMachine build(BeanFactory beanFactory) throws Exception {
StateMachineBuilder.Builder builder = StateMachineBuilder.builder();
System.out.println("構(gòu)建表單狀態(tài)機(jī)");
builder.configureConfiguration()
.withConfiguration()
.machineId(MACHINEID)
.beanFactory(beanFactory);
...
對(duì)應(yīng)的在eventconfig里面
@WithStateMachine(id="orderMachine")
public class OrderEventConfig {
...
@WithStateMachine(id="formMachine")
public class FormEventConfig {
通過@WithStateMachine注解的id參數(shù)就區(qū)分出來(lái)了不同的狀態(tài)機(jī)，這個(gè)id就是builder里面定義的MACHINEID。然后就是怎么引用的問題了，我們來(lái)看controller
@Autowired
private OrderStateMachineBuilder orderStateMachineBuilder;
@Autowired
private FormStateMachineBuilder formStateMachineBuilder;
這樣，不同的builder就能同時(shí)引用，兩種狀態(tài)機(jī)就互不干擾的各自運(yùn)行了，這是運(yùn)行的代碼：
@RequestMapping("/testOrderState")
public void testOrderState(String orderId) throws Exception {
StateMachine stateMachine = orderStateMachineBuilder.build(beanFactory);
System.out.println(stateMachine.getId());
// 創(chuàng)建流程
stateMachine.start();
// 觸發(fā)PAY事件
stateMachine.sendEvent(OrderEvents.PAY);
// 觸發(fā)RECEIVE事件
stateMachine.sendEvent(OrderEvents.RECEIVE);
// 獲取最終狀態(tài)
System.out.println("最終狀態(tài)：" + stateMachine.getState().getId());
}
@RequestMapping("/testFormState")
public void testFormState() throws Exception {
StateMachine stateMachine = formStateMachineBuilder.build(beanFactory);
System.out.println(stateMachine.getId());
// 創(chuàng)建流程
stateMachine.start();
stateMachine.sendEvent(FormEvents.WRITE);
stateMachine.sendEvent(FormEvents.CONFIRM);
stateMachine.sendEvent(FormEvents.SUBMIT);
// 獲取最終狀態(tài)
System.out.println("最終狀態(tài)：" + stateMachine.getState().getId());
}
分別執(zhí)行
http://localhost:9991/statemachine/testOrderState 使用StateMachineBuilder創(chuàng)建的多個(gè)狀態(tài)機(jī)演示
http://localhost:9991/statemachine/testFormState 多種狀態(tài)機(jī)的演示（上面都是order的狀態(tài)機(jī)，這個(gè)是form的狀態(tài)機(jī)）
在日志里面就能看到各自狀態(tài)機(jī)的運(yùn)行結(jié)果了。
目前為止，多個(gè)狀態(tài)機(jī)和多種狀態(tài)機(jī)都可以在spring statemachine里面實(shí)現(xiàn)了，下一章我們來(lái)解決下狀態(tài)機(jī)和實(shí)際業(yè)務(wù)間的數(shù)據(jù)傳輸問題，畢竟我們不是為了讓狀態(tài)機(jī)自個(gè)獨(dú)自玩耍，和業(yè)務(wù)數(shù)據(jù)互通有無(wú)才是企業(yè)開發(fā)的正道。
碼云配套代碼地址
文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/77800.html
