架构师训练第七周

发布于: 21 小时前





当没有遇到性能瓶颈的时候,吞吐量与虚拟用户数之间存在一定的联系,可以采用以下公式计算:F=VU * R / T其中F为吞吐量,VU表示用户个数,R表示每个用户发出的请求数,T表示性能测试所用的时间,其实通过这个公式就能看出吞吐量与并发用户数之间的关系了。



package main

import (
  "fmt"
  "net/http"
  "time"
  "net"
  "encoding/json"
  "strings"
)


var iCurSession int
var iWhileRequest int
var strWeb string

func httpclient()
{
    connTimeout := 2*time.Millisecond
    readTimeout := 3*time.Millisecond

client := http.Client{
        Transport: &http.Transport{
            Dial: func(netw, addr string) (net.Conn, error) {
                c, err := net.DialTimeout("tcp4", addr, connTimeout)
                if err != nil {
                    return nil, err
                }
                c.SetDeadline(time.Now().Add(readTimeout))
                return c, nil
            },
        },
    }

for i:=0; i<iCurSession; i++ {
        postParams := map[string]interface{}{"checksum": "1111111111111", "result": "penggetest"}
        bytebody, _ := json.Marshal(postParams)
        retbody := string(bytebody)

        req, err := http.NewRequest("POST", strWeb, strings.NewReader(retbody))
        if err != nil {
            fmt.Println("new request err:", err)
            return
        }
        headers := make(map[string]string)
        for key, value := range headers {

            req.Header.Set(key, value)
        }
        resp, reqErr := client.Do(req)
        if reqErr != nil {
            fmt.Println(" client do err:", reqErr)
            return
        }
        defer resp.Body.Close()

        fmt.Println("code:", resp.StatusCode, "\nerr:", err)
        time.Sleep(2*time.Second)
    }
}


func main() {

// 通过入参获取参数
// iCurSession iWhileRequest strWeb

var iLoop int
var ithread int = iWhileRequest/iCurSession
var wg sync.WaitGroup
for iLoop = 0; iLoop < ithread; iLoop++ {
go httpclient()
wg.Add(1)
}
wg.Wait()
   
}




用户头像

邵帅

关注

还未添加个人签名 2017.10.29 加入

还未添加个人简介

评论 (1 条评论)

发布
用户头像
请加“极客大学架构师训练营”标签,便于分类
18 小时前
回复
没有更多了
架构师训练第七周