Çalıştırılabilir Go Dokümanları: HTTP İstemcisi

Q: Go'da GET isteği nasıl yapılır?

resp, err := http.Get(url), err'i kontrol edin, sonra defer resp.Body.Close() yazın ve gövdeyi io.ReadAll(resp.Body) ile okuyun ya da json.NewDecoder(resp.Body).Decode(&v) ile çözün. resp.StatusCode'u da kontrol edin: bir 404 ya da 500, http.Get'ten gelen bir hata değildir.

Q: Go'da bir HTTP isteğine timeout nasıl ayarlanır?

Timeout'lu bir istemci oluşturun, client := &http.Client{Timeout: 10 * time.Second}, ve genel bir timeout'u olmayan http.Get ya da http.DefaultClient yerine onu kullanın: bağlantıyı kabul edip hiç yanıt vermeyen bir sunucu çağrıyı sonsuza kadar bloklar. İstek başına bir sınır için isteği http.NewRequestWithContext ve context.WithTimeout'tan gelen bir context ile oluşturun.

Q: Go'da JSON gövdeli bir POST isteği nasıl gönderilir?

Değeri marshal edin, sonra gönderin: body, _ := json.Marshal(v) ve http.Post(url, "application/json", bytes.NewReader(body)). Authorization gibi header'lar eklemek için isteği http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body)) ile oluşturun, req.Header.Set("Content-Type", "application/json") ayarlayın ve client.Do(req) ile gönderin.

Q: Go'da resp.Body'yi neden kapatmam gerekiyor?

Gövde açık bir bağlantı üzerindeki bir akıştır. Onu kapatmak bağlantıyı yeniden kullanım için havuza geri verir; unutmak, program sınırına ulaşana kadar bağlantıları ve dosya tanımlayıcılarını sızdırır. Okumasanız bile kapatın ve bağlantının yeniden kullanılmasını istiyorsanız sonuna kadar okuyun.

Bir GET isteği

package main

import (
	"fmt"
	"io"
	"net/http"
	"net/http/httptest"
)

func main() {
	// A local test server stands in for a real API (the editor has no internet access).
	srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		fmt.Fprintf(w, "you asked for %s", r.URL.Path)
	}))
	defer srv.Close()

	resp, err := http.Get(srv.URL + "/status")
	if err != nil {
		fmt.Println("request failed:", err)
		return
	}
	defer resp.Body.Close()

	body, err := io.ReadAll(resp.Body)
	if err != nil {
		fmt.Println("reading body:", err)
		return
	}
	fmt.Println(resp.StatusCode, resp.Header.Get("Content-Type"))
	fmt.Println(string(body))
}

Bu sayfadaki her örnek httptest.NewServer ile kendi sunucusunu başlatır ve onu localhost üzerinde gerçek bir TCP bağlantısıyla çağırır. srv.URL yerine https://api.example.com gibi gerçek bir adres koyun, istemci kodu değişmez.

Burada görünen üç kural:

Önce err'i kontrol edin. Hiçbir yanıt alınamamasına yol açan başarısızlıkları bildirir: DNS hataları, reddedilen bağlantılar, timeout'lar, TLS sorunları.
Hata kontrolünün hemen ardından defer resp.Body.Close(). Gövde bağlantıyı açık tutar. Kapatılmamış bir gövde bağlantıyı sızdırır.
Gövdeyi okuyun ya da çözün. Metin için io.ReadAll, JSON için json.NewDecoder(resp.Body).Decode(&v).

Durum kodları hata değildir

http.Get, 404 ve 500 dahil sunucunun gönderdiği her yanıt için err == nil döndürür. Durumu kendiniz kontrol etmeniz gerekir:

package main

import (
	"bytes"
	"encoding/json"
	"fmt"
	"io"
	"net/http"
	"net/http/httptest"
)

type User struct {
	ID   int    `json:"id"`
	Name string `json:"name"`
}

func getUser(baseURL string, id int) (User, error) {
	resp, err := http.Get(fmt.Sprintf("%s/users/%d", baseURL, id))
	if err != nil {
		return User{}, err
	}
	defer resp.Body.Close()

	if resp.StatusCode != http.StatusOK {
		// Read a little of the body: APIs usually explain the error there.
		msg, _ := io.ReadAll(io.LimitReader(resp.Body, 512))
		return User{}, fmt.Errorf("get user %d: %s: %s", id, resp.Status, bytes.TrimSpace(msg))
	}

	var u User
	if err := json.NewDecoder(resp.Body).Decode(&u); err != nil {
		return User{}, fmt.Errorf("decode user %d: %w", id, err)
	}
	return u, nil
}

func main() {
	mux := http.NewServeMux()
	mux.HandleFunc("GET /users/{id}", func(w http.ResponseWriter, r *http.Request) {
		if r.PathValue("id") != "1" {
			http.Error(w, "no such user", http.StatusNotFound)
			return
		}
		w.Header().Set("Content-Type", "application/json")
		fmt.Fprint(w, `{"id": 1, "name": "Grace"}`)
	})
	srv := httptest.NewServer(mux)
	defer srv.Close()

	fmt.Println(getUser(srv.URL, 1))
	fmt.Println(getUser(srv.URL, 2))
}

io.LimitReader bir hata gövdesinin ne kadarını okuyacağınızı sınırlar, böylece hatalı davranan bir sunucu sizi bir hata mesajına megabaytlarca veri yüklemeye zorlayamaz. Birçok API başarı için 201, 202 ya da 204 döndürür; herhangi bir 2xx yeterliyse resp.StatusCode >= 200 && resp.StatusCode < 300'ü kontrol edin.

Timeout'lar: gerçek trafik için asla varsayılan istemciyi kullanmayın

http.Get, http.Post ve http.DefaultClient'ın genel bir timeout'u yoktur (varsayılan transport yalnızca bağlanmayı ve TLS el sıkışmasını sınırlar). Bağlantıyı kabul edip hiç yanıt vermeyen bir sunucu goroutine'inizi sonsuza kadar bloklar. Kendi istemcinizi oluşturun:

package main

import (
	"errors"
	"fmt"
	"net"
	"net/http"
	"net/http/httptest"
	"time"
)

func main() {
	slow := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		select {
		case <-time.After(2 * time.Second):
		case <-r.Context().Done(): // stop when the client gives up
		}
	}))
	defer slow.Close()

	client := &http.Client{Timeout: 100 * time.Millisecond}

	start := time.Now()
	_, err := client.Get(slow.URL)
	fmt.Println("gave up quickly:", time.Since(start) < time.Second)

	var netErr net.Error
	if errors.As(err, &netErr) && netErr.Timeout() {
		fmt.Println("timeout error:", netErr.Timeout())
	}
}

Client.Timeout tüm alışverişi kapsar: bağlanmak, yönlendirmeler ve gövdeyi okumak. Döndürdüğü hata, Timeout() == true bildiren bir *url.Error'dır ve errors.As onu net.Error interface'i üzerinden bulur. Bir istemci oluşturun ve her yerde yeniden kullanın; bir http.Client eşzamanlı kullanım için güvenlidir. Bağlantı havuzu Client'ta değil Transport'ta yaşar: istek başına yeni bir http.Client{} yine http.DefaultTransport'u ve onun havuzunu paylaşır, ama istek başına yeni bir http.Transport her seferinde boş bir havuzla başlar.

Context ve header'lı istekler

http.NewRequestWithContext, client.Do ile göndermeden önce özelleştirebileceğiniz bir istek oluşturur. Context, istemcinin timeout'unun üzerine istek başına bir deadline ya da iptal ekler ve bir sunucuda giden çağrıları gelen bir isteğin ömrüne bağlar.

package main

import (
	"context"
	"fmt"
	"io"
	"net/http"
	"net/http/httptest"
	"net/url"
	"time"
)

func main() {
	srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		fmt.Fprintf(w, "auth=%q agent=%q q=%q page=%q",
			r.Header.Get("Authorization"), r.Header.Get("User-Agent"),
			r.URL.Query().Get("q"), r.URL.Query().Get("page"))
	}))
	defer srv.Close()

	client := &http.Client{Timeout: 10 * time.Second}

	ctx, cancel := context.WithTimeout(context.Background(), 2*time.Second)
	defer cancel()

	// Build the query string safely: url.Values escapes spaces and symbols.
	params := url.Values{}
	params.Set("q", "go & rust")
	params.Set("page", "2")
	target := srv.URL + "/search?" + params.Encode()

	req, err := http.NewRequestWithContext(ctx, http.MethodGet, target, nil)
	if err != nil {
		fmt.Println(err)
		return
	}
	req.Header.Set("Authorization", "Bearer token123")
	req.Header.Set("User-Agent", "docs-example/1.0")

	resp, err := client.Do(req)
	if err != nil {
		fmt.Println(err)
		return
	}
	defer resp.Body.Close()
	body, _ := io.ReadAll(resp.Body)
	fmt.Println(string(body))
	fmt.Println("encoded query:", params.Encode())
}

Kullanıcı girdisini bir URL'e birleştirmek ("?q=" + q), &, # ve boşluklarda bozulur. url.Values ve onun Encode metodu kaçışlamayı yapar ve anahtarları sıralar. Yol parçaları için url.PathEscape kullanın.

JSON POST

package main

import (
	"bytes"
	"encoding/json"
	"fmt"
	"io"
	"net/http"
	"net/http/httptest"
	"time"
)

type Order struct {
	Item     string `json:"item"`
	Quantity int    `json:"quantity"`
}

type Created struct {
	ID     int    `json:"id"`
	Status string `json:"status"`
}

func main() {
	srv := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		var o Order
		if r.Header.Get("Content-Type") != "application/json" {
			http.Error(w, "want JSON", http.StatusUnsupportedMediaType)
			return
		}
		if err := json.NewDecoder(r.Body).Decode(&o); err != nil {
			http.Error(w, err.Error(), http.StatusBadRequest)
			return
		}
		w.Header().Set("Content-Type", "application/json")
		w.WriteHeader(http.StatusCreated)
		json.NewEncoder(w).Encode(Created{ID: 101, Status: fmt.Sprintf("%d x %s", o.Quantity, o.Item)})
	}))
	defer srv.Close()

	client := &http.Client{Timeout: 5 * time.Second}

	payload, err := json.Marshal(Order{Item: "coffee", Quantity: 2})
	if err != nil {
		fmt.Println(err)
		return
	}

	resp, err := client.Post(srv.URL+"/orders", "application/json", bytes.NewReader(payload))
	if err != nil {
		fmt.Println(err)
		return
	}
	defer resp.Body.Close()

	if resp.StatusCode != http.StatusCreated {
		msg, _ := io.ReadAll(resp.Body)
		fmt.Println("unexpected status:", resp.Status, string(msg))
		return
	}
	var c Created
	if err := json.NewDecoder(resp.Body).Decode(&c); err != nil {
		fmt.Println(err)
		return
	}
	fmt.Printf("%d %+v\n", resp.StatusCode, c)
}

client.Post(url, contentType, body), o Content-Type header'ına sahip bir isteğin kısayoludur. Başka her şey için (bir auth header'ı, PUT, PATCH, DELETE) metotla birlikte http.NewRequestWithContext ve client.Do kullanın. Form gönderimleri için client.PostForm(url, url.Values{...}) değerleri kodlar ve application/x-www-form-urlencoded ayarlar.

Bağlantı yeniden kullanımı

İstemci bir TCP bağlantısını yalnızca önceki gövdeyi sonuna kadar okuyup kapattığınızda yeniden kullanır. Okumayı erken bırakırsanız (örneğin bir hata durumundan sonra), aynı host'a çok istek yapıyorsanız kapatmadan önce gövdeyi boşaltın:

defer func() {
	io.Copy(io.Discard, resp.Body)
	resp.Body.Close()
}()

Çok büyük olabilecek gövdeler için bunun yerine io.LimitReader üzerinden boşaltın ya da bağlantıyı kaybetmeyi kabul edin.

Yönlendirmeler

İstemci en fazla 10 yönlendirmeyi otomatik olarak izler ve resp.Request.URL nerede son bulduğunuzu söyler. İlk yönlendirmede durmak için, örneğin bir Location header'ını okumak için, CheckRedirect'i ayarlayın:

client := &http.Client{
	Timeout: 10 * time.Second,
	CheckRedirect: func(req *http.Request, via []*http.Request) error {
		return http.ErrUseLastResponse // return the 3xx response itself
	},
}

Sık yapılan hatalar

Production'da http.Get ya da http.DefaultClient kullanmak. Timeout yok. Timeout'lu bir http.Client oluşturun.
resp.Body.Close()'u unutmak. İstekler başarısız olmaya başlayana kadar bağlantılar sızar.
err'i kontrol etmeden gövdeyi kapatmak. err nil değilken resp nil'dir ve resp.Body.Close() panic olur.
err == nil'i başarı saymak. resp.StatusCode'u kontrol edin.
İstek başına yeni bir http.Transport oluşturmak. Her transport'un kendi bağlantı havuzu vardır, bu yüzden her istek yeni bir bağlantı (ve yeni bir TLS el sıkışması) açar. Genellikle paylaşılan tek bir http.Client üzerinden tek bir transport paylaşın.
Sorgu string'lerini elle oluşturmak. url.Values kullanın.

Sıkça Sorulan Sorular

Go'da GET isteği nasıl yapılır?

resp, err := http.Get(url), err'i kontrol edin, sonra defer resp.Body.Close() yazın ve gövdeyi io.ReadAll(resp.Body) ile okuyun ya da json.NewDecoder(resp.Body).Decode(&v) ile çözün. resp.StatusCode'u da kontrol edin: bir 404 ya da 500, http.Get'ten gelen bir hata değildir.

Go'da bir HTTP isteğine timeout nasıl ayarlanır?

Timeout'lu bir istemci oluşturun, client := &http.Client{Timeout: 10 * time.Second}, ve genel bir timeout'u olmayan http.Get ya da http.DefaultClient yerine onu kullanın: bağlantıyı kabul edip hiç yanıt vermeyen bir sunucu çağrıyı sonsuza kadar bloklar. İstek başına bir sınır için isteği http.NewRequestWithContext ve context.WithTimeout'tan gelen bir context ile oluşturun.

Go'da JSON gövdeli bir POST isteği nasıl gönderilir?

Değeri marshal edin, sonra gönderin: body, _ := json.Marshal(v) ve http.Post(url, "application/json", bytes.NewReader(body)). Authorization gibi header'lar eklemek için isteği http.NewRequestWithContext(ctx, http.MethodPost, url, bytes.NewReader(body)) ile oluşturun, req.Header.Set("Content-Type", "application/json") ayarlayın ve client.Do(req) ile gönderin.

Go'da resp.Body'yi neden kapatmam gerekiyor?

Gövde açık bir bağlantı üzerindeki bir akıştır. Onu kapatmak bağlantıyı yeniden kullanım için havuza geri verir; unutmak, program sınırına ulaşana kadar bağlantıları ve dosya tanımlayıcılarını sızdırır. Okumasanız bile kapatın ve bağlantının yeniden kullanılmasını istiyorsanız sonuna kadar okuyun.

İlgili kavramlar