duai4512 2019-03-18 09:50
浏览 29

为什么我的Golang压力测量工具和Apache Batch生成不同数量的ESTABLISHED链接?

Apache Batch is a popular pressure measuring tool.

I write a tool with the same function in golang myself. Then I make some tests. I find it works well.

But accidentally, I find a difference from my tool and Apache Batch:

When checking ESTABLISHED link number by the cmd netstat -na|grep ESTABLISHED|wc -l:

Use cmd ab -n 128000 -c 128 http://127.0.0.1:8000/, the cmd above returns a number near 128.

But use my own tool, the cmd returns near 256 (when set concurrency 128).

Why my own tool have twice the expected number of concurrencies?

My code:

func request(cli *http.Client, uri string) {
    resp, err := cli.Get(uri)
    if err != nil {
        panic(err)
    }
    defer resp.Body.Close()
    if resp.StatusCode != 200 {
        panic("return" + strconv.Itoa(resp.StatusCode))
    }
}

func workRoutine(ch chan string, wg *sync.WaitGroup) {
    cli := &http.Client{}
    for uri := range ch {
        request(cli, uri)
    }
    wg.Done()
}

func main() {
    rnum := 128
    tnum := 128000

    url := "http://127.0.0.1:8000/"

    ch := make(chan string)
    var wg sync.WaitGroup

    go func() {
        for i := 0; i < tnum; i++ {
            ch <- url
        }
        close(ch)
    }()

    wg.Add(rnum)
    for i := 0; i < rnum; i++ {
        go workRoutine(ch, &wg)
    }

    stime := time.Now()
    wg.Wait()
    dtime := time.Now().Sub(stime)
    fmt.Println("Timecost", dtime)
    fmt.Println("Throughputs", float64(tnum)/dtime.Seconds())
}
  • 写回答

0条回答 默认 最新

    报告相同问题?

    悬赏问题

    • ¥60 求一个简单的网页(标签-安全|关键词-上传)
    • ¥35 lstm时间序列共享单车预测,loss值优化,参数优化算法
    • ¥15 基于卷积神经网络的声纹识别
    • ¥15 Python中的request,如何使用ssr节点,通过代理requests网页。本人在泰国,需要用大陆ip才能玩网页游戏,合法合规。
    • ¥100 为什么这个恒流源电路不能恒流?
    • ¥15 有偿求跨组件数据流路径图
    • ¥15 写一个方法checkPerson,入参实体类Person,出参布尔值
    • ¥15 我想咨询一下路面纹理三维点云数据处理的一些问题,上传的坐标文件里是怎么对无序点进行编号的,以及xy坐标在处理的时候是进行整体模型分片处理的吗
    • ¥15 一直显示正在等待HID—ISP
    • ¥15 Python turtle 画图