错误处理和重试逻辑在 golang 函数与外部 api 交互中至关重要：错误处理：创建自定义错误类型（errors.new()）匹配特定错误（errors.is()）包含原始错误（wrappederrors 库）重试逻辑：实现简单重试（time.sleep()）创建有时间限制的重试（context.withtimeout()）
错误处理和重试逻辑：在 Golang 函数与外部 API 交互中的作用
在 Golang 函数与外部 API 交互时，错误处理和重试逻辑至关重要，可以确保应用即使在错误情况下也能正常运行。
错误处理
立即学习“go语言免费学习笔记（深入）”；
- 使用
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 响应状态代码无效时返回错误。
