使用Java實(shí)現(xiàn)構(gòu)建jenkins的多個(gè)job并返回構(gòu)建結(jié)果示例

更新時(shí)間：2020年05月12日 11:32:39 作者：沉豆

這篇文章主要介紹了使用Java實(shí)現(xiàn)構(gòu)建jenkins的多個(gè)job并返回構(gòu)建結(jié)果示例，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧

背景：

使用java實(shí)現(xiàn)jenkins構(gòu)建很簡(jiǎn)單，但是如何確定什么時(shí)候job已經(jīng)構(gòu)建完成才是關(guān)鍵，而且要實(shí)現(xiàn)多個(gè)job并行構(gòu)建。

分析：

我有一篇文章提到過(guò)使用java實(shí)現(xiàn)jenkins構(gòu)建,但是獲取的結(jié)果是最后一次構(gòu)建的結(jié)果,不能實(shí)時(shí)獲取構(gòu)建結(jié)果.實(shí)時(shí)獲取構(gòu)建結(jié)果有個(gè)關(guān)鍵的點(diǎn),在于他會(huì)根據(jù)構(gòu)建的版本號(hào)獲取當(dāng)前版本號(hào)的結(jié)果,如果對(duì)應(yīng)版本號(hào)的結(jié)果為空則證明還在構(gòu)建過(guò)程中,按照這個(gè)思路我們就可以進(jìn)行編碼了.

1.判斷指定構(gòu)建版本號(hào)的job是否執(zhí)行完;

2.根據(jù)是否構(gòu)建完成獲取構(gòu)建結(jié)果;

/**
	 * 判斷指定的構(gòu)建版本號(hào)是否執(zhí)行完成
	 * 
	 * @param number
	 *      構(gòu)建版本號(hào)
	 * @param jobName
	 *      構(gòu)建名稱
	 * @return true為構(gòu)建完成，false為未構(gòu)建完成
	 */
	public static boolean isFinished(int number, String jobName) {
		boolean isBuilding = false;
		if (number <= 0) {
			throw new IllegalArgumentException("jenkins build number must greater than 0!");
		}
		try {
			JobWithDetails job = jobs.get(jobName).details();
			// build 如果為空則證明正在構(gòu)建，走else了
			Build buildByNumber = job.getBuildByNumber(number);
			if (null != buildByNumber) {
				BuildWithDetails details = buildByNumber.details();
				if (null != details) {
					isBuilding = details.isBuilding();
				} else {
					isBuilding = true;
				}
			} else {
				isBuilding = true;
			}
 
			return !isBuilding;
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
		}
		return false;
	}

  private static int nextNum = 0;
	private static JobWithDetails jobWithDetails = null;
	private static boolean flag = true;
	private static BuildResult buildResult = null;
  /**
	 * 根據(jù)項(xiàng)目名稱觸發(fā)jenkins構(gòu)建
	 * 
	 * @param paramJobName
	 *      項(xiàng)目名稱
	 * @return 構(gòu)建結(jié)果:如果為null則表明項(xiàng)目名稱在jenkins中沒(méi)有匹配的job
	 */
	public static BuildResult triggerJenkins(String paramJobName) {
		try {
			jobWithDetails = jobs.get(paramJobName).details();
			nextNum = jobWithDetails.getNextBuildNumber();
			jobWithDetails.build();
			System.out.println("正在構(gòu)建……");
			while (flag) {
				jobWithDetails = jobs.get(paramJobName).details();
				if (isFinished(nextNum, paramJobName)) {
					flag = false;
					System.out.println("構(gòu)建完成……");
				}
				Thread.sleep(2000);
			}
			buildResult = jobWithDetails.getLastBuild().details().getResult();
			return buildResult;
 
		} catch (IOException e) {
			e.printStackTrace();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
		return buildResult;

補(bǔ)充知識(shí)：Java 對(duì)接Jenkins API操作（不需要勾選允許站點(diǎn)跨域訪問(wèn)）

最先的是jenkins的跨域問(wèn)題如果是一般學(xué)習(xí)直接關(guān)閉在公司Java對(duì)接jenkins的話還是不關(guān)閉

需要的maven 依賴

<dependency>
 <groupId>com.offbytwo.jenkins</groupId>
 <artifactId>jenkins-client</artifactId>
 <version>0.3.8</version>
</dependency>

JenkinsUtil 不用勾選跨域也可以訪問(wèn)

public class JenkinsUtils {
 
  private static final Logger LOGGER = LoggerFactory.getLogger(JenkinsUtils.class);
 
  private static String job_class="hudson.model.FreeStyleProject";
  private static String folder_class= "com.cloudbees.hudson.plugins.folder.Folder";
  public static JenkinsServer getJenkinsServer(String userName, String password, String jenkinsUrl) {
    JenkinsHttpClient jenkinsHttpClient=null;
    JenkinsServer jenkinsServer=null;
    try{
      jenkinsHttpClient = new JenkinsHttpClient(new URI(jenkinsUrl), userName, password);
      jenkinsServer = new JenkinsServer(jenkinsHttpClient);
    }catch (URISyntaxException ex){
      LOGGER.info("JenkinsUtils :{}",ex.getMessage());
      throw new ResourceCenterException(ResponseCodeEnum.SYSTEM_ERROR_MESSAGE);
    }
    return jenkinsServer;
  }
 
  ;
 
  public static Integer buildWithParams(HashMap<String, String> params,String jobName, JenkinsServer jenkinsServer) {
  
    JobWithDetails job=null;
    int nextBuildNumber =0;
   try{
     job = jenkinsServer.getJob(jobName); /*根據(jù)名稱獲取job*/
     if(null==job){
       LOGGER.info("jenkins 不存在該Job ：{}",jobName);
       throw new ResourceCenterException(ResponseCodeEnum.JOB_NOT_EXIST);
     }
     /*獲取下一次構(gòu)建的構(gòu)建編號(hào)，可以用于在觸發(fā)構(gòu)建前，先記錄構(gòu)建編號(hào)。在后續(xù)獲取指定編號(hào)的構(gòu)建結(jié)果*/
     //這里需要 一個(gè)插件 Build With Parameters Plugin
     nextBuildNumber=job.getNextBuildNumber();
     job.build(params,true);
   }catch (IOException ex){
     LOGGER.info("JenkinsUtils :{}",ex.getMessage());
     throw new ResourceCenterException(ResponseCodeEnum.SYSTEM_ERROR_MESSAGE);
   }
    //獲取結(jié)果 如果為null表示正在構(gòu)建中 SUCCESS 表示構(gòu)建成功
    return nextBuildNumber;
  } 
  ;
 
  /**
   * 獲取job 某一個(gè)構(gòu)建的日志
   * @param number
   * @param jobName
   * @param jenkinsServer
   * @return
   * @throws Exception
   */
  public static String getBuildLogPrint(Integer number, String jobName, JenkinsServer jenkinsServer) {
 
    BuildWithDetails buildWithDetails=getBuildDetails(number,jobName,jenkinsServer);
    String log =null;
    try{
      log=buildWithDetails.getConsoleOutputText();
    }catch (IOException ex){
      LOGGER.info("JenkinsUtils :{}",ex.getMessage());
      throw new ResourceCenterException(ResponseCodeEnum.SYSTEM_ERROR_MESSAGE);
    }
    return log;
  }
 
  /**
   * 獲取job 某一個(gè)構(gòu)建的結(jié)果 ：成功，失敗，取消等狀態(tài)
   * @param number
   * @param jobName
   * @param jenkinsServer
   * @return
   * @throws Exception
   */
  public static String getBuildLogResult(Integer number, String jobName, JenkinsServer jenkinsServer) throws Exception {
 
    BuildWithDetails buildWithDetails=getBuildDetails(number,jobName,jenkinsServer);
    BuildResult result = buildWithDetails.getResult();
    return result.name();
 
  }
 
  private static BuildWithDetails getBuildDetails(Integer number, String jobName, JenkinsServer jenkinsServer){
    JobWithDetails job = null;
    Build build=null;
     BuildWithDetails buildWithDetails=null;
    try{
      job=jenkinsServer.getJob(jobName); /*根據(jù)jobName名稱獲取job*/
      build = job.getBuildByNumber(number);
      buildWithDetails = build.details();
     }catch (Exception e){
      LOGGER.info("JenkinsUtils :{}",e.getMessage());
      throw new ResourceCenterException(ResponseCodeEnum.SYSTEM_ERROR_MESSAGE);
    }
    return buildWithDetails;
  }
 
  //暫時(shí)解析一層文件夾
  public static String getJobFullName(JenkinsServer jenkinsServer,String jobName){
    String jobFullName="";
    try {
      Map<String, Job> jobs1 = jenkinsServer.getJobs();
      if(null!=jobs1.get(jobName)){
        return jobName;
      }
      Set<String> params = jobs1.keySet();
      for (String tempKey: params) {
        jobFullName=tempKey;
        JobWithDetails job = jenkinsServer.getJob(tempKey);
        if(!folder_class.equals(job.get_class())){
          continue;
        }
        Optional<FolderJob> folderJob = jenkinsServer.getFolderJob(job);
        FolderJob folderJob1 = folderJob.get();
        Map<String, Job> jobs = folderJob1.getJobs();
        Job targetJob = jobs.get(jobName);
        if(null!=targetJob){
          jobFullName=jobFullName+"/"+jobName;
          return jobFullName;
        }
      }
 
 
    }catch (IOException ex){
      LOGGER.info("JenkinsUtils :{}",ex.getMessage());
      throw new ResourceCenterException(ResponseCodeEnum.SYSTEM_ERROR_MESSAGE);
    }
    return jobFullName;
 
  }
}

為什么Java對(duì)接jenkins 不需要勾選跨域訪問(wèn)也可以：