golang 操作Jenkins

1.創建Agent/Node

func CreateAgent(username string, password string, nodeName string, nodeDescription string, numExecutors string, remoteFS string, labelString string, host string) {var obj stringobj = "{'name':+'" + nodeName + "',+'nodeDescription':+'" + nodeDescription + "',+'numExecutors':+'" + numExecutors + "',+'remoteFS':+'" + remoteFS + "',+'labelString':+'" + labelString + "',+'mode':+'NORMAL',+'':+['hudson.plugins.sshslaves.SSHLauncher',+'0'],+'launcher':+{'stapler-class':+'hudson.plugins.sshslaves.SSHLauncher',+'$class':+'hudson.plugins.sshslaves.SSHLauncher',+'host':+'" + host + "',+'includeUser':+'false',+'credentialsId':+'" + credentialsId + "',+'':+'0',+'sshHostKeyVerificationStrategy':+{'stapler-class':+'hudson.plugins.sshslaves.verifiers.KnownHostsFileKeyVerificationStrategy',+'$class':+'hudson.plugins.sshslaves.verifiers.KnownHostsFileKeyVerificationStrategy'},+'port':+'" + port + "',+'javaPath':+'',+'jvmOptions':+'',+'prefixStartSlaveCmd':+'',+'suffixStartSlaveCmd':+'',+'launchTimeoutSeconds':+'',+'maxNumRetries':+'',+'retryWaitTime':+'',+'tcpNoDelay':+true,+'workDir':+''},+'retentionStrategy':+{'stapler-class':+'hudson.slaves.RetentionStrategy$Always',+'$class':+'hudson.slaves.RetentionStrategy$Always'},+'nodeProperties':+{'stapler-class-bag':+'true'},+'type':+'hudson.slaves.DumbSlave',+'Submit':+''}"jenkinsUser := "Jenkins的用户"jenkinsAPIToken := "Jenkins的token"jsonObject := objjenkinsURL := "http://127.1.1:80" //Jeknins地址data := fmt.Sprintf(`json=%s`, jsonObject)req, err := http.NewRequest("POST", jenkinsURL+"/computer/doCreateItem?name="+nodeName+"&type=hudson.slaves.DumbSlave", bytes.NewBufferString(data))if err != nil {Err("CreateAgent error : %v\n", err)return req.Response.StatusCode}req.Header.Set("Content-Type", "application/x-www-form-urlencoded")req.Header.Set("Authorization", fmt.Sprintf("Basic %s", base64.StdEncoding.EncodeToString([]byte(jenkinsUser+":"+jenkinsAPIToken))))client := &http.Client{}resp, err := client.Do(req)if err != nil {Err("CreateAgent error : %v\n", err)return resp.StatusCode}defer resp.Body.Close()body, err := io.ReadAll(resp.Body)if err != nil {fmt.Println("读取响应失败：", err)return}fmt.Println("响应内容：", string(body))fmt.Println("\n\n响应状态码 ", resp.StatusCode)}

nodeName 你创建的node的名字

nodeDescription 描述，空也可以

numExecutors 一般1

remoteFS 远程控制的目录，类似 home/Aaron

labelString 不写也可以

host 远程主机的host

credentialsId 凭证，用来连接到远程主机的

2.创建凭证

func  CreateCredentials(username string, password string, id string)  {var obj stringobj = "{'':+'0',+'credentials':+{'scope':+'GLOBAL',+'username':+'" + username + "',+'usernameSecret':+false,+'password':+'" + password + "',+'$redact':+'password',+'id':+'" + id + "',+'description':+'',+'stapler-class':+'com.cloudbees.plugins.credentials.impl.UsernamePasswordCredentialsImpl',+'$class':+'com.cloudbees.plugins.credentials.impl.UsernamePasswordCredentialsImpl'},+'Submit':+''}"jenkinsUser := "Jenkins的用户"jenkinsAPIToken := "Jenkins的token"jsonObject := objjenkinsURL := "http://127.1.1:80" //Jeknins地址data := fmt.Sprintf(`json=%s`, jsonObject)req, err := http.NewRequest("POST", jenkinsURL+"/manage/credentials/store/system/domain/_/createCredentials", bytes.NewBufferString(data))if err != nil {Err("CreateCredentials error : %v\n", err)return }req.Header.Set("Content-Type", "application/x-www-form-urlencoded")req.Header.Set("Authorization", fmt.Sprintf("Basic %s", base64.StdEncoding.EncodeToString([]byte(jenkinsUser+":"+jenkinsAPIToken))))client := &http.Client{}resp, err := client.Do(req)if err != nil {Err("CreateCredentials error : %v\n", err)return }defer resp.Body.Close()}

username 创建凭证的用户名

password 创建凭证的密码

id 凭证的id，唯一，创建node的时候会用到

3.创建Job


func  CreateJob(jobName string, agent string, command string)  {jenkinsURL := "http://127.1.1:80" //Jeknins地址url := jenkinsURL + "/createItem?name=" + jobNamedata := `<project><actions/><description></description><keepDependencies>false</keepDependencies><properties/><scm class="hudson.scm.NullSCM"/><assignedNode>` + agent + `</assignedNode><canRoam>false</canRoam><disabled>false</disabled><blockBuildWhenDownstreamBuilding>false</blockBuildWhenDownstreamBuilding><blockBuildWhenUpstreamBuilding>false</blockBuildWhenUpstreamBuilding><triggers/><concurrentBuild>false</concurrentBuild><builders><hudson.tasks.Shell><command>` + command + `</command><configuredLocalRules/></hudson.tasks.Shell></builders><publishers/><buildWrappers><hudson.plugins.timestamper.TimestamperBuildWrapper plugin="timestamper@1.25"/></buildWrappers></project>`jenkinsUser := "Jenkins的用户"jenkinsAPIToken := "Jenkins的token"req, err := http.NewRequest("POST", url, bytes.NewBuffer([]byte(data)))if err != nil {Err("Error creating request:", err)return req.Response.StatusCode}req.Header.Set("Content-Type", "application/xml")req.SetBasicAuth(jenkinsUser, jenkinsAPIToken)client := &http.Client{}resp, err := client.Do(req)if err != nil {fmt.Println("Error sending request:", err)return}defer resp.Body.Close()
}

jobName 你创建的Job的名字

agent 你的Job要跑在那个agent/node上面

command 执行的命令，类似 “ls pwd”等

4.执行Job

func  BuildNow(jobName string)  {jenkinsURL := "http://127.1.1:80" //Jeknins地址url := jenkinsURL + "/job/" + jobName + "/build?delay=0sec"jenkinsUser := "Jenkins的用户"jenkinsAPIToken := "Jenkins的token"req, err := http.NewRequest("POST", url, bytes.NewBuffer([]byte("")))if err != nil {return}req.Header.Set("Content-Type", "application/xml")req.SetBasicAuth(jenkinsUser, jenkinsAPIToken)client := &http.Client{}resp, err := client.Do(req)if err != nil {return}defer resp.Body.Close()}

5.获取Job信息

url := fmt.Sprintf("http://%s@%s:%d/%s/api/json", Token, Addr, Port, api)url = fmt.Sprintf("%s?depth=%d", url, 2)req, err := http.NewRequest("GET", url, bytes.NewBuffer([]byte("")))

Token jenkins的token

Addr jenkins地址

Port jenkins端口号

api 固定写“computer”

这边会返回很多信息，都是json信息，然后你可以自己分析其中的内容。

PS:

这些API 你都可以自己去找，打开Jenkins，打开浏览器开发选项(选择network)，然后做你要做的时候，就可以找到对应的API的动作了。Reuqest URL就是 API的地址，往下拉可以看到请求的内容。