手把手教你搭建基于 Go kit 的 Http 微服务

本文主要是介绍手把手教你搭建基于 Go kit 的 Http 微服务，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一、项目目录结构设计

实现一个简单的功能：通过http请求用户的uid，返回用户uid对应的name，age和level

Transport层主要负责与传输协议HTTP，GRPC，THRIFT等相关的逻辑
Endpoint层主要负责Request／Response格式的转换，以及公用拦截器相关的逻辑
Service层则专注于业务逻辑，就是我们的业务类、接口等相关信息存放

二、go.mod文件定义

module com.project.gokit-testrequire github.com/go-kit/kit v0.13.0require (github.com/go-kit/log v0.2.0 // indirectgithub.com/go-logfmt/logfmt v0.5.1 // indirect
)go 1.22

然后执行模块初始化

go mod init com.project.gokit-test

三、service层的开发

package servicetype IUserService interface {GetUname(userId int) stringGetUage(userId int) intGetUlevel(userId int) int
}type UserService struct {
}func (s UserService) GetUname(userId int) string {info := map[int]string{1: "zhangsan",}return info[userId]
}func (s UserService) GetUage(userId int) int {info := map[int]int{1: 12,}return info[userId]
}func (s UserService) GetUlevel(userId int) int {info := map[int]int{1: 15,}return info[userId]
}

四、Endpoint层的开发

package endpointimport ("context""com.project.gokit-test/service""github.com/go-kit/kit/endpoint"
)// todo 定义请求格式
type UserRequest struct {Uid int `json:"uid"`
}// todo 定义返回格式
type UserResponse struct {UName  string `json:"uname"`UAge   int    `json:"uage"`ULevel int    `json:"ulevel"`
}func GetUserEndPoint(userService service.IUserService) endpoint.Endpoint {return func(ctx context.Context, request interface{}) (response interface{}, err error) {r := request.(UserRequest)          //todo 获取请求数据name := userService.GetUname(r.Uid) //todo 调用service里面函数进行处理age := userService.GetUage(r.Uid)level := userService.GetUlevel(r.Uid)return UserResponse{UName:  name,UAge:   age,ULevel: level,}, nil //todo 返回响应，整个接受请求到通过service处理请求，最后响应的过程，属于一种Endpoint类型}
}

五、Transport层的开发

package transportimport ("context""encoding/json""errors""net/http""strconv""com.project.gokit-test/endpoint"
)// todo 这一步的作用就是接受参数，然后传递给定义的Request对象，交给Endpoint去处理
func DecodeUserRequest(ctx context.Context, r *http.Request) (interface{}, error) {//todo 相当于从http://127.0.0.1?uid=101 这样获取uid参数if r.URL.Query().Get("uid") != "" {uid, _ := strconv.Atoi(r.URL.Query().Get("uid")) //todo 将一个表示整数的字符串转换为相应的整数值return endpoint.UserRequest{Uid: uid}, nil}return nil, errors.New("参数错误")
}func EncodeUserResponse(ctx context.Context, w http.ResponseWriter, response interface{}) error {w.Header().Set("Content-type", "application/json")return json.NewEncoder(w).Encode(response)
}

六、main.go主函数入口的开发

package mainimport ("net/http""com.project.gokit-test/endpoint""com.project.gokit-test/service""com.project.gokit-test/transport"httpTransport "github.com/go-kit/kit/transport/http"
)func main() {user := service.UserService{}endPoint := endpoint.GetUserEndPoint(user)// 构造服务，实现http.handler并包装endpoint层serverHandler := httpTransport.NewServer(endPoint, transport.DecodeUserRequest, transport.EncodeUserResponse)// 监听端口，并且使用serverHandler处理随之而来的请求_ = http.ListenAndServe(":8080", serverHandler)}

然后终端命令行执行：