在 golang web 应用程序中,处理部分成功错误至关重要:使用自定义错误类型(如 grouperror)收集并处理部分成功的错误。并发执行创建对象的操作,将成功结果收集到一个数组中,并将错误收集到 grouperror 中。如果有错误,则返回带有所有错误信息的 500 internal server error 响应。否则,返回 200 ok 响应及成功的对象。这种解决方案优雅且可扩展,可改善开发人员和最终用户体验。
Go 框架处理部分成功错误的最佳实践
在 Golang Web 应用程序中,错误处理是一个至关重要的方面。框架如何处理部分成功错误对于保持代码干净和可扩展至关重要。
场景:考虑一个同时创建多个对象的 API 端点。如果其中一个对象创建成功,而另一个失败,我们如何优雅地处理此情况?
立即学习“go语言免费学习笔记(深入)”;
实战案例:
package main
import (
"context"
"fmt"
"net/http"
"github.com/go-chi/chi"
"github.com/go-chi/render"
)
// UserService simulates a service that creates user objects.
type UserService struct{}
// CreateUser creates a new user.
func (s *UserService) CreateUser(ctx context.Context, user *User) (*User, error) {
// Create user in database
return &User{}, nil // stub implementation
}
// User represents a user object.
type User struct {
ID int `json:"id"`
Name string `json:"name"`
}
func main() {
r := chi.NewRouter()
r.Post("/users", CreateUserHandler)
http.ListenAndServe(":3000", r)
}
// CreateUserHandler handles the POST /users request.
func CreateUserHandler(w http.ResponseWriter, r *http.Request) {
u := new(User)
if err := render.Bind(r, u); err != nil {
render.Render(w, r, ErrorRenderer(http.StatusUnprocessableEntity, err))
return
}
users := []*User{}
// Create users concurrently
svcs := []func() error{
func() error {
u1, err := UserService{}.CreateUser(r.Context(), u)
if err != nil {
return err
}
users = append(users, u1)
return nil
},
// ... Add more create user callouts here
}
var groupErr GroupError
// Execute create calls concurrently and collect errors
for _, svc := range svcs {
if err := svc(); err != nil {
groupErr.Errors = append(groupErr.Errors, err)
}
}
if len(groupErr.Errors) > 0 {
w.WriteHeader(http.StatusInternalServerError)
render.Render(w, r, ErrorRenderer(http.StatusInternalServerError, &groupErr))
return
}
render.JSON(w, r, users)
}
// ErrorRenderer renders the error response.
func ErrorRenderer(status int, err error) *render.Renderer {
return &render.StatusRenderer{
Status: status,
Render: func(w http.ResponseWriter, r *http.Request) {
render.JSON(w, r, map[string]interface{}{
"status": status,
"message": err.Error(),
})
},
}
}
// GroupError is a custom error type to represent multiple errors.
type GroupError struct {
Errors []error
}
func (ge *GroupError) Error() string {
return fmt.Sprintf("Multiple errors encountered: %s", ge.Errors)
}
在这个例子中,我们使用了一个自定义错误类型 GroupError 来收集部分成功的错误。
- 每个创建用户调用的结果通过并发性被收集到 users 数组。
- 对于失败的调用,错误被收集到 GroupError。
- 如果有错误,API 返回 500 Internal Server Error,其中包含所有错误的详细信息。否则,它返回 200 OK 及其成功的用户对象。
这个解决方案优雅且可扩展,它允许框架优雅地处理部分成功错误,同时保持响应易于理解,从而改善了开发人员体验和最终用户体验。