在Go Kit中，如果你想讀取未序列化的HTTP請求體，可以使用標(biāo)準(zhǔn)的net/http包來實(shí)現(xiàn)。以下是一個示例，演示了如何完成這個任務(wù)：iON28資訊網(wǎng)——每日最新資訊28at.com

package mainimport (	"context"	"encoding/json"	"errors"	"fmt"	"io/ioutil"	"net/http"	"github.com/go-kit/kit/transport/http")func main() {	http.Handle("/your-endpoint", http.NewServer(		yourEndpoint,		decodeRequest,		encodeResponse,	))}// 請求和響應(yīng)類型type YourRequest struct {	// 定義你的請求結(jié)構(gòu)	// ...}type YourResponse struct {	// 定義你的響應(yīng)結(jié)構(gòu)	// ...}// 你的端點(diǎn)邏輯func yourEndpoint(ctx context.Context, request interface{}) (interface{}, error) {	// 獲取原始請求體	rawBody, ok := request.(json.RawMessage)	if !ok {		return nil, errors.New("無法訪問原始請求體")	}	// 根據(jù)需要處理原始請求體	fmt.Println("原始請求體:", string(rawBody))	// 你的實(shí)際端點(diǎn)邏輯在這里	// ...	// 返回響應(yīng)（示例響應(yīng)）	return YourResponse{Message: "請求成功處理"}, nil}// 請求解碼器以獲取原始請求體func decodeRequest(_ context.Context, r *http.Request) (interface{}, error) {	// 讀取原始請求體	body, err := ioutil.ReadAll(r.Body)	if err != nil {		return nil, err	}	// 將原始請求體作為json.RawMessage返回	return json.RawMessage(body), nil}// 響應(yīng)編碼器func encodeResponse(_ context.Context, w http.ResponseWriter, response interface{}) error {	return json.NewEncoder(w).Encode(response)}

在這個例子中：iON28資訊網(wǎng)——每日最新資訊28at.com

• decodeRequest 函數(shù)使用 ioutil.ReadAll 讀取原始的HTTP請求體，然后將其作為 json.RawMessage 返回。
• 在 yourEndpoint 函數(shù)中，通過將請求類型斷言為 json.RawMessage，你可以訪問原始的請求體，然后根據(jù)需要處理它。
• 代碼的其余部分設(shè)置了一個基本的Go Kit HTTP服務(wù)器，包括你的端點(diǎn)、請求解碼和響應(yīng)編碼邏輯。

記得用你實(shí)際的請求和響應(yīng)類型，以及你的用例需要的處理邏輯替換占位符類型和端點(diǎn)邏輯。iON28資訊網(wǎng)——每日最新資訊28at.com

示例

package mainimport (	"context"	"encoding/json"	"fmt"	"net/http"	"github.com/go-kit/kit/endpoint"	"github.com/go-kit/kit/log"	"github.com/go-kit/kit/transport/http")// 表示請求負(fù)載的結(jié)構(gòu)體type Request struct {	Message string `json:"message"`}// 表示響應(yīng)負(fù)載的結(jié)構(gòu)體type Response struct {	Result string `json:"result"`}func main() {	// 創(chuàng)建一個簡單的Go Kit服務(wù)	var svc MyService	endpoint := makeUppercaseEndpoint(&svc)	// 創(chuàng)建一個Go Kit HTTP傳輸	httpHandler := http.NewServer(		endpoint,		decodeRequest,		encodeResponse,	)	// 啟動HTTP服務(wù)器	http.ListenAndServe(":8080", httpHandler)}// MyService是一個只有一個方法的簡單服務(wù)type MyService struct{}// Uppercase是MyService上的一個方法func (MyService) Uppercase(ctx context.Context, message string) (string, error) {	return fmt.Sprintf("接收到消息：%s", message), nil}// makeUppercaseEndpoint是創(chuàng)建Uppercase方法的Go Kit端點(diǎn)的輔助函數(shù)func makeUppercaseEndpoint(svc MyService) endpoint.Endpoint {	return func(ctx context.Context, request interface{}) (interface{}, error) {		req := request.(Request)		result, err := svc.Uppercase(ctx, req.Message)		return Response{Result: result}, err	}}// decodeRequest是解碼傳入JSON請求的輔助函數(shù)func decodeRequest(_ context.Context, r *http.Request) (interface{}, error) {	var request Request	if err := json.NewDecoder(r.Body).Decode(&request); err != nil {		return nil, err	}	return request, nil}// encodeResponse是編碼傳出JSON響應(yīng)的輔助函數(shù)func encodeResponse(_ context.Context, w http.ResponseWriter, response interface{}) error {	return json.NewEncoder(w).Encode(response)}

在這個例子中，decodeRequest 函數(shù)是一個解碼傳入JSON請求的輔助函數(shù)，makeUppercaseEndpoint 函數(shù)是一個創(chuàng)建Uppercase方法的Go Kit端點(diǎn)的輔助函數(shù)。這個示例演示了如何使用Go Kit處理HTTP請求和響應(yīng)。記得根據(jù)你的具體用例和要求對其進(jìn)行調(diào)整。iON28資訊網(wǎng)——每日最新資訊28at.com

本文鏈接：http://www.tebozhan.com/showinfo-26-37269-0.htmlGo Kit中讀取原始HTTP請求體的方法，你學(xué)會了嗎？

聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。郵件：2376512515@qq.com

上一篇： Python的函數(shù)遞歸與調(diào)用，你會嗎？

下一篇： 五個殺手級IntelliJ IDEA插件