[Golang] go-kit 介绍和使用 (微服务实现工具)

2024-06-17 05:28

本文主要是介绍[Golang] go-kit 介绍和使用 (微服务实现工具),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

文章目录

      • 1.go-kit 介绍
        • 1.1 go-kit 三层结构
      • 2.go-kit 实例

1.go-kit 介绍

go-kit是一个分布式的开发工具集,在大型的组织(业务)中可以用来构建微服务,其解决了分布式系统中大多数常见问题,因此,使用者可以将精力集中在业务逻辑上。

他里面有用来帮助我们实现微服务的一些工具包, 和SpringBoot不同, 直接把框架搭好, 而需要手动的搭框架。go-kit 也存在3层架构。

微服务就是一个大项目中的一个小功能块,并且这个功能块可以不计语言差别的和其他功能模块通过API进行通讯和结合。

1.1 go-kit 三层结构

go-kit和SSM中的MVC一样也有三层结构endpoint,service, transport,通过这三层结构来实现,接收一个请求,然后返回一个结果。

  1. Transport
    Transport处于该微服务的最上层,主要负责于HTTP, gRPC,thrift等相关的逻辑,负责解析请求,并且调用endpoint来处理请求

  2. Endpoint
    endpoint属于客户端和服务端的转接器,他定义了request和response的格式,上层给Transport调用来处理请求,下层链接Service将Service所返回的结果转换成request需要的格式

  3. Service
    最底下的我们这个模块所需要实现的功能了

2.go-kit 实例

service -> endpoint -> transport

在这里插入图片描述

service.go

package serviceimport ("errors""strings"
)type StringServiceI interface {GetUppercase(string) (string, error)PostUppercase(string) (string, error)GetCount(string) int
}type StringService struct {
}func (StringService) GetUppercase(s string) (string, error) {if s == "" {return "", errors.New("error")}return strings.ToUpper(s), nil
}func (StringService) PostUppercase(s string) (string, error) {if s == "" {return "", errors.New("error")}return strings.ToUpper(s), nil
}func (StringService) GetCount(s string) (int, error) {if s == "" {return 0, errors.New("error")}return len(s), nil
}

endpoint.go

package endpointimport ("context""github.com/go-kit/kit/endpoint""go-demo06/service"
)type Endpoints struct {GetUppercase  endpoint.EndpointPostUppercase endpoint.EndpointGetCount      endpoint.Endpoint
}type UppercaseRequest struct {S string `json:"s"`
}type UppercaseResponse struct {V   string `json:"v"`Err error  `json:"err"`
}type CountRequest struct {S string `json:"s"`
}type CountResponse struct {V int `json:"v"`
}func MakeEndpoints(svc service.StringService) Endpoints {return Endpoints{GetCount:      MakeGetCountEndpoint(svc),GetUppercase:  MakeGetUppercaseEndpoint(svc),PostUppercase: MakePostUppercaseEndpoint(svc),}
}func MakeGetUppercaseEndpoint(svc service.StringService) endpoint.Endpoint {return func(ctx context.Context, request interface{}) (response interface{}, err error) {req := request.(UppercaseRequest)v, err := svc.GetUppercase(req.S)if err != nil {return UppercaseResponse{v, err}, nil}return UppercaseResponse{v, err}, nil}
}func MakePostUppercaseEndpoint(svc service.StringService) endpoint.Endpoint {return func(ctx context.Context, request interface{}) (response interface{}, err error) {req := request.(UppercaseRequest)v, err := svc.PostUppercase(req.S)if err != nil {return UppercaseResponse{v, err}, nil}return UppercaseResponse{v, err}, nil}
}func MakeGetCountEndpoint(svc service.StringService) endpoint.Endpoint {return func(ctx context.Context, request interface{}) (response interface{}, err error) {req := request.(CountRequest)v, err := svc.GetCount(req.S)if err != nil {return CountResponse{v}, nil}return CountResponse{v}, nil}
}

rest.go

package transportimport ("context""encoding/json"httptransport "github.com/go-kit/kit/transport/http""github.com/gorilla/mux""go-demo06/endpoint""go-demo06/service""log""net/http"
)func RestRun() {svc := service.StringService{}r := makeHttpHandler(svc)log.Fatal(http.ListenAndServe(":8080", r))
}func makeHttpHandler(svc service.StringService) http.Handler {r := mux.NewRouter()e := endpoint.MakeEndpoints(svc)r.Methods("GET").Path("/uppercase").Handler(httptransport.NewServer(e.GetUppercase, DecodeUppercaseRequest, EncodeUppercaseResponse))r.Methods("GET").Path("/count").Handler(httptransport.NewServer(e.GetCount, DecodeCountRequest, EncodeCountResponse))return r
}func DecodeUppercaseRequest(_ context.Context, r *http.Request) (interface{}, error) {var req endpoint.UppercaseRequestif err := json.NewDecoder(r.Body).Decode(&req); err != nil {return nil, err}return req, nil
}func EncodeUppercaseResponse(_ context.Context, w http.ResponseWriter, response interface{}) error {// transport body to jsonw.Header().Set("Content-type", "application/json")return json.NewEncoder(w).Encode(response)
}func DecodeCountRequest(_ context.Context, r *http.Request) (interface{}, error) {var req endpoint.CountRequestif err := json.NewDecoder(r.Body).Decode(&req); err != nil {return nil, err}return req, nil
}func EncodeCountResponse(_ context.Context, w http.ResponseWriter, response interface{}) error {// transport body to jsonw.Header().Set("Content-type", "application/json")return json.NewEncoder(w).Encode(response)
}

main.go

package mainimport ("go-demo06/transport"
)func main() {transport.RestRun()
}
go run main.go

在这里插入图片描述

在这里插入图片描述

这篇关于[Golang] go-kit 介绍和使用 (微服务实现工具)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1068579

相关文章

使用Python实现矢量路径的压缩、解压与可视化

《使用Python实现矢量路径的压缩、解压与可视化》在图形设计和Web开发中,矢量路径数据的高效存储与传输至关重要,本文将通过一个Python示例,展示如何将复杂的矢量路径命令序列压缩为JSON格式,... 目录引言核心功能概述1. 路径命令解析2. 路径数据压缩3. 路径数据解压4. 可视化代码实现详解1

PyQt6/PySide6中QTableView类的实现

《PyQt6/PySide6中QTableView类的实现》本文主要介绍了PyQt6/PySide6中QTableView类的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学... 目录1. 基本概念2. 创建 QTableView 实例3. QTableView 的常用属性和方法

Pandas透视表(Pivot Table)的具体使用

《Pandas透视表(PivotTable)的具体使用》透视表用于在数据分析和处理过程中进行数据重塑和汇总,本文就来介绍一下Pandas透视表(PivotTable)的具体使用,感兴趣的可以了解一下... 目录前言什么是透视表?使用步骤1. 引入必要的库2. 读取数据3. 创建透视表4. 查看透视表总结前言

PyQt6/PySide6中QTreeView类的实现

《PyQt6/PySide6中QTreeView类的实现》QTreeView是PyQt6或PySide6库中用于显示分层数据的控件,本文主要介绍了PyQt6/PySide6中QTreeView类的实现... 目录1. 基本概念2. 创建 QTreeView 实例3. QTreeView 的常用属性和方法属性

Python 交互式可视化的利器Bokeh的使用

《Python交互式可视化的利器Bokeh的使用》Bokeh是一个专注于Web端交互式数据可视化的Python库,本文主要介绍了Python交互式可视化的利器Bokeh的使用,具有一定的参考价值,感... 目录1. Bokeh 简介1.1 为什么选择 Bokeh1.2 安装与环境配置2. Bokeh 基础2

Android使用ImageView.ScaleType实现图片的缩放与裁剪功能

《Android使用ImageView.ScaleType实现图片的缩放与裁剪功能》ImageView是最常用的控件之一,它用于展示各种类型的图片,为了能够根据需求调整图片的显示效果,Android提... 目录什么是 ImageView.ScaleType?FIT_XYFIT_STARTFIT_CENTE

pandas中位数填充空值的实现示例

《pandas中位数填充空值的实现示例》中位数填充是一种简单而有效的方法,用于填充数据集中缺失的值,本文就来介绍一下pandas中位数填充空值的实现,具有一定的参考价值,感兴趣的可以了解一下... 目录什么是中位数填充?为什么选择中位数填充?示例数据结果分析完整代码总结在数据分析和机器学习过程中,处理缺失数

Golang HashMap实现原理解析

《GolangHashMap实现原理解析》HashMap是一种基于哈希表实现的键值对存储结构,它通过哈希函数将键映射到数组的索引位置,支持高效的插入、查找和删除操作,:本文主要介绍GolangH... 目录HashMap是一种基于哈希表实现的键值对存储结构,它通过哈希函数将键映射到数组的索引位置,支持

Java学习手册之Filter和Listener使用方法

《Java学习手册之Filter和Listener使用方法》:本文主要介绍Java学习手册之Filter和Listener使用方法的相关资料,Filter是一种拦截器,可以在请求到达Servl... 目录一、Filter(过滤器)1. Filter 的工作原理2. Filter 的配置与使用二、Listen

Pandas使用AdaBoost进行分类的实现

《Pandas使用AdaBoost进行分类的实现》Pandas和AdaBoost分类算法,可以高效地进行数据预处理和分类任务,本文主要介绍了Pandas使用AdaBoost进行分类的实现,具有一定的参... 目录什么是 AdaBoost?使用 AdaBoost 的步骤安装必要的库步骤一:数据准备步骤二:模型