网络监控

func httpPing(url string, count int) (int, float64) {
	client := &http.Client{
		Timeout: 2 * time.Second,
		Transport: &http.Transport{
			DialContext: (&net.Dialer{
				Timeout:   2 * time.Second,
				KeepAlive: -1,
			}).DialContext,
		},
		CheckRedirect: func(req *http.Request, via []*http.Request) error {
			return http.ErrUseLastResponse
		},
	}

	startTime := time.Now().UnixMilli()

	errNum := 0
	for i := 0; i < count; i++ {
		_, err := client.Get(url)
		if err != nil {
			errNum++
		}
	}

	endTime := time.Now().UnixMilli()

	spend := (endTime - startTime) / int64(count)

	return int(spend), float64(errNum) / float64(count)
}


func TcpPing(host string, count int) (int64, float64) {
	start := time.Now().UnixMilli()

	failNum := 0
	for i := 0; i < count; i++ {
		d := net.Dialer{Timeout: 2 * time.Second}
		conn, err := d.Dial("tcp", host)
		if err != nil {
			failNum++
		}
		if conn != nil {
			conn.Close()
		}
	}

	spendTime := time.Now().UnixMilli() - start
	if failNum == count {
		return 0, 1
	}

	return spendTime / int64(count), float64(failNum) / float64(count)
}