Timeout & batas server

Default net/http adalah "tidak ada batas": tidak ada batas waktu membaca, menulis, maupun menganggur. Untuk contoh di tutorial itu praktis; untuk server yang terbuka ke internet itu kerentanan.

Konfigurasi yang layak produksi

srv := &http.Server{
	Addr:    ":8080",
	Handler: handler,

	// Waktu maksimum membaca HEADER. Pertahanan Slowloris.
	ReadHeaderTimeout: 5 * time.Second,

	// Header + body. Naikkan hanya kalau memang menerima unggahan besar.
	ReadTimeout: 15 * time.Second,

	// Dari header selesai dibaca sampai respons selesai ditulis.
	// Ini mencakup SELURUH waktu kerja handler-mu.
	WriteTimeout: 15 * time.Second,

	// Berapa lama koneksi keep-alive menganggur sebelum ditutup.
	// Harus LEBIH BESAR dari idle timeout ALB (Fase 10).
	IdleTimeout: 65 * time.Second,

	// Batas ukuran seluruh header. Default 1 MB.
	MaxHeaderBytes: 1 << 20,
}

Serangan yang dicegahnya

Slowloris: buka 10.000 koneksi, kirim
    "GET / HTTP/1.1\r\n"
lalu satu header tiap 30 detik, tanpa pernah selesai.

Tanpa ReadHeaderTimeout:
  • 10.000 goroutine hidup, masing-masing menunggu selamanya
  • 10.000 file descriptor terpakai
  • memori naik, pengguna sungguhan tidak kebagian koneksi
  • satu laptop cukup untuk melakukannya

Kenapa WriteTimeout sering menipu

// Handler ini butuh 20 detik. Dengan WriteTimeout 15 detik:
// koneksi diputus di detik 15, dan KLIEN menerima respons terpotong —
// sementara handler-mu TETAP BERJALAN sampai selesai.
func lambat(w http.ResponseWriter, r *http.Request) {
	hasil := prosesBerat(r.Context())   // 20 detik
	json.NewEncoder(w).Encode(hasil)     // koneksi sudah mati
}

Timeout server memutus koneksi; ia tidak menghentikan handler. Yang menghentikan handler adalah context. Karena itu keduanya dipakai bersama:

// Middleware timeout memasang tenggat DI CONTEXT — inilah yang benar-benar
// menghentikan pekerjaan, termasuk kueri database di lapisan terdalam.
func BatasWaktu(d time.Duration) func(http.Handler) http.Handler {
	return func(next http.Handler) http.Handler {
		return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
			ctx, batal := context.WithTimeout(r.Context(), d)
			defer batal()
			next.ServeHTTP(w, r.WithContext(ctx))
		})
	}
}

Endpoint yang perlu pengecualian

// Unggahan besar atau SSE: perpanjang tenggat per permintaan,
// tanpa melonggarkan seluruh server.
func unggah(w http.ResponseWriter, r *http.Request) {
	rc := http.NewResponseController(w)          // Go 1.20+
	_ = rc.SetReadDeadline(time.Now().Add(10 * time.Minute))
	_ = rc.SetWriteDeadline(time.Time{})          // tanpa batas tulis

	...
}

// Server-sent events: matikan batas tulis dan flush setiap pesan.
func peristiwa(w http.ResponseWriter, r *http.Request) {
	rc := http.NewResponseController(w)
	_ = rc.SetWriteDeadline(time.Time{})

	w.Header().Set("Content-Type", "text/event-stream")
	for {
		select {
		case <-r.Context().Done():
			return
		case p := <-pesan:
			fmt.Fprintf(w, "data: %s\n\n", p)
			_ = rc.Flush()
		}
	}
}

Menyelaraskan dengan ALB