1.創建Agent/Node
func CreateAgent(username string, password string, nodeName string, nodeDescription string, numExecutors string, remoteFS string, labelString string, host string) {
var obj string
obj = "{'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 := obj
jenkinsURL := "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 string
obj = "{'':+'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 := obj
jenkinsURL := "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=" + jobName
data := `<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的地址，往下拉可以看到请求的内容。
![洛谷 P8802 [蓝桥杯 2022 国 B] 出差](https://img-blog.csdnimg.cn/img_convert/4d78fd802e8dc1b57b8a7daf6854702e.jpeg)
