LiteFlow轻量级工作流引擎使用示例详解

import com.yomahub.liteflow.annotation.LiteflowRule;
import com.yomahub.liteflow.core.NodeComponent;
@LiteflowRule
public class UserFlow {
    public static class CreateUserNode extends NodeComponent {
        @Override
        public void process() {
            System.out.println("Creating user...");
            // 这里执行数据库操作等逻辑
        }
    }
    public static class SendActivationEmailNode extends NodeComponent {
        @Override
        public void process() {
            System.out.println("Sending activation email...");
            // 这里执行发送邮件的操作
        }
    }
    public static class CompleteRegistrationNode extends NodeComponent {
        @Override
        public void process() {
            System.out.println("Completing registration...");
            // 这里执行激活链接的处理
        }
    }
}

<liteflow>
    <flow id="userRegistrationFlow">
        <node name="createUserNode" type="com.example.UserFlow$CreateUserNode"/>
        <node name="sendActivationEmailNode" type="com.example.UserFlow$SendActivationEmailNode"/>
        <node name="completeRegistrationNode" type="com.example.UserFlow$CompleteRegistrationNode"/>
        <edge from="createUserNode" to="sendActivationEmailNode"/>
        <edge from="sendActivationEmailNode" to="completeRegistrationNode"/>
    </flow>
</liteflow>

<dependency>
    <groupId>com.yomahub</groupId>
    <artifactId>liteflow-spring-boot-starter</artifactId>
    <version>2.4.0</version> <!-- 请检查最新版本 -->
</dependency>

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ApplicationContext;
import com.yomahub.liteflow.core.LiteflowExecutor;
@SpringBootApplication
public class LiteFlowApplication {
    public static void main(String[] args) {
        ApplicationContext context = SpringApplication.run(LiteFlowApplication.class, args);
        // 执行工作流
        LiteflowExecutor liteflowExecutor = context.getBean(LiteflowExecutor.class);
        liteflowExecutor.execute("userRegistrationFlow", null); // 执行指定的工作流
    }
}