酷站(www.ku0.com)-致力于为互联网从业者提供专业的网络资源资讯

热门关键词:  企业  as  baidu  c4rp3nt3r  美女

Golang请求fasthttp实例介绍

来源:互联网 作者:秩名 人气: 发布时间:2021-11-03
本篇文章主要介绍了Golang请求fasthttp实例介绍,对大家的学习或者工作具有一定的参考学习价值,感兴趣的小伙伴们可以参考一下,也感谢大家对酷站(ku0.com)的支持。

在github.com/valyala/fasthttp用到了对象池,为了在高性能测试中减少内存的使用,fasthttp使用了两个对象池(我只看了这俩):requestPool sync.Pool和responsePool sync.Pool,当然fasthttp也提供了正常的对象创建API,后面我在案例中也会写到。

基础API演示

首先分享一下基础的用法封装:

PS:这个属于练习版本,所以没写多少注释。

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

package ft

 

import (

 "encoding/json"

 "fmt"

 "funtester/task"

 "github.com/valyala/fasthttp"

)

 

 

func FastGet(url string, args map[string]interface{}) ([]byte, error) {

 uri := url + "?" + task.ToValues(args)

 _, resp, err := fasthttp.Get(nil, uri)

 if err != nil {

  fmt.Println("请求失败:", err.Error())

  return nil, err

 }

 return resp, err

}

 

func FastPostForm(url string, args map[string]interface{}) ([]byte, error) {

 

 // 填充表单,类似于net/url

 params := &fasthttp.Args{}

 for s, i2 := range args {

  sprintf := fmt.Sprintf("%v", i2)

  params.Add(s, sprintf)

 }

 _, resp, err := fasthttp.Post(nil, url, params)

 if err != nil {

  fmt.Println("请求失败:", err.Error())

  return nil, err

 }

 return resp, nil

}

 

func FastPostJson(url string, args map[string]interface{}) ([]byte, error) {

 

 req := &fasthttp.Request{}

 req.SetRequestURI(url)

 

 marshal, _ := json.Marshal(args)

 req.SetBody(marshal)

 

 // 默认是application/x-www-form-urlencoded,其实无所谓

 req.Header.SetContentType("application/json")

 req.Header.SetMethod("POST")

 

 resp := &fasthttp.Response{}

 if err := fasthttp.Do(req, resp); err != nil {

  fmt.Println("请求失败:", err.Error())

  return nil, err

 }

 return resp.Body(), nil

}

其中两点主要注意:

FastGet、FastPostForm使用的fasthttp提供的默认获取请求的方式,FastPostJson使用了自定义请求和获取响应的方式

关于请求头中的req.Header.SetContentType方法,其实无所谓,服务端都可以解析

高性能API演示

下面分享使用更高的性能(基于对象池)的API创建请求和获取响应的方式:

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

package task

 

import (

 "crypto/tls"

 "encoding/json"

 "fmt"

 "github.com/valyala/fasthttp"

 "log"

 "time"

)

 

var FastClient fasthttp.Client = fastClient()

 

// FastGet 获取GET请求对象,没有进行资源回收

// @Description:

// @param url

// @param args

// @return *fasthttp.Request

func FastGet(url string, args map[string]interface{}) *fasthttp.Request {

 req := fasthttp.AcquireRequest()

 req.Header.SetMethod("GET")

 values := ToValues(args)

 req.SetRequestURI(url + "?" + values)

 return req

}

 

// FastPostJson POST请求JSON参数,没有进行资源回收

// @Description:

// @param url

// @param args

// @return *fasthttp.Request

func FastPostJson(url string, args map[string]interface{}) *fasthttp.Request {

 req := fasthttp.AcquireRequest()

 // 默认是application/x-www-form-urlencoded

 req.Header.SetContentType("application/json")

 req.Header.SetMethod("POST")

 req.SetRequestURI(url)

 marshal, _ := json.Marshal(args)

 req.SetBody(marshal)

 return req

}

 

// FastPostForm POST请求表单传参,没有进行资源回收

// @Description:

// @param url

// @param args

// @return *fasthttp.Request

func FastPostForm(url string, args map[string]interface{}) *fasthttp.Request {

 req := fasthttp.AcquireRequest()

 // 默认是application/x-www-form-urlencoded

 //req.Header.SetContentType("application/json")

 req.Header.SetMethod("POST")

 req.SetRequestURI(url)

 marshal, _ := json.Marshal(args)

 req.BodyWriter().Write([]byte(ToValues(args)))

 req.BodyWriter().Write(marshal)

 return req

}

 

// FastResponse 获取响应,保证资源回收

// @Description:

// @param request

// @return []byte

// @return error

func FastResponse(request *fasthttp.Request) ([]byte, error) {

 response := fasthttp.AcquireResponse()

 defer fasthttp.ReleaseResponse(response)

 defer fasthttp.ReleaseRequest(request)

 if err := FastClient.Do(request, response); err != nil {

  log.Println("响应出错了")

  return nil, err

 }

 return response.Body(), nil

}

 

// DoGet 发送GET请求,获取响应

// @Description:

// @param url

// @param args

// @return []byte

// @return error

func DoGet(url string, args map[string]interface{}) ([]byte, error) {

 req := fasthttp.AcquireRequest()

 defer fasthttp.ReleaseRequest(req) // 用完需要释放资源

 req.Header.SetMethod("GET")

 values := ToValues(args)

 req.SetRequestURI(url + "?" + values)

 resp := fasthttp.AcquireResponse()

 defer fasthttp.ReleaseResponse(resp) // 用完需要释放资源

 if err := FastClient.Do(req, resp); err != nil {

  fmt.Println("请求失败:", err.Error())

  return nil, err

 }

 return resp.Body(), nil

}

 

// fastClient 获取fast客户端

// @Description:

// @return fasthttp.Client

func fastClient() fasthttp.Client {

 return fasthttp.Client{

  Name:                     "FunTester",

  NoDefaultUserAgentHeader: true,

  TLSConfig:                &tls.Config{InsecureSkipVerify: true},

  MaxConnsPerHost:          2000,

  MaxIdleConnDuration:      5 * time.Second,

  MaxConnDuration:          5 * time.Second,

  ReadTimeout:              5 * time.Second,

  WriteTimeout:             5 * time.Second,

  MaxConnWaitTimeout:       5 * time.Second,

 }

}

测试服务

用的还是moco_FunTester测试框架,脚本如下:

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

package com.mocofun.moco.main

 

import com.funtester.utils.ArgsUtil

import com.mocofun.moco.MocoServer

import org.apache.tools.ant.taskdefs.condition.And

 

class Share extends MocoServer {

 

    static void main(String[] args) {

        def util = new ArgsUtil(args)

        //                def server = getServerNoLog(util.getIntOrdefault(0,12345))

        def server = getServer(util.getIntOrdefault(0, 12345))

        server.get(both(urlStartsWith("/test"),existArgs("code"))).response("get请求")

        server.post(both(urlStartsWith("/test"), existForm("fun"))).response("post请求form表单")

        server.post(both(urlStartsWith("/test"), existParams("fun"))).response("post请求json表单")

        server.get(urlStartsWith("/qps")).response(qps(textRes("恭喜到达QPS!"), 1))

//        server.response(delay(jsonRes(getJson("Have=Fun ~ Tester !")), 1000))

        server.response("Have Fun ~ Tester !")

        def run = run(server)

        waitForKey("fan")

        run.stop()

    }

}

Golang单元测试

第一次写Golang单测,有点不适应,搞了很久才通。

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

package test

 

import (

 "funtester/ft"

 "funtester/task"

 "log"

 "testing"

)

 

const url = "http://localhost:12345/test"

 

func args() map[string]interface{} {

 return map[string]interface{}{

  "code": 32,

  "fun":  32,

  "msg":  "324",

 }

}

 

func TestGet(t *testing.T) {

 get := task.FastGet(url, args())

 res, err := task.FastResponse(get)

 if err != nil {

  t.Fail()

 }

 v := string(res)

 log.Println(v)

 if v != "get请求" {

  t.Fail()

 }

}

 

func TestPostJson(t *testing.T) {

 post := task.FastPostJson(url, args())

 res, err := task.FastResponse(post)

 if err != nil {

  t.Fail()

 }

 v := string(res)

 log.Println(v)

 if v != "post请求json表单" {

  t.Fail()

 }

}

 

func TestPostForm(t *testing.T) {

 post := task.FastPostForm(url, args())

 res, err := task.FastResponse(post)

 if err != nil {

  t.Fail()

 }

 v := string(res)

 log.Println(v)

 if v != "post请求form表单" {

  t.Fail()

 }

}

 

func TestGetNor(t *testing.T) {

 res, err := ft.FastGet(url, args())

 if err != nil {

  t.Fail()

 }

 v := string(res)

 log.Println(v)

 if v != "get请求" {

  t.Fail()

 }

}

 

func TestPostJsonNor(t *testing.T) {

 res, err := ft.FastPostJson(url, args())

 if err != nil {

  t.Fail()

 }

 v := string(res)

 log.Println(v)

 if v != "post请求json表单" {

  t.Fail()

 }

}

 

func TestPostFormNor(t *testing.T) {

 res, err := ft.FastPostForm(url, args())

 if err != nil {

  t.Fail()

 }

 v := string(res)

 log.Println(v)

 if v != "post请求form表单" {

  t.Fail()

 }

}

测试报告

用的自带的控制台输出内容:

=== RUN   TestGet
2021/10/18 18:56:49 get请求
--- PASS: TestGet (0.01s)
=== RUN   TestPostJson
2021/10/18 18:56:49 post请求json表单
--- PASS: TestPostJson (0.00s)
=== RUN   TestPostForm
2021/10/18 18:56:49 post请求form表单
--- PASS: TestPostForm (0.00s)
=== RUN   TestGetNor
2021/10/18 18:56:49 get请求
--- PASS: TestGetNor (0.00s)
=== RUN   TestPostJsonNor
2021/10/18 18:56:49 post请求json表单
--- PASS: TestPostJsonNor (0.00s)
=== RUN   TestPostFormNor
2021/10/18 18:56:49 post请求form表单
--- PASS: TestPostFormNor (0.00s)
=== RUN   TestStageJSON

版权声明:本文内容来源于互联网或用户自行发布贡献,该文观点仅代表原作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 959677720#qq.cn(#换@) 举报,一经查实,本站将立刻删除。
原文链接:https://mp.weixin.qq.com/s/9otWDl2mSGEo9fboyToNnw

相关文章

  • Golang打包配置文件的实现介绍

    Golang打包配置文件的实现介绍

    众所周知,Golang 适合写 CLI 工具,但你可能还不知道 Golang 还可以打包配置文件。 背景 最近在写一个涉及到管理阿里云 ECS 的 CLI 工具,这里当然就要考虑阿里云资源使用......
    12-08
  • Golang请求fasthttp实例介绍

    Golang请求fasthttp实例介绍

    在github.com/valyala/fasthttp用到了对象池,为了在高性能测试中减少内存的使用,fasthttp使用了两个对象池(我只看了这俩):requestPool sync.Pool和responsePool sync.Pool,当然fasth......
    11-03
  • Go并发读写sync.map介绍

    Go并发读写sync.map介绍

    map 的两种目前在业界使用的最多的并发支持的模式分别是: 原生map +互斥锁或读写锁mutex。 标准库sync.Map(Go1.9及以后)。 有了选择,总是有选择困难症的,这两种到底怎......
    10-15
  • Golang利用反射对结构体优雅排序的操作教程介绍

    Golang利用反射对结构体优雅排序的操作教程介绍

    最近开始实习,工作技术栈主要Python和Golang,目前的任务把Python模块重构为GO模块,然后出现了一个问题,就是要将一个结构体按结构体中各个字段进行排序,然后写入......
    10-14
  • Go语言的接口的介绍

    Go语言的接口的介绍

    接口就是一系列方法的集合(规范行为) 在面向对象的领域里,接口一般这样定义:接口定义一个对象的行为,规范子类对象的行为。 在 Go 语言中的接口是非侵入式接口......
    10-11
  • Go中的条件语句Switch介绍

    Go中的条件语句Switch介绍

    Switch简介 Go的switch的基本功能和C、Java类似: switch 语句用于基于不同条件执行不同动作,每一个 case 分支都是唯一的,从上至下逐一测试,直到匹配为止。 匹配项后面也......
    08-22
  • 基于HLS创建Golang视频流服务器的优缺点

    基于HLS创建Golang视频流服务器的优缺点

    HLS 是 HTTP Live Streaming 的缩写,是苹果开发的一种基于 HTTP 的自适应比特率流媒体传输协议, 并于 2009 年. HLS 流媒体已经成为应用最广泛的实时视频协议。它是一种将流分解......
    08-08
  • Go Plugins插件的实现介绍

    Go Plugins插件的实现介绍

    官方实现 golang 1.8 及以上版本提供了一个创建共享库(shared object)的新工具,称为 Plugins。目前 Plugins 仅在 Linux、FreeBSD 和 macOS 上受支持,且只支持 golang 调用。 使用示例......
    08-07
  • 在Golang中实现一个简单的Http中间件过程介绍

    在Golang中实现一个简单的Http中间件过程介绍

    本文主要针对Golang的内置库 net/http 做了简单的扩展,通过添加中间件的形式实现了管道(Pipeline)模式,这样的好处是各模块之间是低耦合的,符合单一职责原则,可以很灵......
    07-29
  • golang内置函数len的小技巧分享

    golang内置函数len的小技巧分享

    len是很常用的内置函数,可以测量字符串、slice、array、channel以及map的长度/元素个数。 不过你真的了解len吗?也许还有一些你不知道的小知识。 我们来看一道GO101的题目......
    07-25