[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

相关文章

Java枚举类实现Key-Value映射的多种实现方式

《Java枚举类实现Key-Value映射的多种实现方式》在Java开发中,枚举(Enum)是一种特殊的类,本文将详细介绍Java枚举类实现key-value映射的多种方式,有需要的小伙伴可以根据需要... 目录前言一、基础实现方式1.1 为枚举添加属性和构造方法二、http://www.cppcns.co

使用Python实现快速搭建本地HTTP服务器

《使用Python实现快速搭建本地HTTP服务器》:本文主要介绍如何使用Python快速搭建本地HTTP服务器,轻松实现一键HTTP文件共享,同时结合二维码技术,让访问更简单,感兴趣的小伙伴可以了... 目录1. 概述2. 快速搭建 HTTP 文件共享服务2.1 核心思路2.2 代码实现2.3 代码解读3.

Elasticsearch 在 Java 中的使用教程

《Elasticsearch在Java中的使用教程》Elasticsearch是一个分布式搜索和分析引擎,基于ApacheLucene构建,能够实现实时数据的存储、搜索、和分析,它广泛应用于全文... 目录1. Elasticsearch 简介2. 环境准备2.1 安装 Elasticsearch2.2 J

使用C#代码在PDF文档中添加、删除和替换图片

《使用C#代码在PDF文档中添加、删除和替换图片》在当今数字化文档处理场景中,动态操作PDF文档中的图像已成为企业级应用开发的核心需求之一,本文将介绍如何在.NET平台使用C#代码在PDF文档中添加、... 目录引言用C#添加图片到PDF文档用C#删除PDF文档中的图片用C#替换PDF文档中的图片引言在当

Java中List的contains()方法的使用小结

《Java中List的contains()方法的使用小结》List的contains()方法用于检查列表中是否包含指定的元素,借助equals()方法进行判断,下面就来介绍Java中List的c... 目录详细展开1. 方法签名2. 工作原理3. 使用示例4. 注意事项总结结论:List 的 contain

C#使用SQLite进行大数据量高效处理的代码示例

《C#使用SQLite进行大数据量高效处理的代码示例》在软件开发中,高效处理大数据量是一个常见且具有挑战性的任务,SQLite因其零配置、嵌入式、跨平台的特性,成为许多开发者的首选数据库,本文将深入探... 目录前言准备工作数据实体核心技术批量插入:从乌龟到猎豹的蜕变分页查询:加载百万数据异步处理:拒绝界面

Android中Dialog的使用详解

《Android中Dialog的使用详解》Dialog(对话框)是Android中常用的UI组件,用于临时显示重要信息或获取用户输入,本文给大家介绍Android中Dialog的使用,感兴趣的朋友一起... 目录android中Dialog的使用详解1. 基本Dialog类型1.1 AlertDialog(

MySQL双主搭建+keepalived高可用的实现

《MySQL双主搭建+keepalived高可用的实现》本文主要介绍了MySQL双主搭建+keepalived高可用的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,... 目录一、测试环境准备二、主从搭建1.创建复制用户2.创建复制关系3.开启复制,确认复制是否成功4.同

Python使用自带的base64库进行base64编码和解码

《Python使用自带的base64库进行base64编码和解码》在Python中,处理数据的编码和解码是数据传输和存储中非常普遍的需求,其中,Base64是一种常用的编码方案,本文我将详细介绍如何使... 目录引言使用python的base64库进行编码和解码编码函数解码函数Base64编码的应用场景注意

Java实现文件图片的预览和下载功能

《Java实现文件图片的预览和下载功能》这篇文章主要为大家详细介绍了如何使用Java实现文件图片的预览和下载功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... Java实现文件(图片)的预览和下载 @ApiOperation("访问文件") @GetMapping("