golang的框架如何处理部分成功的错误？-码农资源网

正文概述

在 golang web 应用程序中，处理部分成功错误至关重要：使用自定义错误类型（如 grouperror）收集并处理部分成功的错误。并发执行创建对象的操作，将成功结果收集到一个数组中，并将错误收集到 grouperror 中。如果有错误，则返回带有所有错误信息的 500 internal server error 响应。否则，返回 200 ok 响应及成功的对象。这种解决方案优雅且可扩展，可改善开发人员和最终用户体验。

golang的框架如何处理部分成功的错误？

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 来收集部分成功的错误。