Why Process Orchestration Is Essential for Scalable Backend Systems

Problem: tangled conditional logic

When many business lines share a single service, developers add if‑else branches for each line. Example code shows nested checks for BizA and BizB. With ten+ lines the code becomes a “shit mountain”, making regression bugs and exhaustive testing impossible.

Requirements

Isolate business‑specific logic.

Allow new business lines without touching existing code.

Solution architecture

Two mechanisms are combined:

Workflow engine that lets each business configure its own execution chain.

Plugin‑extension engine that hosts business‑specific implementations in separate modules.

Demo: MemberClub

The demo project defines three distinct flow‑chain configurations for different member‑product purchase processes. Operators bind a chain to a product through a UI.

Defining flow nodes

Each node implements four lifecycle methods: process – main business logic. success – called after all process calls succeed. rollback – called in reverse order when an exception occurs. callback – always executed last, regardless of success or failure.

Execution algorithm

At runtime the caller creates a context object and invokes FlowChain.execute(chain, context). The engine links nodes sequentially, similar to the Chain‑of‑Responsibility pattern, and follows this order:

Iterate over nodes, invoke process. Stop on the first exception.

If an exception was thrown, walk the already‑executed nodes backward and invoke rollback on each.

If no exception, walk backward and invoke success on each node.

Finally, walk backward again and invoke callback on every node.

Core implementation

public <T> void execute(FlowChain<T> chain, T context) {
    Exception exception = null;
    int index = -1;
    for (FlowNode<T> node : chain.getNodes()) {
        try {
            node.process(context);
            index++;
        } catch (Exception e) {
            if (e instanceof SkipException) {
                CommonLog.warn("当前流程:{} 发出 Skip请求,后续流程不再执行", node.getClass().getSimpleName());
                break;
            }
            exception = e;
            break;
        }
    }
    if (exception != null) {
        for (int i = index; i >= 0; i--) {
            FlowNode<T> node = chain.getNodes().get(i);
            try {
                node.rollback(context, exception);
            } catch (Exception e) {
                CommonLog.error("rollback执行异常,忽略 name:{}", node.getClass().getSimpleName(), e);
            }
        }
    } else {
        for (int i = index; i >= 0; i--) {
            FlowNode<T> node = chain.getNodes().get(i);
            try {
                node.success(context);
            } catch (Exception e) {
                CommonLog.error("success 执行异常,忽略 name:{}", node.getClass().getSimpleName(), e);
            }
        }
    }
    for (int i = index; i >= 0; i--) {
        FlowNode<T> node = chain.getNodes().get(i);
        try {
            node.callback(context, exception);
        } catch (Exception e) {
            CommonLog.error("callback执行异常,忽略 name:{}", node.getClass().getSimpleName(), e);
        }
    }
    if (exception != null) {
        throw exception;
    }
}

Repository

Full demo source: https://gitee.com/juejinwuyang/memberclub