摘要：雖然多個(gè)狀態(tài)機(jī)的問題解決了，但是對于實(shí)際的企業(yè)應(yīng)用而言，還是有問題。這個(gè)問題就用到了狀態(tài)機(jī)的持久化，我們下一章就談?wù)劤志没瘑栴}。

1、多個(gè)狀態(tài)機(jī)的搞法
在實(shí)際的企業(yè)應(yīng)用中，基本不可能只有一個(gè)狀態(tài)機(jī)流程在跑，比如訂單，肯定是很多個(gè)訂單在運(yùn)行，每個(gè)訂單都有自己的訂單狀態(tài)機(jī)流程，但上一章的例子，大家可以試一下，當(dāng)執(zhí)行到一個(gè)狀態(tài)時(shí)，再次刷新頁面，不會(huì)有任何日志出現(xiàn)，當(dāng)一個(gè)狀態(tài)流程執(zhí)行到某個(gè)狀態(tài)，再次執(zhí)行這個(gè)狀態(tài)，是不會(huì)有任何輸出的，因?yàn)闋顟B(tài)機(jī)的機(jī)制是只有在狀態(tài)切換的時(shí)候才會(huì)事件（event）觸發(fā)，所以我們這一章講多個(gè)狀態(tài)機(jī)的并行執(zhí)行。

首先，靠上一章例子里面的手打定制一個(gè)StateMachineConfig的做法，就只能是有一個(gè)狀態(tài)機(jī)流程制霸整個(gè)項(xiàng)目，這種霸道的做法肯定是不行啦，要想多個(gè)狀態(tài)機(jī)流程并行，那么就要請builder出場了，看代碼：

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);
     
     builder.configureStates()
                 .withStates()
                 .initial(OrderStates.UNPAID)
                 .states(EnumSet.allOf(OrderStates.class));
                 
     builder.configureTransitions()
                 .withExternal()
                    .source(OrderStates.UNPAID).target(OrderStates.WAITING_FOR_RECEIVE)
                    .event(OrderEvents.PAY).action(action())
                    .and()
                .withExternal()
                    .source(OrderStates.WAITING_FOR_RECEIVE).target(OrderStates.DONE)
                    .event(OrderEvents.RECEIVE);
                 
     return builder.build();
 }

有沒有似曾相識的感覺，里面描述訂單狀態(tài)機(jī)的初始狀態(tài)，狀態(tài)機(jī)的流程代碼和StateMachineConfig幾乎是一樣的，但是都配置在StateMachineBuilder里面

StateMachineBuilder.Builder builder = StateMachineBuilder.builder();
這是完整的builder類代碼：

import java.util.EnumSet;
import org.springframework.beans.factory.BeanFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.statemachine.StateContext;
import org.springframework.statemachine.StateMachine;
import org.springframework.statemachine.action.Action;
import org.springframework.statemachine.config.StateMachineBuilder;
import org.springframework.stereotype.Component;

@Component
public class OrderStateMachineBuilder {

    private final static String MACHINEID = "orderMachine";
    
     /**
      * 構(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(OrderStates.UNPAID)
                     .states(EnumSet.allOf(OrderStates.class));
                     
         builder.configureTransitions()
                     .withExternal()
                        .source(OrderStates.UNPAID).target(OrderStates.WAITING_FOR_RECEIVE)
                        .event(OrderEvents.PAY).action(action())
                        .and()
                    .withExternal()
                        .source(OrderStates.WAITING_FOR_RECEIVE).target(OrderStates.DONE)
                        .event(OrderEvents.RECEIVE);
                     
         return builder.build();
     }
    
    @Bean
    public Action action() {
        return new Action() {

            @Override
            public void execute(StateContext context) {
               System.out.println(context);
            }
        };
    }

    
}

在完整的代碼里面我們看到有個(gè)東西沒講，那就是MACHINEID，在builder的配置代碼里面，有這么一段

builder.configureConfiguration()

             .withConfiguration()
             .machineId(MACHINEID)
             .beanFactory(beanFactory);

machineId是狀態(tài)機(jī)的配置類和事件實(shí)現(xiàn)類的關(guān)聯(lián)，和它關(guān)聯(lián)的是OrderEventConfig，代碼如下：

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="orderMachine")
public class OrderEventConfig {
private Logger logger = LoggerFactory.getLogger(getClass());
    
    /**
     * 當(dāng)前狀態(tài)UNPAID
     */
    @OnTransition(target = "UNPAID")
    public void create() {
        logger.info("---訂單創(chuàng)建，待支付---");
    }
    
    ......

}

這個(gè)后面的內(nèi)容和上一章的OrderSingleEventConfig一模一樣，但在類的上面注解了這一句：

@WithStateMachine(id="orderMachine")
這個(gè)id對應(yīng)的就是OrderStateMachineBuilder 里面的MACHINEID，被builder寫到.machineId(MACHINEID)里面。這樣，OrderStateMachineBuilder對應(yīng)上一章的StateMachineConfig多個(gè)狀態(tài)機(jī)的實(shí)現(xiàn)版本，OrderEventConfig對應(yīng)上一章的OrderSingleEventConfig，基本一樣，只是和OrderStateMachineBuilder通過machineid做了關(guān)聯(lián)。

現(xiàn)在我們來看怎么用上它。在controller里面引用這個(gè)類：

@Autowired
    private OrderStateMachineBuilder orderStateMachineBuilder;

然后使用它

@RequestMapping("/testOrderState")
    public void testOrderState(String orderId) throws Exception {

        StateMachine stateMachine = orderStateMachineBuilder.build(beanFactory);

        // 創(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());
    }

這其實(shí)就是每次請求testOrderState就會(huì)生成一個(gè)新的statemachine，所以每次刷新testOrderState請求都會(huì)看到日志顯示：

構(gòu)建訂單狀態(tài)機(jī)
orderMachine
2019-05-03 19:24:23.734  INFO 11752 --- [nio-9991-exec-1] tConfig$$EnhancerBySpringCGLIB$$29e58541 : ---訂單創(chuàng)建，待支付---
2019-05-03 19:24:23.754  INFO 11752 --- [nio-9991-exec-1] o.s.s.support.LifecycleObjectSupport     : started org.springframework.statemachine.support.DefaultStateMachineExecutor@133d52dd
2019-05-03 19:24:23.755  INFO 11752 --- [nio-9991-exec-1] o.s.s.support.LifecycleObjectSupport     : started UNPAID DONE WAITING_FOR_RECEIVE  / UNPAID / uuid=52b44103-22af-49cc-a645-3aab29212a9e / id=orderMachine
DefaultStateContext [stage=TRANSITION, message=GenericMessage [payload=PAY, headers={id=ed826b85-e069-9a5e-34a1-d78454183143, timestamp=1556882663765}], messageHeaders={id=ade4055c-9b59-6498-501e-0e2a8cfe04b4, _sm_id_=52b44103-22af-49cc-a645-3aab29212a9e, timestamp=1556882663767}, extendedState=DefaultExtendedState [variables={}], transition=AbstractTransition [source=ObjectState [getIds()=[UNPAID], getClass()=class org.springframework.statemachine.state.ObjectState, hashCode()=1027927242, toString()=AbstractState [id=UNPAID, pseudoState=org.springframework.statemachine.state.DefaultPseudoState@4b05dcc, deferred=[], entryActions=[], exitActions=[], stateActions=[], regions=[], submachine=null]], target=ObjectState [getIds()=[WAITING_FOR_RECEIVE], getClass()=class org.springframework.statemachine.state.ObjectState, hashCode()=422378, toString()=AbstractState [id=WAITING_FOR_RECEIVE, pseudoState=null, deferred=[], entryActions=[], exitActions=[], stateActions=[], regions=[], submachine=null]], kind=EXTERNAL, guard=null], stateMachine=UNPAID DONE WAITING_FOR_RECEIVE  / UNPAID / uuid=52b44103-22af-49cc-a645-3aab29212a9e / id=orderMachine, source=null, target=null, sources=null, targets=null, exception=null]
傳遞的參數(shù)：null
2019-05-03 19:24:23.775  INFO 11752 --- [nio-9991-exec-1] tConfig$$EnhancerBySpringCGLIB$$29e58541 : ---用戶完成支付，待收貨---
傳遞的參數(shù)：null
傳遞的參數(shù)：null
2019-05-03 19:24:23.782  INFO 11752 --- [nio-9991-exec-1] tConfig$$EnhancerBySpringCGLIB$$29e58541 : ---用戶已收貨，訂單完成---
最終狀態(tài)：DONE

這和之前執(zhí)行testSingleOrderState是不一樣的，testSingleOrderState只有第一次會(huì)有日志打出，再執(zhí)行就沒有日志出來了，而testOrderState因?yàn)槊看味糱uild一個(gè)新的statemachine，所以每次都會(huì)顯示日志出來，這樣就能保證每個(gè)訂單都可以為它build一個(gè)新的statemachine，就解決了多個(gè)狀態(tài)機(jī)并行執(zhí)行的問題了。

雖然多個(gè)狀態(tài)機(jī)的問題解決了，但是對于實(shí)際的企業(yè)應(yīng)用而言，還是有問題。這種簡單粗暴的，來一個(gè)請求就新增一個(gè)狀態(tài)機(jī)的搞法很不經(jīng)濟(jì)，而且狀態(tài)機(jī)也不是越多越好，而應(yīng)該是和業(yè)務(wù)對象一一對應(yīng)才行，比如訂單，就是一個(gè)訂單一個(gè)狀態(tài)機(jī)，而不是每次訂單變化就build的一個(gè)。這個(gè)問題就用到了狀態(tài)機(jī)的持久化，我們下一章就談?wù)劤志没瘑栴}。

2、有個(gè)坑
EventConfig類的@WithStateMachine注解有兩個(gè)參數(shù)可用

public @interface WithStateMachine {

    /**
     * The name of a state machine bean which annotated bean should be associated.
     * Defaults to {@code stateMachine}
     *
     * @return the state machine bean name
     */
    String name() default StateMachineSystemConstants.DEFAULT_ID_STATEMACHINE;

    /**
     * The id of a state machine which annotated bean should be associated.
     *
     * @return the state machine id
     * @see StateMachine#getId()
     */
    String id() default "";
}

我們在上面是用id來關(guān)聯(lián)StateMachineBuilder和EventConfig的，用name是無效的，但這個(gè)id是spring-statemachine-starter，2.x版本才有，在1.x版本里面，只有name參數(shù)，用name參數(shù)StateMachineBuilder和EventConfig關(guān)聯(lián)不上，也就是在builder里面狀態(tài)變化，eventConfig里面并不會(huì)同步觸發(fā)事件，請大家確認(rèn)使用的是2.x的版本，這都是我血與淚的忠告。

碼云配套代碼地址