基本使用

  1. 发送GET请求,并打印出返回值

  2. 发送GET请求,下载远程文件

    1. if r, err := g.Client().Get(ctx, "https://goframe.org/cover.png"); err != nil {
    2. panic(err)
    3. }
    4. defer r.Close()
    5. gfile.PutBytes("/Users/john/Temp/cover.png", r.ReadAll())

    下载文件操作,小文件下载非常简单。需要注意的是,如果远程文件比较大时,服务端会分批返回数据,因此会需要客户端发多个GET请求,每一次通过Header来请求分批的文件范围长度,感兴趣的同学可自行研究相关细节。

  3. 发送POST请求,并打印出返回值

    1. if r, err := g.Client().Post(ctx, "http://127.0.0.1:8199/form", "name=john&age=18"); err != nil {
    2. panic(err)
    3. }
    4. defer r.Close()
    5. fmt.Println(r.ReadAllString())

    传递多参数的时候用户可以使用&符号进行连接,注意参数值往往需要通过gurl.Encode编码一下。

    1. if r, err := g.Client().Post(
    2. ctx,
    3. "http://127.0.0.1:8199/form",
    4. g.Map{
    5. "submit" : "1",
    6. "callback" : "http://127.0.0.1/callback?url=http://baidu.com",
    7. }
    8. )); err != nil {
    9. panic(err)
    10. }
    11. defer r.Close()
    12. fmt.Println(r.ReadAllString())

    传递多参数的时候用户可以使用&符号进行连接,也可以直接使用map(其实之前也提到,任意数据类型都支持,包括struct)。

  4. 发送POST请求,参数为JSON数据,并打印出返回值

    1. if r, err := g.Client().Post(
    2. ctx,
    3. "http://user.svc/v1/user/create",
    4. `{"passport":"john","password":"123456","password-confirm":"123456"}`,
    5. ); err != nil {
    6. }
    7. defer r.Close()

    可以看到,通过ghttp客户端发送JSON数据请求非常方便,直接通过Post方法提交即可,客户端会自动将请求的Content-Type设置为application/json

  5. 发送DELETE请求,并打印出返回值

*Bytes*Content方法

BytesContent后缀结尾的请求方法为直接获取返回内容的快捷方法,这些方法将会自动读取服务端返回内容并自动关闭请求连接。*Bytes方法用于获取[]byte类型结果,*Content方法用于获取string类型结果。需要注意的是,如果请求执行失败,返回内容将会为空。

    1. // 返回content为[]bytes类型
    2. content := g.Client().GetBytes(ctx, "https://goframe.org")
    1. // 返回content为string类型
    2. content := g.Client().GetContent(ctx, "https://goframe.org")
  1. 发送POST请求,返回服务端返回内容

    1. // 返回content为[]bytes类型
    2. content := g.Client().PostBytes(ctx,
    3. "http://user.svc/v1/user/create",
    4. `{"passport":"john","password":"123456","password-confirm":"123456"}`,
    5. )
    1. // 返回content为string类型
    2. content := g.Client().PostContent(ctx,
    3. "http://user.svc/v1/user/create",
    4. `{"passport":"john","password":"123456","password-confirm":"123456"}`,
    5. )

*Var方法

Var后缀结尾的请求方法直接请求并获取HTTP接口结果为g.Var泛型类型便于转换。往往用于服务端返回格式为JSON/XML的情况,通过返回的g.Var泛型对象可根据需要自动解析。此外,如果请求失败或者请求结果为空,会返回一个空的g.Var泛型对象,不影响转换方法调用。

使用示例:

  1. // Struct
  2. var user *User
  3. g.Client().GetVar(ctx, url).Scan(&user)
  1. // Struct数组
  2. var users []*User
  3. g.Client().GetVar(ctx, url).Scan(&users)

New方法的使用

正常New方法的使用方式

  1. func ExampleNew() {
  2. var (
  3. ctx = gctx.New()
  4. )
  5. if r, err := client.Get(ctx, "http://127.0.0.1:8999/var/json"); err != nil {
  6. panic(err)
  7. } else {
  8. fmt.Println(r.ReadAllString())
  9. }
  10. // Output:
  11. // {"id":1,"name":"john"}
  12. }

原生http.Client就支持了连接池的使用, 只需要设置http.Tranport的属性即可支持.

  1. func ExampleNew_MultiConn_Recommend() {
  2. var (
  3. ctx = gctx.New()
  4. client = g.Client()
  5. )
  6. // controls the maximum idle(keep-alive) connections to keep per-host
  7. client.Transport.(*http.Transport).MaxIdleConnsPerHost = 5
  8. for i := 0; i < 5; i++ {
  9. go func() {
  10. if r, err := client.Get(ctx, "http://127.0.0.1:8999/var/json"); err != nil {
  11. panic(err)
  12. } else {
  13. fmt.Println(r.ReadAllString())
  14. r.Close()
  15. }
  16. }()
  17. }
  18. time.Sleep(time.Second * 1)
  19. // Output:
  20. //{"id":1,"name":"john"}
  21. //{"id":1,"name":"john"}
  22. //{"id":1,"name":"john"}
  23. //{"id":1,"name":"john"}
  24. //{"id":1,"name":"john"}
  25. }