Bagaimana untuk melaksanakan mekanisme percubaan semula permintaan untuk hos tertentu menggunakan Go dan http.Transport?

Bagaimana untuk melaksanakan mekanisme cuba semula permintaan untuk hos tertentu menggunakan Go dan http.Transport?

Dalam sistem pengedaran moden, permintaan rangkaian tidak dapat dielakkan. Kadangkala permintaan yang kami mulakan mungkin gagal disebabkan oleh pelbagai sebab, seperti ketidakstabilan rangkaian, masa henti pelayan, dsb. Untuk memastikan kebolehpercayaan permintaan, kami berharap dapat mencuba semula apabila permintaan itu gagal. Artikel ini akan memperkenalkan cara menggunakan bahasa Go dan http.Transport untuk melaksanakan mekanisme percubaan semula permintaan untuk hos tertentu.

Bahasa Go menyediakan pakej http, yang boleh menghantar dan menerima permintaan rangkaian dengan mudah. Struktur http.Transport digunakan untuk mengurus dan mengawal sambungan klien HTTP, pengalihan semula, proksi dan operasi lain. Kita boleh menetapkan mekanisme cuba semula dalam konfigurasi struktur ini. Seterusnya kami akan menggunakan contoh khusus untuk menunjukkan cara melaksanakan permintaan cuba semula.

Pertama, kami perlu mengimport perpustakaan yang diperlukan:

import (
    "net/http"
    "time"
)

Kemudian, kami mencipta struktur Pengangkutan tersuai:

type CustomTransport struct {
    Transport http.Transport
    RetryCount int // 重试次数
}

func (ct *CustomTransport) RoundTrip(req *http.Request) (*http.Response, error) {
    var resp *http.Response
    var err error

    for i := 0; i <= ct.RetryCount; i++ {
        resp, err = ct.Transport.RoundTrip(req)
        if err == nil || i == ct.RetryCount {
            break
        }
        time.Sleep(time.Second) // 等待1秒后进行重试
    }

    return resp, err
}

Dalam Pengangkutan Tersuai, kami mengatasi kaedah RoundTrip untuk logik percubaan semula permintaan tersuai. Selepas setiap permintaan gagal, kami akan menunggu untuk tempoh masa sebelum mencuba semula, di sini kami menetapkannya kepada 1 saat. Ambil perhatian bahawa kami telah menambah kawalan bilangan maksimum percubaan semula di sini untuk mengelakkan percubaan semula yang tidak terhingga.

Seterusnya, kami menggunakan Pengangkutan tersuai untuk mencipta objek http.Client dan menghantar permintaan rangkaian:

func main() {
    retryCount := 3 // 重试次数

    transport := http.Transport{
        MaxIdleConns:    10,
        IdleConnTimeout: 30 * time.Second,
    }

    client := http.Client{
        Transport: &CustomTransport{
            Transport: transport,
            RetryCount: retryCount,
        },
    }

    req, err := http.NewRequest("GET", "http://example.com", nil)
    if err != nil {
        panic(err)
    }

    resp, err := client.Do(req)
    if err != nil {
        panic(err)
    }

    defer resp.Body.Close()

    // 处理响应结果
    // ...
}

Dalam kod di atas, kami membuat permintaan GET melalui kaedah http.NewRequest dan menetapkan URL yang diminta kepada http: / /example.com. Kemudian, hantar permintaan melalui kaedah klien. Lakukan dan dapatkan respons. Sebelum itu, kami menyerahkan Pengangkutan tersuai ke dalam http.Client untuk melaksanakan mekanisme percubaan semula permintaan untuk hos tertentu.

Pada ketika ini, kami telah melengkapkan contoh penggunaan Go dan http.Transport untuk melaksanakan mekanisme percubaan semula permintaan untuk hos tertentu. Dengan menyesuaikan struktur Pengangkutan, kami boleh mengawal bilangan percubaan semula, selang percubaan semula dan parameter berkaitan permintaan lain secara fleksibel. Dalam pembangunan sebenar, kami boleh membuat penyesuaian yang lebih terperinci mengikut keperluan kami sendiri untuk mencapai permintaan rangkaian yang lebih dipercayai.

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan mekanisme percubaan semula permintaan untuk hos tertentu menggunakan Go dan http.Transport?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!