错误处理和重试逻辑在 函数与外部 api 交互中至关重要：错误处理：创建自定义错误类型（errors.new()）匹配特定错误（errors.is()）包含原始错误（wrappederrors 库）重试逻辑：实现简单重试（time.sleep()）创建有时间限制的重试（context.withtimeout()）
错误处理和重试逻辑：在 Golang 函数与外部 API 交互中的作用
在 Golang 函数与外部 API 交互时，错误处理和重试逻辑至关重要，可以确保应用即使在错误情况下也能正常运行。
错误处理
立即学习“”；
- 使用 errors.New() 创建自定义错误类型：
import "errors" var ErrNotFound = errors.New("not found")
登录后复制
- 使用 errors.Is() 匹配特定错误：
if errors.Is(err, ErrNotFound) { // 处理找不到的错误 }
登录后复制
- 使用带 WrappedErrors 的第三方库，如 hub.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中文网其它相关文章！
微信扫一扫打赏
支付宝扫一扫打赏
