登录
首页 >  Golang >  Go教程

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

时间:2024-10-26 17:53:01 303浏览 收藏

本篇文章主要是结合我之前面试的各种经历和实战开发中遇到的问题解决经验整理的,希望这篇《错误处理和重试逻辑在 Golang 函数与外部 API 交互中的作用》对你有很大帮助!欢迎收藏,分享给更多的需要的朋友学习~

错误处理和重试逻辑在 Golang 函数与外部 API 交互中至关重要:错误处理:创建自定义错误类型(errors.New())匹配特定错误(errors.Is())包含原始错误(WrappedErrors 库)重试逻辑:实现简单重试(time.Sleep())创建有时间限制的重试(context.WithTimeout())

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

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

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

错误处理

  • 使用 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 交互中的作用》的介绍应该让你收获多多了吧!欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识,快来关注吧!

相关阅读
更多>
最新阅读
更多>
课程推荐
更多>