Go語(yǔ)言resty http包調(diào)用jenkins api實(shí)例

更新時(shí)間：2022年06月09日 09:39:56 作者：愛(ài)吃紅薯粉

這篇文章主要為大家介紹了Go語(yǔ)言resty http包調(diào)用jenkins api實(shí)例，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

前言

在前兩篇文章中都使用HttpRequest這個(gè)http包來(lái)做api的請(qǐng)求

然后github上面還有一個(gè)更有名，星星更多，社區(qū)也更活躍的http包Resty

最近11月3號(hào)又發(fā)布了一個(gè)新版本，項(xiàng)目參與者多達(dá)75個(gè)，標(biāo)星有5.2k

Resty特色

支持GET, POST, PUT, DELETE, HEAD, PATCH, OPTIONS等方法
設(shè)置和請(qǐng)求的方法簡(jiǎn)單
請(qǐng)求體支持多種數(shù)據(jù)類型(string,[]byte,struct,map,slice,io.Reader)
返回支持[]byte和string
對(duì)json和xml內(nèi)容自動(dòng)編碼和解碼
支持上傳一個(gè)多個(gè)文件和下載指定路徑或打包
請(qǐng)求參數(shù)支持QueryParams,QueryString,FormData
支持重試，代理，證書(shū)
支持簡(jiǎn)單認(rèn)證和認(rèn)證token

Resty官網(wǎng): https://github.com/go-resty/resty

演示例子

演示部分例子get,post等例子，其它put,delete,patch都差不多

簡(jiǎn)單get請(qǐng)求

該示例顯示請(qǐng)求狀態(tài)和響應(yīng)耗時(shí)

func simpleGet() {
   client := resty.New()
   resp, _ := client.R().EnableTrace().Get("https://httpbin.org/get")
   fmt.Println("狀態(tài)碼:", resp.StatusCode())
   fmt.Println("總耗時(shí):", resp.Time())
}

增強(qiáng)get請(qǐng)求

該示例支持map類型和路徑參數(shù)，支持設(shè)置請(qǐng)求頭和認(rèn)證token

func enhancedGet() {
   client := resty.New()
   resp, _ := client.R().
      SetQueryParams(map[string]string{
         "page_no": "1",
         "limit":   "20",
         "sort":    "name",
         "order":   "asc",
         "random":  strconv.FormatInt(time.Now().Unix(), 10),
      }).
      //SetQueryString("productId=232&amp;template=fresh-sample&amp;cat=resty&amp;source=google&amp;kw=buy a lot more").
      SetHeader("Accept", "application/json").
      SetAuthToken("xxxxxxxxxxxxxxxxxxxxxxx").
      Get("/search_result")
   fmt.Println(resp)
}

靈活post請(qǐng)求

該示例支持設(shè)置body內(nèi)容為map支持簡(jiǎn)單認(rèn)證和token認(rèn)證

func variousPost() {
   client := resty.New()
   resp, err := client.R().
      SetBody(map[string]interface{}{"username": "testuser", "password": "testpass"}).
      SetAuthToken("&lt;your-auth-token&gt;").
      Post("https://myapp.com/login")
   fmt.Println(resp, err)
}

多文件上傳

該示例支持多文件上傳，支持定義本地文件路徑，支持設(shè)置FormData數(shù)據(jù)

func multipartFileUpload() {
   profileImgBytes, _ := ioutil.ReadFile("/Users/jeeva/test-img.png")
   notesBytes, _ := ioutil.ReadFile("/Users/jeeva/text-file.txt")
   client := resty.New()
   resp, _ := client.R().
      SetFileReader("profile_img", "test-img.png", bytes.NewReader(profileImgBytes)).
      SetFileReader("notes", "text-file.txt", bytes.NewReader(notesBytes)).
      SetFormData(map[string]string{
         "first_name": "dddd",
         "last_name": "cccc",
      }).
      Post("http://myapp.com/upload")
   fmt.Println(resp)
}

文件下載

定義下載保存路徑，直接下載

func downFile() {
   client := resty.New()
   _, _ = client.R().
      SetOutput("plugin/test-v5.1-beta.zip").
      Get("http://my.app/test")
}

實(shí)戰(zhàn)例子

通過(guò)上面的演示例子，可以看到resty這個(gè)包功能非常強(qiáng)大

接下來(lái)我們使用該包來(lái)封裝jenkins api，來(lái)進(jìn)行二次開(kāi)發(fā)

構(gòu)造一個(gè)jenkins客戶端

編寫一個(gè)方法創(chuàng)建jenkins客戶端，后續(xù)所有動(dòng)作只需調(diào)用既可

該客戶端集成了重試，json頭，以及簡(jiǎn)單認(rèn)證

func jenkinsClient() *resty.Request {
   c := resty.New()
   a := c.SetRetryCount(3).SetRetryWaitTime(5 * time.Second).
      SetRetryMaxWaitTime(20 * time.Second).
      R().SetHeader("Accept", "application/json").
      SetBasicAuth("username", "password")
   return a
}
var (
   url = "http://ip:port"
)

獲取jenkins job信息

創(chuàng)建好jobinfo的結(jié)構(gòu)體，方便接下來(lái)的數(shù)據(jù)接收

type JobInfo struct {
   DisplayName string
   FullName string
   Buildable bool
   NextBuildNumber int
   InQueue bool
   Color string //blue成功 red失敗
   Url string
}

resty會(huì)將返回?cái)?shù)據(jù)解碼,只需要提供結(jié)構(gòu)體接收

func jenkinsJobInfo(job string) {
   a := jenkinsClient()
   jobInfo := &amp;JobInfo{}
   resp, err := a.SetResult(jobInfo).Get(url + "/job/" + job + "/api/json")
   if err != nil {
      fmt.Println(err)
   }
   fmt.Println("resp\n", resp.StatusCode(), resp.Time())
   fmt.Println(jobInfo.Color)
}

無(wú)參構(gòu)建job

簡(jiǎn)單post請(qǐng)求,調(diào)用無(wú)參數(shù)構(gòu)建

func jenkinsJobBuild(job string)  {
   a := jenkinsClient()
   resp, _  := a.Post(url+"/job/"+job+"/build")
   if resp.StatusCode() == 201 {
      fmt.Println("build 成功")
   }
}

查看構(gòu)建日志

查看日志，需要先獲取job的最后一次的buildID

所以這里發(fā)請(qǐng)2次請(qǐng)求，第1次獲取buildID,第2次獲取日志內(nèi)容

func jenkinsJobLog(job string)  {
   a := jenkinsClient()
   resp, _ := a.Get(url + "/job/" + job + "/lastBuild/buildNumber")
   if resp.StatusCode() == 200 {
      lastBuild := resp.String()
      resp2, _ := a.Get(url + "/job/" + job + "/" + lastBuild + "/logText/progressiveText")
      fmt.Println(resp2.String())
   }
}

job開(kāi)關(guān)(啟用禁用job)

第一個(gè)參數(shù)為job名稱，第二個(gè)參數(shù)設(shè)定開(kāi)關(guān)值

func jenkinsJobSwich(job string,swi bool) {
   a := jenkinsClient()
   if swi {
      resp, _ := a.Post(url + "/job/" + job + "/enable")
      fmt.Println(resp.Status())
   } else {
      resp, _ := a.Post(url + "/job/" + job + "/disable")
      fmt.Println(resp.Status())
   }
}