【发布时间】:2020-06-03 07:19:59
【问题描述】:
尽管我使用了 Spring 状态机,但我还是遇到了问题。我已经声明了一个动作,我想从扩展状态中获取一个变量,但是我所有的变量都是空的。
这是我的配置,我用 Action startMeasureAction() 配置了第一个转换,我想获得一个发送到状态机的变量。
@Configuration
@EnableStateMachine
public class MeasureStateMachineConfig extends StateMachineConfigurerAdapter<State, MeasureEvents> {
private final Logger logger = LoggerFactory.getLogger(MeasureStateMachineConfig.class);
@Override
public void configure(StateMachineConfigurationConfigurer<State, MeasureEvents> config) throws Exception {
StateMachineListenerAdapter<State, MeasureEvents> adapter =
new StateMachineListenerAdapter<State, MeasureEvents>() {
@Override
public void stateChanged(org.springframework.statemachine.state.State<State, MeasureEvents> from,
org.springframework.statemachine.state.State<State, MeasureEvents> to) {
logger.info(format("stateChanged(from: %s, to %s)", from + "", to + ""));
}
};
config.withConfiguration().autoStartup(true).listener(adapter);
}
@Override
public void configure(StateMachineStateConfigurer<State, MeasureEvents> states) throws Exception {
states.withStates()
.initial(State.OPEN)
.states(EnumSet.allOf(State.class));
}
@Override
public void configure(StateMachineTransitionConfigurer<State, MeasureEvents> transition) throws Exception {
transition
.withInternal().source(State.OPEN).event(OPEN).action(startMeasureAction())
.and()
.withExternal().source(State.OPEN).source(INPROGRESS).event(START)
.and()
.withExternal().source(State.OPEN).target(REJECTED).event(REJECT)
.and()
.withExternal().source(REJECTED).target(State.OPEN).event(OPEN)
.and()
.withExternal().source(INPROGRESS).target(IMPLEMENTED).event(IMPLEMENT)
.and()
.withExternal().source(IMPLEMENTED).target(State.INEFFECTIVE).event(INEFFECTIVE)
.and()
.withExternal().source(State.IMPLEMENTED).target(FINISHED).event(FINISH)
.and()
.withExternal().source(State.INEFFECTIVE).target(State.OPEN).event(OPEN)
.and()
.withExternal().source(FINISHED).target(State.OPEN).event(OPEN);
}
@Bean
public Action<State, MeasureEvents> startMeasureAction() {
return new MeasureStartAction();
}
}
我的逻辑,我在其中发送带有数据的事件。这里我设置了一个 Header 并将数据和事件发送到状态机。但是在 Action (MeasureStartAction) 中调试时,没有可用的变量。
@Override
public void save(Measure entity) {
validator.validate(entity);
Message<MeasureEvents> startMeasureMessage =
MessageBuilder.withPayload(OPEN).setHeader("MEASURE_ID", 1L).build();
sm.sendEvent(startMeasureMessage);
}
这是我的Action,我想在那里获取变量。
public class MeasureStartAction implements Action<State, MeasureEvents> {
private static final Logger logger = LoggerFactory.getLogger(MeasureStartAction.class);
@Override
public void execute(StateContext<State, MeasureEvents> context) {
final long measure = context.getExtendedState().get("MEASURE_ID", Long.class);
logger.info("measureID" + measure);
}
}
Measure 总是为空,我做错了什么?
【问题讨论】:
标签: spring spring-statemachine