并发测试

concurrency.go

package main

import (
	"crypto/tls"
	"fmt"
	"io/ioutil"
	"net/http"
	"strings"
	"sync"
	"time"
)

func main() {
	count := 1
	fmt.Printf("[concurrency] %d\n", count)
	wg := sync.WaitGroup{}
	startTime := time.Now().Unix()
	for index := 0; index < count; index++ {
		wg.Add(1)
		go func() {
			defer func() {
				wg.Add(-1)
			}()

			query()
		}()
	}
	wg.Wait()
	endTime := time.Now().Unix()
	fmt.Printf("[cost] %ds\n", endTime-startTime)
}

func query() {

	url := "https://baidu.com:8888/run"

	payload := strings.NewReader("{\n\t\"client\":\"local\",\n\t\"tgt\":\"*\",\n\t\"fun\":\"service.tcpall\",\n\t\"username\":\"*\",\n\t\"password\":\"*\",\n\t\"eauth\":\"pam\",\n\t\"arg\":[\"ips=*\", \"port=1935\"]\n}")

	tr := &http.Transport{
		TLSClientConfig: &tls.Config{InsecureSkipVerify: true},
	}
	cl := http.Client{
		Transport: tr,
	}

	res, err := cl.Post(url, "application/json", payload)

	if err != nil {
		fmt.Println(err)
		return
	}

	defer res.Body.Close()
	body, _ := ioutil.ReadAll(res.Body)

	fmt.Println(string(body))

}