Comment utiliser Golang pour implémenter le mécanisme de nouvelle tentative de téléchargement de fichiers HTTP ?

Utilisez Go pour implémenter le mécanisme de nouvelle tentative de téléchargement de fichier HTTP : utilisez la méthode Client.Do() pour envoyer une requête. Attend le nombre de secondes spécifié (retryWaitSeconds) lorsqu'une erreur se produit. Réessayez maxRetries fois. Si le nombre maximum de tentatives est atteint, l'erreur « nombre maximum de tentatives dépassé » est renvoyée.

Comment utiliser Go pour implémenter le mécanisme de nouvelle tentative de téléchargement de fichiers HTTP

Lors de la construction d'un système distribué, la fiabilité du téléchargement de fichiers HTTP est cruciale. Lorsque la connexion réseau est instable ou que le serveur est temporairement indisponible, le mécanisme de nouvelle tentative peut contribuer à garantir que les fichiers sont téléchargés avec succès.

Utilisez Go pour implémenter le mécanisme de nouvelle tentative

Go fournit un package net/http intégré, qui contient le type Client, qui peut être utilisé pour effectuer Requêtes HTTP. Nous pouvons utiliser la méthode Client.Do() pour envoyer une requête et la réessayer si une erreur se produit. net/http 包，其中包含 Client 类型，可用于执行 HTTP 请求。我们可以使用 Client.Do() 方法发送请求，并在发生错误时执行重试操作。

下面是实现重试机制的步骤：

import (
    "context"
    "errors"
    "fmt"
    "io"
    "io/ioutil"
    "net/http"
    "strconv"
    "time"
)

// 重试前等待的时间，单位秒
var retryWaitSeconds = 5

// 最大重试次数
var maxRetries = 3

// UploadFileWithRetry 发送文件并重试失败的请求
func UploadFileWithRetry(ctx context.Context, client *http.Client, url string, file io.Reader) (string, error) {
    var err error

    for i := 0; i <= maxRetries; i++ {
        // 发送请求
        req, err := http.NewRequestWithContext(ctx, http.MethodPost, url, file)
        if err != nil {
            return "", fmt.Errorf("create request: %w", err)
        }

        resp, err := client.Do(req)
        if err != nil {
            if i == maxRetries {
                return "", fmt.Errorf("client do: %w", err)
            }
            time.Sleep(time.Second * time.Duration(retryWaitSeconds))
            continue
        }

        defer resp.Body.Close()

        body, err := ioutil.ReadAll(resp.Body)
        if err != nil {
            return "", fmt.Errorf("read response: %w", err)
        }

        if resp.StatusCode != http.StatusOK {
            if i == maxRetries {
                return "", fmt.Errorf("unexpected response: %s %s", resp.Status, string(body))
            }
            time.Sleep(time.Second * time.Duration(retryWaitSeconds))
            continue
        }

        return string(body), nil
    }

    return "", errors.New("maximum retries exceeded")
}

实战案例

以下是一个使用 UploadFileWithRetry()

Voici les étapes pour mettre en œuvre le mécanisme de nouvelle tentative :

func main() {
    ctx := context.Background()
    client := &http.Client{}
    url := "https://example.com/upload"
    file, err := os.Open("test.txt")
    if err != nil {
        log.Fatal(err)
    }
    defer file.Close()

    body, err := UploadFileWithRetry(ctx, client, url, file)
    if err != nil {
        log.Fatal(err)
    }

    fmt.Println("File uploaded successfully:", body)
}

🎜Cas pratique🎜🎜🎜Voici un exemple d'utilisation de la fonction UploadFileWithRetry() pour télécharger un fichier : 🎜rrreee🎜By Grâce à ce mécanisme de nouvelle tentative, nous sommes en mesure d'améliorer la robustesse des applications en garantissant des téléchargements de fichiers fiables en cas de problèmes de réseau ou de serveur. 🎜

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!