如何在单个Jenkinsfile中并行加载并运行多个Groovy文件

我看了你当前的Jenkinsfile，发现你想并行运行Jenkinsfiles目录下的几个Groovy脚本作为流水线阶段，但现在的写法有几个小问题需要调整。咱们一步步来修正：

修正后的完整Jenkinsfile代码 #

@Library(xxxxxxx) _ 
@Library(xxxxxxx) _ 
properties([ 
    parameters([ 
        choice(choices: ['failover', 'revert'], description: 'choose whether to failover or revert failover', name: 'ACTION'), 
        choice(choices: ['qa', 'prod'], description: 'choose the environment to failover or revert failover', name: 'ENVIRONMENT') 
    ]) 
]) 
timestamps { 
    node { 
        try { 
            parallel(
                // 并行分支1：Redis故障转移任务
                "Redis Failover": {
                    dir("Jenkinsfiles") {
                        stage('Initiate REDIS Failover') {
                            // 加载对应的Groovy脚本
                            def redisScript = load("redis.groovy")
                            // 调用脚本中的执行方法，传递流水线参数
                            redisScript.run(ENVIRONMENT, ACTION)
                        }
                    }
                },
                // 并行分支2：RDS故障转移任务
                "RDS Failover": {
                    dir("Jenkinsfiles") {
                        stage('Initiate RDS Failover') {
                            def rdsScript = load("Common.groovy")
                            rdsScript.run(ENVIRONMENT, ACTION)
                        }
                    }
                },
                // 并行分支3：WEB故障转移任务
                "WEB Failover": {
                    dir("Jenkinsfiles") {
                        stage('Initiate WEB Failover') {
                            def webScript = load("web.groovy")
                            webScript.run(ENVIRONMENT, ACTION)
                        }
                    }
                }
            )
        } finally { 
            cleanWs() 
        } 
    } 
}

关键修改点说明 #

1. 调整并行结构
   原代码把多个stage放在同一个dir下的parallel块里，这不是正确的并行写法。现在改成每个并行分支是独立的键值对，键是分支名称（方便在Jenkins界面识别任务），值是对应的执行闭包，这样三个任务会真正并行运行。

2. 加载脚本后必须执行逻辑
   原代码只做了load()脚本的操作，但没有调用脚本里的实际逻辑。现在加载脚本后调用了run()方法——你需要确保每个Groovy脚本里都定义了这个方法，比如web.groovy可以这么写：

   def run(String environment, String action) {
       echo "Executing WEB ${action} for ${environment} environment"
       // 这里写你的WEB故障转移/回滚逻辑，比如调用shell命令、kubectl操作等
   }
   return this
   

3. 修正脚本与阶段的对应关系
   原代码里存在阶段名称和加载脚本不匹配的问题（比如WEB阶段加载了rds.groovy），现在每个阶段都加载对应的脚本，逻辑更清晰不易出错。

4. 传递流水线参数
   把流水线的ENVIRONMENT和ACTION参数传递给每个脚本的方法，这样每个脚本可以根据参数执行不同的逻辑（比如区分故障转移还是回滚、不同环境的配置）。

额外注意事项 #

• 确保Jenkinsfiles目录存在于流水线的工作空间中（如果是从SCM拉取的代码，要确认这个目录被正确拉取）。
• 如果你的Groovy脚本不需要参数，可以去掉run()方法的参数，直接调用redisScript.run()即可。
• Jenkins会自动根据可用资源并行执行这些分支，你可以在流水线界面看到每个并行任务的执行状态。

内容的提问来源于stack exchange，提问作者Anushka Fernando