在Go Kit中，如果你想讀取未序列化的HTTP請求體，可以使用標準的net/http包來實現(xiàn)。以下是一個示例，演示了如何完成這個任務：

公司主營業(yè)務：成都網(wǎng)站制作、成都網(wǎng)站建設、移動網(wǎng)站開發(fā)等業(yè)務。幫助企業(yè)客戶真正實現(xiàn)互聯(lián)網(wǎng)宣傳，提高企業(yè)的競爭能力。成都創(chuàng)新互聯(lián)公司是一支青春激揚、勤奮敬業(yè)、活力青春激揚、勤奮敬業(yè)、活力澎湃、和諧高效的團隊。公司秉承以“開放、自由、嚴謹、自律”為核心的企業(yè)文化，感謝他們對我們的高要求，感謝他們從不同領域給我們帶來的挑戰(zhàn)，讓我們激情的團隊有機會用頭腦與智慧不斷的給客戶帶來驚喜。成都創(chuàng)新互聯(lián)公司推出扎賚特免費做網(wǎng)站回饋大家。

package main

import (
	"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,
	))
}

// 請求和響應類型
type YourRequest struct {
	// 定義你的請求結構
	// ...
}

type YourResponse struct {
	// 定義你的響應結構
	// ...
}

// 你的端點邏輯
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))

	// 你的實際端點邏輯在這里
	// ...

	// 返回響應（示例響應）
	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
}

// 響應編碼器
func encodeResponse(_ context.Context, w http.ResponseWriter, response interface{}) error {
	return json.NewEncoder(w).Encode(response)
}

在這個例子中：

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

記得用你實際的請求和響應類型，以及你的用例需要的處理邏輯替換占位符類型和端點邏輯。

示例

package main

import (
	"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"
)

// 表示請求負載的結構體
type Request struct {
	Message string `json:"message"`
}

// 表示響應負載的結構體
type Response struct {
	Result string `json:"result"`
}

func main() {
	// 創(chuàng)建一個簡單的Go Kit服務
	var svc MyService
	endpoint := makeUppercaseEndpoint(&svc)

	// 創(chuàng)建一個Go Kit HTTP傳輸
	httpHandler := http.NewServer(
		endpoint,
		decodeRequest,
		encodeResponse,
	)

	// 啟動HTTP服務器
	http.ListenAndServe(":8080", httpHandler)
}

// MyService是一個只有一個方法的簡單服務
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端點的輔助函數(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響應的輔助函數(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端點的輔助函數(shù)。這個示例演示了如何使用Go Kit處理HTTP請求和響應。記得根據(jù)你的具體用例和要求對其進行調整。

文章名稱：Go Kit中讀取原始HTTP請求體的方法，你學會了嗎？
文章位置：http://uogjgqi.cn/article/cdespho.html