net & http & timeout

郭學聰 Hsueh-Tsung Kuo
Sun, 02 Aug 2020

net & http & timeout 郭學聰 Hsueh-Tsung Kuo Sun, 02 Aug 2020 CC BY-SA 4.0

	srv := &http.Server{
	ReadTimeout: 5 * time.Second,
	WriteTimeout: 10 * time.Second,
	IdleTimeout: 60 * time.Second,
	ReadHeaderTimeout: 1 * time.Second,
	}
	log.Println(srv.ListenAndServe())

	c := &http.Client{
	Transport: &http.Transport{
	Dial: (&net.Dialer{
	Timeout: 30 * time.Second,
	KeepAlive: 30 * time.Second,
	}).Dial,
	TLSHandshakeTimeout: 10 * time.Second,
	ResponseHeaderTimeout: 10 * time.Second,
	ExpectContinueTimeout: 1 * time.Second,
	IdleConnTimeout: 60 * time.Second,
	}
	}

	ctx := context.Background()

	client := http.DefaultClient

	requestMod := stream_http.RequestMod(func(req *http.Request) {
	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
	req.Header.Set("Authorization", "Bearer qawsedrftgyhujikolp")

	query := req.URL.Query()
	query.Add("param", "pvalue")
	req.URL.RawQuery = query.Encode()
	})
	requestTimeout := stream_http.Timeout(500 * time.Millisecond)

	reqBody := bytes.NewBuffer([]byte("form=fvalue"))
	var respBody bytes.Buffer

	resp, err := stream_http.DoRequest(ctx, client, http.MethodPost, "http://httpbin.org/anything", reqBody, &respBody, requestMod, requestTimeout)
	//resp, err := stream_http.DoRequest(ctx, client, http.MethodGet, "http://httpbin.org/status/401", nil, &respBody, requestMod, requestTimeout)
	if err != nil {
	return err
	}

	fmt.Printf("get response with status code: %d\n%s\n", resp.StatusCode, respBody.String())

	c := &http.Client{
	Timeout: 15 * time.Second,
	}
	resp, err := c.Get("https://blog.filippo.io/")

	func handleFunc(w http.ResponseWriter, req *http.Request) {
	n, err := stream_http.TimeoutCopy(&reqBody, req.Body, time.Duration(-1), 500*time.Millisecond)

	n, err = stream_http.TimeoutCopy(w, &respBody, 500*time.Millisecond, time.Duration(-1))
	}

	if !t.Stop() {
	<-t.C // don't do this if t.C is drained from another goroutine
	}
	_ = t.Reset(d) // don't use return value