本指南解釋了我如何簡化 Go 微服務(wù)中請(qǐng)求、驗(yàn)證和響應(yīng)的處理，旨在實(shí)現(xiàn)簡單性、可重用性和更易于維護(hù)的代碼庫。
介紹
我在 Go 中使用微服務(wù)已經(jīng)有一段時(shí)間了，我一直很欣賞這種語言提供的清晰度和簡單性。我最喜歡 Go 的事情之一是幕后沒有發(fā)生任何事情；代碼始終是透明且可預(yù)測的。
但是，開發(fā)的某些部分可能非常乏味，尤其是在驗(yàn)證和標(biāo)準(zhǔn)化 API 端點(diǎn)中的響應(yīng)時(shí)。我嘗試了許多不同的方法來解決這個(gè)問題，但最近，在編寫 Go 課程時(shí)，我想到了一個(gè)相當(dāng)意想不到的想法。這個(gè)想法給我的訓(xùn)練員增添了一絲“魔力”，令我驚訝的是，我喜歡它。通過這個(gè)解決方案，我能夠集中請(qǐng)求的驗(yàn)證、解碼和參數(shù)解析的所有邏輯，并統(tǒng)一 API 的編碼和響應(yīng)。最終，我在保持代碼清晰性和減少重復(fù)實(shí)現(xiàn)之間找到了平衡。
問題
開發(fā) Go 微服務(wù)時(shí)，一項(xiàng)常見任務(wù)是有效處理傳入的 HTTP 請(qǐng)求。此過程通常涉及解析請(qǐng)求主體、提取參數(shù)、驗(yàn)證數(shù)據(jù)以及發(fā)回一致的響應(yīng)。讓我用一個(gè)例子來說明這個(gè)問題：
package main
import (
"encoding/json"
"github.com/go-chi/chi/v5"
"github.com/go-chi/chi/v5/middleware"
"github.com/go-playground/validator/v10"
"log"
"net/http"
)
type SampleRequest struct {
Name string `json:"name" validate:"required,min=3"`
Age int `json:"age" validate:"required,min=1"`
}
var validate = validator.New()
type ValidationErrors struct {
Errors map[string][]string `json:"errors"`
}
func main() {
r := chi.NewRouter()
r.Use(middleware.Logger)
r.Use(middleware.Recoverer)
r.Post("/submit/{name}", func(w http.ResponseWriter, r *http.Request) {
sampleReq := &SampleRequest{}
// Set the path parameter
name := chi.URLParam(r, "name")
if name == "" {
w.WriteHeader(http.StatusBadRequest)
json.NewEncoder(w).Encode(map[string]interface{}{
"code": http.StatusBadRequest,
"message": "name is required",
})
return
}
sampleReq.Name = name
// Parse and decode the JSON body
if err := json.NewDecoder(r.Body).Decode(sampleReq); err != nil {
w.WriteHeader(http.StatusBadRequest)
json.NewEncoder(w).Encode(map[string]interface{}{
"code": http.StatusBadRequest,
"message": "Invalid JSON format",
})
return
}
// Validate the request
if err := validate.Struct(sampleReq); err != nil {
validationErrors := make(map[string][]string)
for _, err := range err.(validator.ValidationErrors) {
fieldName := err.Field()
validationErrors[fieldName] = append(validationErrors[fieldName], err.Tag())
}
w.WriteHeader(http.StatusBadRequest)
json.NewEncoder(w).Encode(map[string]interface{}{
"code": http.StatusBadRequest,
"message": "Validation error",
"body": ValidationErrors{Errors: validationErrors},
})
return
}
// Send success response
w.WriteHeader(http.StatusOK)
json.NewEncoder(w).Encode(map[string]interface{}{
"code": http.StatusOK,
"message": "Request received successfully",
"body": sampleReq,
})
})
log.Println("Starting server on :8080")
http.ListenAndServe(":8080", r)
}
讓我解釋一下上面的代碼，重點(diǎn)是我們手動(dòng)處理的處理程序部分：
- 處理路徑參數(shù)：驗(yàn)證所需的路徑參數(shù)是否存在并處理它。
- 解碼請(qǐng)求正文：確保正確解析傳入的 JSON。
- 驗(yàn)證：使用驗(yàn)證器包檢查請(qǐng)求字段是否滿足要求標(biāo)準(zhǔn)。
- 錯(cuò)誤處理：當(dāng)驗(yàn)證失敗或JSON格式錯(cuò)誤時(shí)，用適當(dāng)?shù)腻e(cuò)誤消息響應(yīng)客戶端。
- 一致的響應(yīng)：手動(dòng)構(gòu)建響應(yīng)結(jié)構(gòu)。
雖然代碼有效，但它涉及大量的樣板邏輯，必須為每個(gè)新端點(diǎn)重復(fù)這些邏輯，這使得維護(hù)更加困難并且容易出現(xiàn)不一致。
那么，我們?cè)撊绾胃倪M(jìn)呢？
分解代碼
為了解決這個(gè)問題并提高代碼的可維護(hù)性，我決定將邏輯分為三個(gè)不同的層：請(qǐng)求、響應(yīng)和驗(yàn)證。這種方法封裝了每個(gè)部分的邏輯，使其可重用且更易于獨(dú)立測試。
請(qǐng)求層
Request 層負(fù)責(zé)從傳入的 HTTP 請(qǐng)求中解析和提取數(shù)據(jù)。通過隔離這個(gè)邏輯，我們可以標(biāo)準(zhǔn)化數(shù)據(jù)的處理方式，并確保所有解析得到統(tǒng)一處理。
驗(yàn)證層
驗(yàn)證層僅專注于根據(jù)預(yù)定義規(guī)則驗(yàn)證解析的數(shù)據(jù)。這使驗(yàn)證邏輯與請(qǐng)求處理分開，使其在不同端點(diǎn)之間更易于維護(hù)和重用。
響應(yīng)層
Response 層處理程序響應(yīng)的構(gòu)造和格式化。通過集中響應(yīng)邏輯，我們可以確保所有 API 響應(yīng)遵循一致的結(jié)構(gòu)，從而簡化調(diào)試并改進(jìn)客戶端交互。
所以......雖然將代碼分成層可以帶來諸如可重用性、可測試性和可維護(hù)性之類的好處，但它也帶來了一些權(quán)衡。復(fù)雜性的增加可能會(huì)使新開發(fā)人員更難掌握項(xiàng)目結(jié)構(gòu)，而對(duì)于簡單的端點(diǎn)，使用單獨(dú)的層可能會(huì)讓人感覺過度，可能會(huì)導(dǎo)致過度設(shè)計(jì)。了解這些優(yōu)點(diǎn)和缺點(diǎn)有助于決定何時(shí)有效應(yīng)用此模式。
在一天結(jié)束的時(shí)候，總是關(guān)于最困擾你的事情。正確的？所以，現(xiàn)在讓我們介入我們的舊代碼并開始實(shí)現(xiàn)上面提到的層。
將代碼重構(gòu)為層
第 1 步：創(chuàng)建請(qǐng)求層
首先，我們重構(gòu)代碼，將請(qǐng)求解析封裝到專用的函數(shù)或模塊中。該層僅專注于讀取和解析請(qǐng)求主體，確保其與處理程序中的其他職責(zé)分離。
創(chuàng)建一個(gè)新文件httpsuite/request.go:
package main
import (
"encoding/json"
"github.com/go-chi/chi/v5"
"github.com/go-chi/chi/v5/middleware"
"github.com/go-playground/validator/v10"
"log"
"net/http"
)
type SampleRequest struct {
Name string `json:"name" validate:"required,min=3"`
Age int `json:"age" validate:"required,min=1"`
}
var validate = validator.New()
type ValidationErrors struct {
Errors map[string][]string `json:"errors"`
}
func main() {
r := chi.NewRouter()
r.Use(middleware.Logger)
r.Use(middleware.Recoverer)
r.Post("/submit/{name}", func(w http.ResponseWriter, r *http.Request) {
sampleReq := &SampleRequest{}
// Set the path parameter
name := chi.URLParam(r, "name")
if name == "" {
w.WriteHeader(http.StatusBadRequest)
json.NewEncoder(w).Encode(map[string]interface{}{
"code": http.StatusBadRequest,
"message": "name is required",
})
return
}
sampleReq.Name = name
// Parse and decode the JSON body
if err := json.NewDecoder(r.Body).Decode(sampleReq); err != nil {
w.WriteHeader(http.StatusBadRequest)
json.NewEncoder(w).Encode(map[string]interface{}{
"code": http.StatusBadRequest,
"message": "Invalid JSON format",
})
return
}
// Validate the request
if err := validate.Struct(sampleReq); err != nil {
validationErrors := make(map[string][]string)
for _, err := range err.(validator.ValidationErrors) {
fieldName := err.Field()
validationErrors[fieldName] = append(validationErrors[fieldName], err.Tag())
}
w.WriteHeader(http.StatusBadRequest)
json.NewEncoder(w).Encode(map[string]interface{}{
"code": http.StatusBadRequest,
"message": "Validation error",
"body": ValidationErrors{Errors: validationErrors},
})
return
}
// Send success response
w.WriteHeader(http.StatusOK)
json.NewEncoder(w).Encode(map[string]interface{}{
"code": http.StatusOK,
"message": "Request received successfully",
"body": sampleReq,
})
})
log.Println("Starting server on :8080")
http.ListenAndServe(":8080", r)
}
注意：此時(shí)，我不得不使用反射。也許我太愚蠢了，找不到更好的等待去做。 ？
當(dāng)然，我們也可以測試這個(gè)，創(chuàng)建測試文件httpsuite/request_test.go:
package httpsuite
import (
"encoding/json"
"errors"
"github.com/go-chi/chi/v5"
"net/http"
"reflect"
)
// RequestParamSetter defines the interface used to set the parameters to the HTTP request object by the request parser.
// Implementing this interface allows custom handling of URL parameters.
type RequestParamSetter interface {
// SetParam assigns a value to a specified field in the request struct.
// The fieldName parameter is the name of the field, and value is the value to set.
SetParam(fieldName, value string) error
}
// ParseRequest parses the incoming HTTP request into a specified struct type, handling JSON decoding and URL parameters.
// It validates the parsed request and returns it along with any potential errors.
// The pathParams variadic argument allows specifying URL parameters to be extracted.
// If an error occurs during parsing, validation, or parameter setting, it responds with an appropriate HTTP status.
func ParseRequest[T RequestParamSetter](w http.ResponseWriter, r *http.Request, pathParams ...string) (T, error) {
var request T
var empty T
defer func() {
_ = r.Body.Close()
}()
if r.Body != http.NoBody {
if err := json.NewDecoder(r.Body).Decode(&request); err != nil {
SendResponse[any](w, "Invalid JSON format", http.StatusBadRequest, nil)
return empty, err
}
}
// If body wasn't parsed request may be nil and cause problems ahead
if isRequestNil(request) {
request = reflect.New(reflect.TypeOf(request).Elem()).Interface().(T)
}
// Parse URL parameters
for _, key := range pathParams {
value := chi.URLParam(r, key)
if value == "" {
SendResponse[any](w, "Parameter "+key+" not found in request", http.StatusBadRequest, nil)
return empty, errors.New("missing parameter: " + key)
}
if err := request.SetParam(key, value); err != nil {
SendResponse[any](w, "Failed to set field "+key, http.StatusInternalServerError, nil)
return empty, err
}
}
// Validate the combined request struct
if validationErr := IsRequestValid(request); validationErr != nil {
SendResponse[ValidationErrors](w, "Validation error", http.StatusBadRequest, validationErr)
return empty, errors.New("validation error")
}
return request, nil
}
func isRequestNil(i interface{}) bool {
return i == nil || (reflect.ValueOf(i).Kind() == reflect.Ptr && reflect.ValueOf(i).IsNil())
}
如您所見，請(qǐng)求層使用驗(yàn)證層。然而，我仍然希望在代碼中保持層的分離，不僅是為了更容易維護(hù)，而且因?yàn)槲铱赡苓€想使用隔離的驗(yàn)證層。
根據(jù)需要，將來我可能會(huì)決定將所有層保持隔離，并通過使用一些接口來允許其相互依賴。
第 2 步：實(shí)現(xiàn)驗(yàn)證層
一旦請(qǐng)求解析被分離，我們就創(chuàng)建一個(gè)獨(dú)立的驗(yàn)證函數(shù)或模塊來處理驗(yàn)證邏輯。通過隔離此邏輯，我們可以輕松測試它并跨多個(gè)端點(diǎn)應(yīng)用一致的驗(yàn)證規(guī)則。
為此，我們創(chuàng)建 httpsuite/validation.go 文件：
package main
import (
"encoding/json"
"github.com/go-chi/chi/v5"
"github.com/go-chi/chi/v5/middleware"
"github.com/go-playground/validator/v10"
"log"
"net/http"
)
type SampleRequest struct {
Name string `json:"name" validate:"required,min=3"`
Age int `json:"age" validate:"required,min=1"`
}
var validate = validator.New()
type ValidationErrors struct {
Errors map[string][]string `json:"errors"`
}
func main() {
r := chi.NewRouter()
r.Use(middleware.Logger)
r.Use(middleware.Recoverer)
r.Post("/submit/{name}", func(w http.ResponseWriter, r *http.Request) {
sampleReq := &SampleRequest{}
// Set the path parameter
name := chi.URLParam(r, "name")
if name == "" {
w.WriteHeader(http.StatusBadRequest)
json.NewEncoder(w).Encode(map[string]interface{}{
"code": http.StatusBadRequest,
"message": "name is required",
})
return
}
sampleReq.Name = name
// Parse and decode the JSON body
if err := json.NewDecoder(r.Body).Decode(sampleReq); err != nil {
w.WriteHeader(http.StatusBadRequest)
json.NewEncoder(w).Encode(map[string]interface{}{
"code": http.StatusBadRequest,
"message": "Invalid JSON format",
})
return
}
// Validate the request
if err := validate.Struct(sampleReq); err != nil {
validationErrors := make(map[string][]string)
for _, err := range err.(validator.ValidationErrors) {
fieldName := err.Field()
validationErrors[fieldName] = append(validationErrors[fieldName], err.Tag())
}
w.WriteHeader(http.StatusBadRequest)
json.NewEncoder(w).Encode(map[string]interface{}{
"code": http.StatusBadRequest,
"message": "Validation error",
"body": ValidationErrors{Errors: validationErrors},
})
return
}
// Send success response
w.WriteHeader(http.StatusOK)
json.NewEncoder(w).Encode(map[string]interface{}{
"code": http.StatusOK,
"message": "Request received successfully",
"body": sampleReq,
})
})
log.Println("Starting server on :8080")
http.ListenAndServe(":8080", r)
}
現(xiàn)在，創(chuàng)建測試文件httpsuite/validation_test.go:
package httpsuite
import (
"encoding/json"
"errors"
"github.com/go-chi/chi/v5"
"net/http"
"reflect"
)
// RequestParamSetter defines the interface used to set the parameters to the HTTP request object by the request parser.
// Implementing this interface allows custom handling of URL parameters.
type RequestParamSetter interface {
// SetParam assigns a value to a specified field in the request struct.
// The fieldName parameter is the name of the field, and value is the value to set.
SetParam(fieldName, value string) error
}
// ParseRequest parses the incoming HTTP request into a specified struct type, handling JSON decoding and URL parameters.
// It validates the parsed request and returns it along with any potential errors.
// The pathParams variadic argument allows specifying URL parameters to be extracted.
// If an error occurs during parsing, validation, or parameter setting, it responds with an appropriate HTTP status.
func ParseRequest[T RequestParamSetter](w http.ResponseWriter, r *http.Request, pathParams ...string) (T, error) {
var request T
var empty T
defer func() {
_ = r.Body.Close()
}()
if r.Body != http.NoBody {
if err := json.NewDecoder(r.Body).Decode(&request); err != nil {
SendResponse[any](w, "Invalid JSON format", http.StatusBadRequest, nil)
return empty, err
}
}
// If body wasn't parsed request may be nil and cause problems ahead
if isRequestNil(request) {
request = reflect.New(reflect.TypeOf(request).Elem()).Interface().(T)
}
// Parse URL parameters
for _, key := range pathParams {
value := chi.URLParam(r, key)
if value == "" {
SendResponse[any](w, "Parameter "+key+" not found in request", http.StatusBadRequest, nil)
return empty, errors.New("missing parameter: " + key)
}
if err := request.SetParam(key, value); err != nil {
SendResponse[any](w, "Failed to set field "+key, http.StatusInternalServerError, nil)
return empty, err
}
}
// Validate the combined request struct
if validationErr := IsRequestValid(request); validationErr != nil {
SendResponse[ValidationErrors](w, "Validation error", http.StatusBadRequest, validationErr)
return empty, errors.New("validation error")
}
return request, nil
}
func isRequestNil(i interface{}) bool {
return i == nil || (reflect.ValueOf(i).Kind() == reflect.Ptr && reflect.ValueOf(i).IsNil())
}
第 3 步：構(gòu)建響應(yīng)層
最后，我們將響應(yīng)構(gòu)造重構(gòu)為一個(gè)單獨(dú)的模塊。這可確保所有響應(yīng)遵循一致的格式，從而更輕松地管理和調(diào)試整個(gè)應(yīng)用程序中的響應(yīng)。
創(chuàng)建文件httpsuite/response.go:
package httpsuite
import (
"bytes"
"context"
"encoding/json"
"errors"
"fmt"
"github.com/go-chi/chi/v5"
"github.com/stretchr/testify/assert"
"log"
"net/http"
"net/http/httptest"
"strconv"
"strings"
"testing"
)
// TestRequest includes custom type annotation for UUID
type TestRequest struct {
ID int `json:"id" validate:"required"`
Name string `json:"name" validate:"required"`
}
func (r *TestRequest) SetParam(fieldName, value string) error {
switch strings.ToLower(fieldName) {
case "id":
id, err := strconv.Atoi(value)
if err != nil {
return errors.New("invalid id")
}
r.ID = id
default:
log.Printf("Parameter %s cannot be set", fieldName)
}
return nil
}
func Test_ParseRequest(t *testing.T) {
testSetURLParam := func(r *http.Request, fieldName, value string) *http.Request {
ctx := chi.NewRouteContext()
ctx.URLParams.Add(fieldName, value)
return r.WithContext(context.WithValue(r.Context(), chi.RouteCtxKey, ctx))
}
type args struct {
w http.ResponseWriter
r *http.Request
pathParams []string
}
type testCase[T any] struct {
name string
args args
want *TestRequest
wantErr assert.ErrorAssertionFunc
}
tests := []testCase[TestRequest]{
{
name: "Successful Request",
args: args{
w: httptest.NewRecorder(),
r: func() *http.Request {
body, _ := json.Marshal(TestRequest{Name: "Test"})
req := httptest.NewRequest("POST", "/test/123", bytes.NewBuffer(body))
req = testSetURLParam(req, "ID", "123")
req.Header.Set("Content-Type", "application/json")
return req
}(),
pathParams: []string{"ID"},
},
want: &TestRequest{ID: 123, Name: "Test"},
wantErr: assert.NoError,
},
{
name: "Missing body",
args: args{
w: httptest.NewRecorder(),
r: func() *http.Request {
req := httptest.NewRequest("POST", "/test/123", nil)
req = testSetURLParam(req, "ID", "123")
req.Header.Set("Content-Type", "application/json")
return req
}(),
pathParams: []string{"ID"},
},
want: nil,
wantErr: assert.Error,
},
{
name: "Missing Path Parameter",
args: args{
w: httptest.NewRecorder(),
r: func() *http.Request {
req := httptest.NewRequest("POST", "/test", nil)
req.Header.Set("Content-Type", "application/json")
return req
}(),
pathParams: []string{"ID"},
},
want: nil,
wantErr: assert.Error,
},
{
name: "Invalid JSON Body",
args: args{
w: httptest.NewRecorder(),
r: func() *http.Request {
req := httptest.NewRequest("POST", "/test/123", bytes.NewBufferString("{invalid-json}"))
req = testSetURLParam(req, "ID", "123")
req.Header.Set("Content-Type", "application/json")
return req
}(),
pathParams: []string{"ID"},
},
want: nil,
wantErr: assert.Error,
},
{
name: "Validation Error for body",
args: args{
w: httptest.NewRecorder(),
r: func() *http.Request {
body, _ := json.Marshal(TestRequest{})
req := httptest.NewRequest("POST", "/test/123", bytes.NewBuffer(body))
req = testSetURLParam(req, "ID", "123")
req.Header.Set("Content-Type", "application/json")
return req
}(),
pathParams: []string{"ID"},
},
want: nil,
wantErr: assert.Error,
},
{
name: "Validation Error for zero ID",
args: args{
w: httptest.NewRecorder(),
r: func() *http.Request {
body, _ := json.Marshal(TestRequest{Name: "Test"})
req := httptest.NewRequest("POST", "/test/0", bytes.NewBuffer(body))
req = testSetURLParam(req, "ID", "0")
req.Header.Set("Content-Type", "application/json")
return req
}(),
pathParams: []string{"ID"},
},
want: nil,
wantErr: assert.Error,
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
got, err := ParseRequest[*TestRequest](tt.args.w, tt.args.r, tt.args.pathParams...)
if !tt.wantErr(t, err, fmt.Sprintf("parseRequest(%v, %v, %v)", tt.args.w, tt.args.r, tt.args.pathParams)) {
return
}
assert.Equalf(t, tt.want, got, "parseRequest(%v, %v, %v)", tt.args.w, tt.args.r, tt.args.pathParams)
})
}
}
創(chuàng)建測試文件httpsuite/response_test.go:
package httpsuite
import (
"errors"
"github.com/go-playground/validator/v10"
)
// ValidationErrors represents a collection of validation errors for an HTTP request.
type ValidationErrors struct {
Errors map[string][]string `json:"errors,omitempty"`
}
// NewValidationErrors creates a new ValidationErrors instance from a given error.
// It extracts field-specific validation errors and maps them for structured output.
func NewValidationErrors(err error) *ValidationErrors {
var validationErrors validator.ValidationErrors
errors.As(err, &validationErrors)
fieldErrors := make(map[string][]string)
for _, vErr := range validationErrors {
fieldName := vErr.Field()
fieldError := fieldName + " " + vErr.Tag()
fieldErrors[fieldName] = append(fieldErrors[fieldName], fieldError)
}
return &ValidationErrors{Errors: fieldErrors}
}
// IsRequestValid validates the provided request struct using the go-playground/validator package.
// It returns a ValidationErrors instance if validation fails, or nil if the request is valid.
func IsRequestValid(request any) *ValidationErrors {
validate := validator.New(validator.WithRequiredStructEnabled())
err := validate.Struct(request)
if err != nil {
return NewValidationErrors(err)
}
return nil
}
此重構(gòu)的每一步都允許我們通過將特定職責(zé)委托給定義良好的層來簡化處理程序邏輯。雖然我不會(huì)在每個(gè)步驟中顯示完整的代碼，但這些更改涉及將解析、驗(yàn)證和響應(yīng)邏輯移動(dòng)到各自的函數(shù)或文件中。
重構(gòu)示例代碼
現(xiàn)在，我們需要更改舊代碼以使用圖層，讓我們看看它會(huì)是什么樣子。
package httpsuite
import (
"github.com/go-playground/validator/v10"
"testing"
"github.com/stretchr/testify/assert"
)
type TestValidationRequest struct {
Name string `validate:"required"`
Age int `validate:"required,min=18"`
}
func TestNewValidationErrors(t *testing.T) {
validate := validator.New()
request := TestValidationRequest{} // Missing required fields to trigger validation errors
err := validate.Struct(request)
if err == nil {
t.Fatal("Expected validation errors, but got none")
}
validationErrors := NewValidationErrors(err)
expectedErrors := map[string][]string{
"Name": {"Name required"},
"Age": {"Age required"},
}
assert.Equal(t, expectedErrors, validationErrors.Errors)
}
func TestIsRequestValid(t *testing.T) {
tests := []struct {
name string
request TestValidationRequest
expectedErrors *ValidationErrors
}{
{
name: "Valid request",
request: TestValidationRequest{Name: "Alice", Age: 25},
expectedErrors: nil, // No errors expected for valid input
},
{
name: "Missing Name and Age below minimum",
request: TestValidationRequest{Age: 17},
expectedErrors: &ValidationErrors{
Errors: map[string][]string{
"Name": {"Name required"},
"Age": {"Age min"},
},
},
},
{
name: "Missing Age",
request: TestValidationRequest{Name: "Alice"},
expectedErrors: &ValidationErrors{
Errors: map[string][]string{
"Age": {"Age required"},
},
},
},
}
for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
errs := IsRequestValid(tt.request)
if tt.expectedErrors == nil {
assert.Nil(t, errs)
} else {
assert.NotNil(t, errs)
assert.Equal(t, tt.expectedErrors.Errors, errs.Errors)
}
})
}
}
通過將處理程序代碼重構(gòu)為請(qǐng)求解析、驗(yàn)證和響應(yīng)格式化層，我們成功刪除了之前嵌入處理程序本身的重復(fù)邏輯。這種模塊化方法不僅提高了可讀性，而且通過保持每個(gè)職責(zé)的重點(diǎn)和可重用性來增強(qiáng)可維護(hù)性和可測試性。現(xiàn)在，處理程序已得到簡化，開發(fā)人員可以輕松理解和修改特定層，而不會(huì)影響整個(gè)流程，從而創(chuàng)建更清晰、更具可擴(kuò)展性的代碼庫。
結(jié)論
我希望這份關(guān)于使用專用請(qǐng)求、驗(yàn)證和響應(yīng)層構(gòu)建 Go 微服務(wù)的分步指南能夠?yàn)閯?chuàng)建更清晰、更可維護(hù)的代碼提供深入見解。我很想聽聽您對(duì)這種方法的想法。我錯(cuò)過了什么重要的事情嗎？您將如何在自己的項(xiàng)目中擴(kuò)展或改進(jìn)這個(gè)想法？
我鼓勵(lì)您探索源代碼并直接在項(xiàng)目中使用httpsuite。您可以在 rluders/httpsuite 存儲(chǔ)庫中找到該庫。您的反饋和貢獻(xiàn)對(duì)于使這個(gè)庫對(duì) Go 社區(qū)更加強(qiáng)大和有用來說非常寶貴。
大家下期見。
以上是改進(jìn) Go 微服務(wù)中的請(qǐng)求、驗(yàn)證和響應(yīng)處理的詳細(xì)內(nèi)容。更多信息請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！
熱AI工具
Undress AI Tool
免費(fèi)脫衣服圖片
Undresser.AI Undress
人工智能驅(qū)動(dòng)的應(yīng)用程序，用于創(chuàng)建逼真的裸體照片
AI Clothes Remover
用于從照片中去除衣服的在線人工智能工具。
Clothoff.io
AI脫衣機(jī)
Video Face Swap
使用我們完全免費(fèi)的人工智能換臉工具輕松在任何視頻中換臉！
熱門文章
熱工具
記事本++7.3.1
好用且免費(fèi)的代碼編輯器
SublimeText3漢化版
中文版，非常好用
禪工作室 13.0.1
功能強(qiáng)大的PHP集成開發(fā)環(huán)境
Dreamweaver CS6
視覺化網(wǎng)頁開發(fā)工具
SublimeText3 Mac版
神級(jí)代碼編輯軟件(SublimeText3)
是Golang前端還是后端
Jul 08, 2025 am 01:44 AM
Golang主要用于后端開發(fā)，但也能在前端領(lǐng)域間接發(fā)揮作用。其設(shè)計(jì)目標(biāo)聚焦高性能、并發(fā)處理和系統(tǒng)級(jí)編程，適合構(gòu)建API服務(wù)器、微服務(wù)、分布式系統(tǒng)、數(shù)據(jù)庫操作及CLI工具等后端應(yīng)用。雖然Golang不是網(wǎng)頁前端的主流語言，但可通過GopherJS編譯成JavaScript、通過TinyGo運(yùn)行于WebAssembly，或搭配模板引擎生成HTML頁面來參與前端開發(fā)。然而，現(xiàn)代前端開發(fā)仍需依賴JavaScript/TypeScript及其生態(tài)。因此，Golang更適合以高性能后端為核心的技術(shù)棧選擇。
如何在Golang中構(gòu)建GraphQl API
Jul 08, 2025 am 01:03 AM
要構(gòu)建一個(gè)GraphQLAPI在Go語言中，推薦使用gqlgen庫以提高開發(fā)效率。1.首先選擇合適的庫，如gqlgen，它支持根據(jù)schema自動(dòng)生成代碼；2.接著定義GraphQLschema，描述API的結(jié)構(gòu)和查詢?nèi)肟?，如定義Post類型和查詢方法；3.然后初始化項(xiàng)目并生成基礎(chǔ)代碼，實(shí)現(xiàn)resolver中的業(yè)務(wù)邏輯；4.最后將GraphQLhandler接入HTTPserver，通過內(nèi)置Playground測試API。注意事項(xiàng)包括字段命名規(guī)范、錯(cuò)誤處理、性能優(yōu)化及安全設(shè)置等，確保項(xiàng)目可維護(hù)性
如何安裝去
Jul 09, 2025 am 02:37 AM
安裝Go的關(guān)鍵在于選擇正確版本、配置環(huán)境變量并驗(yàn)證安裝。1.前往官網(wǎng)下載對(duì)應(yīng)系統(tǒng)的安裝包，Windows使用.msi文件，macOS使用.pkg文件，Linux使用.tar.gz文件并解壓至/usr/local目錄；2.配置環(huán)境變量，在Linux/macOS中編輯~/.bashrc或~/.zshrc添加PATH和GOPATH，Windows則在系統(tǒng)屬性中設(shè)置PATH為Go的安裝路徑；3.使用goversion命令驗(yàn)證安裝，并運(yùn)行測試程序hello.go確認(rèn)編譯執(zhí)行正常。整個(gè)流程中PATH設(shè)置和環(huán)
Go Sync.WaitGroup示例
Jul 09, 2025 am 01:48 AM
sync.WaitGroup用于等待一組goroutine完成任務(wù)，其核心是通過Add、Done、Wait三個(gè)方法協(xié)同工作。1.Add(n)設(shè)置需等待的goroutine數(shù)量；2.Done()在每個(gè)goroutine結(jié)束時(shí)調(diào)用，計(jì)數(shù)減一；3.Wait()阻塞主協(xié)程直到所有任務(wù)完成。使用時(shí)需注意：Add應(yīng)在goroutine外調(diào)用、避免重復(fù)Wait、務(wù)必確保Done被調(diào)用，推薦配合defer使用。常見于并發(fā)抓取網(wǎng)頁、批量數(shù)據(jù)處理等場景，能有效控制并發(fā)流程。
去嵌入軟件包教程
Jul 09, 2025 am 02:46 AM
使用Go的embed包可以方便地將靜態(tài)資源嵌入二進(jìn)制，適合Web服務(wù)打包HTML、CSS、圖片等文件。1.聲明嵌入資源需在變量前加//go:embed注釋，如嵌入單個(gè)文件hello.txt；2.可嵌入整個(gè)目錄如static/*，通過embed.FS實(shí)現(xiàn)多文件打包；3.開發(fā)時(shí)建議通過buildtag或環(huán)境變量切換磁盤加載模式以提高效率；4.注意路徑正確性、文件大小限制及嵌入資源的只讀特性。合理使用embed能簡化部署并優(yōu)化項(xiàng)目結(jié)構(gòu)。
進(jìn)行音頻/視頻處理
Jul 20, 2025 am 04:14 AM
音視頻處理的核心在于理解基本流程與優(yōu)化方法。1.其基本流程包括采集、編碼、傳輸、解碼和播放，每個(gè)環(huán)節(jié)均有技術(shù)難點(diǎn)；2.常見問題如音畫不同步、卡頓延遲、聲音噪音、畫面模糊等，可通過同步調(diào)整、編碼優(yōu)化、降噪模塊、參數(shù)調(diào)節(jié)等方式解決；3.推薦使用FFmpeg、OpenCV、WebRTC、GStreamer等工具實(shí)現(xiàn)功能；4.性能管理方面應(yīng)注重硬件加速、合理設(shè)置分辨率幀率、控制并發(fā)及內(nèi)存泄漏問題。掌握這些關(guān)鍵點(diǎn)有助于提升開發(fā)效率和用戶體驗(yàn)。
如何在GO中構(gòu)建Web服務(wù)器
Jul 15, 2025 am 03:05 AM
搭建一個(gè)用Go編寫的Web服務(wù)器并不難，核心在于利用net/http包實(shí)現(xiàn)基礎(chǔ)服務(wù)。1.使用net/http啟動(dòng)最簡服務(wù)器：通過幾行代碼注冊(cè)處理函數(shù)并監(jiān)聽端口；2.路由管理：使用ServeMux組織多個(gè)接口路徑，便于結(jié)構(gòu)化管理；3.常見做法：按功能模塊分組路由，并可用第三方庫支持復(fù)雜匹配；4.靜態(tài)文件服務(wù)：通過http.FileServer提供HTML、CSS和JS文件；5.性能與安全：啟用HTTPS、限制請(qǐng)求體大小、設(shè)置超時(shí)時(shí)間以提升安全性與性能。掌握這些要點(diǎn)后，擴(kuò)展功能將更加容易。
使用默認(rèn)情況選擇
Jul 14, 2025 am 02:54 AM
select加default的作用是讓select在沒有其他分支就緒時(shí)執(zhí)行默認(rèn)行為，避免程序阻塞。1.非阻塞地從channel接收數(shù)據(jù)時(shí)，若channel為空，會(huì)直接進(jìn)入default分支；2.結(jié)合time.After或ticker定時(shí)嘗試發(fā)送數(shù)據(jù)，若channel滿則不阻塞而跳過；3.防止死鎖，在不確定channel是否被關(guān)閉時(shí)避免程序卡住；使用時(shí)需注意default分支會(huì)立即執(zhí)行，不能濫用，且default與case互斥，不會(huì)同時(shí)執(zhí)行。
