架构师训练营第七周作业

package benchmark
import (	"fmt"	"io/ioutil"	"net/http"	"sort"	"sync"	"time")
// Report benchmark reporttype Report struct {	// url to be tested	url string
	// how many requests were sent in test	times int
	// latency of 95% requests	latency95 float64}
//HTTPBenchmark HTTPBenchmark generate report by invoking http requests and evalaluting responsesfunc HTTPBenchmark(url string, times int) Report {	if times <= 0 {		return Report{url, times, -1}	}
	var collector []chan float64 = make([]chan float64, times)	var latch sync.WaitGroup
	latch.Add(times)	for invoke := 0; invoke < times; invoke++ {		collector[invoke] = make(chan float64, 1)		go requestHTTP(url, &latch, collector[invoke])	}	fmt.Printf("Started %d jobs and waiting for the results\n", times)	latch.Wait()	fmt.Printf("All %d jobs were finished\n", times)
	var responses []float64 = make([]float64, times)	for invoke, collected := range collector {		responses[invoke] = <-collected	}
	sort.Slice(responses, func(r1, r2 int) bool {		return responses[r1] < responses[r2]	})
	var total float64	for r := 0; r < int(0.95*float64(times)); r++ {		total = total + responses[r]	}
	return Report{		url, times,		total / float64(times)}}
func requestHTTP(url string, latch *sync.WaitGroup, ch chan<- float64) {	defer latch.Done()
	start := time.Now()	rsp, err := http.Get(url)	var elapsed float64 = time.Since(start).Seconds()
	if err != nil {		fmt.Printf("failed to get response from '%s', detail: %s\n", url, err)	} else {		body, _ := ioutil.ReadAll(rsp.Body)		fmt.Printf("get response from '%s' (lenth: '%d') in %.2f seconds \n", url, len(body), elapsed)	}
	ch <- elapsed	close(ch)}

package benchmark
import (	"fmt"
	. "github.com/onsi/ginkgo")
var _ = Describe("http benchamark test", func() {	When("Test baidu by 100 concurrent requests", func() {		var report Report = HTTPBenchmark("http://www.baidu.com", 100)		fmt.Printf("%v", report)	})})