错误处理和重试逻辑在 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 响应状态代码无效时返回错误。
以上就是错误处理和重试逻辑在 Golang 函数与外部 API 交互中的作用的详细内容,更多请关注php中文网其它相关文章!
版权声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系 yyfuon@163.com