错误处理和重试逻辑在 Golang 函数与外部 API 交互中的作用-Golang-PHP中文网

错误处理和重试逻辑在 Golang 函数与外部 API 交互中的作用

WBOY

发布： 2024-09-29 11:30:02

原创

722人浏览过

错误处理和重试逻辑在 golang 函数与外部 api 交互中至关重要：错误处理：创建自定义错误类型（errors.new()）匹配特定错误（errors.is()）包含原始错误（wrappederrors 库）重试逻辑：实现简单重试（time.sleep()）创建有时间限制的重试（context.withtimeout()）

错误处理和重试逻辑在 Golang 函数与外部 API 交互中的作用

错误处理和重试逻辑：在 Golang 函数与外部 API 交互中的作用

在 Golang 函数与外部 API 交互时，错误处理和重试逻辑至关重要，可以确保应用即使在错误情况下也能正常运行。

错误处理

立即学习“go语言免费学习笔记（深入）”；

语鲸

AI智能阅读辅助工具

252

查看详情

使用 errors.New() 创建自定义错误类型：

import "errors"

var ErrNotFound = errors.New("not found")

登录后复制

使用 errors.Is() 匹配特定错误：

if errors.Is(err, ErrNotFound) {
    // 处理找不到的错误
}

登录后复制

使用带 WrappedErrors 的第三方库，如 github.com/jmoiron/sqlx，在错误链中包含原始错误：

import "github.com/jmoiron/sqlx"

db := sqlx.MustOpen("mysql", "user:password@tcp(localhost:3306)/database")

if err := db.Get(nil, "SELECT * FROM users WHERE id = ?", 10); err != nil {
    // 处理由基础 SQL 错误引起的错误
}

登录后复制

重试逻辑

使用 time.Sleep() 函数实现简单的重试：

for i := 0; i < 3; i++ {
    if err := callAPI(); err != nil {
        time.Sleep(100 * time.Millisecond)
        continue
    }

    return nil
}

登录后复制

使用 context.WithTimeout() 创建有时间限制的重试：

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

for {
    if err := callAPI(ctx); err != nil {
        select {
        case <-ctx.Done():
            return err
        default:
            continue
        }
    }

    return nil
}

登录后复制

实战案例

考虑与外部 API 交互的函数 FetchUsers(), 该函数可能会因网络问题或 API 超时而失败。

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

func FetchUsers(w io.Writer) error {
    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    defer cancel()

    req, err := http.NewRequestWithContext(ctx, http.MethodGet, "https://api.example.com/users", nil)
    if err != nil {
        return fmt.Errorf("error creating HTTP request: %w", err)
    }

    resp, err := http.DefaultClient.Do(req)
    if err != nil {
        return fmt.Errorf("error making HTTP request: %w", err)
    }
    defer resp.Body.Close()

    if resp.StatusCode != http.StatusOK {
        return fmt.Errorf("invalid HTTP response status code: %d", resp.StatusCode)
    }

    // 解析 JSON 响应并进行处理
    // ...

    return nil
}

登录后复制

以上示例中，FetchUsers() 函数使用重试逻辑来处理 HTTP 请求可能的错误，并在超时或 HTTP 响应状态代码无效时返回错误。

以上就是错误处理和重试逻辑在 Golang 函数与外部 API 交互中的作用的详细内容，更多请关注php中文网其它相关文章！