[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

在这里插入图片描述

在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/web/28165.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Paragon NTFS for Mac 15软件下载-详细安装教程视频

​Paragon NTFS for Mac是Mac平台上一款非常优秀的读写工具,可以在Mac OS X中完全读写、修改、访问NTFS硬盘、U盘等外接设备的文件。这款软件最大的亮点简书可以让我们读写 NTFS 分区,因为在Mac OS X 系统上,默认状态下我们只能读取NTFS 分区…

Java Arrays 类的常用方法详解

Arrays 类是 Java 标准库中的一个实用工具类,提供了许多静态方法来操作数组。其中一些方法在日常开发中使用频率较高。以下是一些在实际开发中最常用的方法: 1. toString 方法 将数组转换为字符串表示。 int[] array {1, 2, 3, 4, 5}; System.out.pr…

Spring-kafka消费者消费的一些问题

前言 Spring Kafka 无缝集成了 Spring Boot、Spring Framework 及其生态系统中的其他项目,如 Spring Cloud。通过与 Spring Boot 的自动配置结合,开发者可以快速启动和配置 Kafka 相关的功能。无需编写大量样板代码即可实现 Kafka 的生产和消费功能&…

Arm平台编译linuxdeployqt

在网上看了一下网友的分享,这个linuxdeployqt工具主要是用来打包qt程序的,但是程序不支持arm平台,需要下载源码编译才能用,自己测试了一下成功了,记录分享一下 操作步骤: 去下载源码:源码下载我…

揭开 Docker 容器的神秘面纱:深入理解容器原理

前言 前几年比较火的是微服务,再然后就是云。讨论技术必谈微服务,要上云,开发出的产品也都是某某云。现在讨论比较少了,因为AI盖过他们。还有就是因为容器技术,现在几乎都是k8s,云原生。要比较快的上手k8s…

HCIP笔记(拖拽题)

1、接口安全保护动作的名称和操作对应关系: 1)restrict:丢弃触发静态MAC地址漂移的报文,并上报告警; 2)protect:只丢弃触发触发静态MAC地址漂移的报文,不上报告警; 3&…

【源码】16国语言交易所源码/币币交易+期权交易+秒合约交易+永续合约+交割合约+新币申购+投资理财/手机端uniapp纯源码+PC纯源码+后端PHP

测试环境:Linux系统CentOS7.6、宝塔面板、Nginx、PHP7.3、MySQL5.6,根目录public,伪静态laravel5,开启ssl证书 语言:16种,看图 这套带前端uniapp纯源码,手机端和pc端都有纯源码,后…

【C++】 基础复习 | 数据类型,输入,输出流 scanf printf

文章目录 1 基本数据类型1.1 基本数据类型1.2 构造类型1.3 指针类型&#xff08;Pointers&#xff09; 2 基础输入输出2.1 通过输入输出操作符>> <<2.2 通过scanf和printf输入和输出2.2.1 输出printf 函数2.2.2 输出scanf 函数2.2.3 注意事项 1 基本数据类型 了解…

list集合自定义排序

一、基本类型排序 1.list中只有数字或字符串 //升序排序 List<T> ,T为数字或字符串 Collections.sort(list); //降序排序 Collections.sort(list,Collections.reverseOrder());2.list中为对象 基于jdk.18 import lombok.Data;Data public class User {private int i…

Linux基础指令(二)(文件、权限等)

目录 普通文件的操作 touch cat 翻页 标准输出重定向&#xff1a; 标准输出重定向种类&#xff1a;​​​​​​​ 管道符&#xff1a;&#xff5c; 压缩指令&#xff1a; zip gzip tar Linux下最常见的打包指令 其他系统指令&#xff1a;​​​​​​​ 快捷…

mysql update sql语句常见错误

以下update语句得不到预期结果 update event_detail set step_status1 and impact_area222isss.jsjd.lemem.com and end_time2024-06-14 17:23:39 where event_id91 and stepother_group2; 多个字段改动&#xff0c;不能使用 and连接&#xff0c;使用逗号“&#xff0c;”分隔即…

【C语言】进程间通信之管道pipe

进程间通信之管道pipe 一、进程间通信管道pipe()管道的读写行为 最后 一、进程间通信 管道pipe() 管道pipe也称为匿名管道&#xff0c;只有在有血缘关系的进程间进行通信。管道的本质就是一块内核缓冲区。 进程间通过管道的一端写&#xff0c;通过管道的另一端读。管道的读端…

【Python高阶编程】如何模拟生成训练日志并记录到文件

Python综合练习&#xff1a;生成训练日志 任务描述 在机器学习模型训练过程中&#xff0c;我们经常会记录模型的训练日志&#xff0c;包括accuracy&#xff08;准确率&#xff09;和loss&#xff08;损失&#xff09;。这个综合练习的目标是编写一段Python代码&#xff0c;模…

Linux下Shell脚本基础知识

主要参考视频&#xff1a; 这可能是B站讲的最好的Linux Shell脚本教程&#xff0c;3h打通Linux-shell全套教程&#xff0c;从入门到精通完整版_哔哩哔哩_bilibili 主要参考文档&#xff1a; Shell 教程 | 菜鸟教程 (runoob.com) Bash Shell教程 (yiibai.com) 先用视频入门&…

写在前面的话

《CSS in Depth》第二版开篇词 A minute to learn … A lifetime to master. ——Othello 「学会只需一分钟&#xff0c;精通却要一辈子」——这是诞生于上世纪的经典游戏《黑白棋》中的一个标语。 不知道看到这句话的你&#xff0c;是否有过这样的经历&#xff1a;在自己人生…

adb简单使用命令

1. 查看当前连接的设备 adb devices 2. 文件路径 adb install apk 注意文件路径中不能有中文 3. adb shell ps Toplogcatlogcat可以结合greplogcat *:w 显示警告级别以上de 4. adb uninstall 软件名 1.软件名如何查看&#xff1f; 使用命令adb shell pm list packages会…

基于springboot实现火锅店管理系统项目【项目源码+论文说明】

基于springboot实现火锅店管理系统演示 摘要 传统办法管理信息首先需要花费的时间比较多&#xff0c;其次数据出错率比较高&#xff0c;而且对错误的数据进行更改也比较困难&#xff0c;最后&#xff0c;检索数据费事费力。因此&#xff0c;在计算机上安装火锅店管理系统软件来…

编译一个叫:未来的IDE-Zed编辑器(Windows平台)

一、前言 截止到2024-6-15&#xff0c;Zed官方并未给出Windows的二进制安装包&#xff0c;如果想在Windows平台使用的话需要自己编译&#xff0c;我是如何编译的请随我道来&#xff0c;有兴趣的码友可以尝试下&#xff0c;在下可不敢保证各位码友按我这方法能100%编译出来&…

【JavaEE进阶】——利用框架完成功能全面的图书管理系统

目录 &#x1f6a9;项目所需要的技术栈 &#x1f6a9;项目准备工作 &#x1f388;环境准备 &#x1f388;数据库准备 &#x1f6a9;前后端交互分析 &#x1f388;登录 &#x1f4dd;前后端交互 &#x1f4dd;实现服务器代码 &#x1f4dd;测试前后端代码是否正确 &am…

使用python获取内存信息

#!/usr/bin/python # -*- coding:utf-8 -*- psutil模块是一个跨平台的获取进程和系统应用情况&#xff08;CPU&#xff0c;内存&#xff0c;磁盘&#xff0c;网络&#xff0c;传感器&#xff09;的库。 该模块用于系统监控、限制进程资源和运行进程的管理等方面。 内存信息&am…