架构师训练第七周

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()
    
}