[Go 微服务] go-micro + consul 的使用

文章目录

      • 1.go-micro 介绍
      • 2.go-micro 的主要功能
      • 3.go-micro 安装
      • 4.go-micro 的使用
        • 4.1 创建服务端
        • 4.2 配置服务端 consul
        • 4.3 生成客户端
      • 5.goodsinfo 服务
        • 5.1 服务端开发
        • 5.2 客户端开发

1.go-micro 介绍

Go Micro是一个简化分布式开发 的微服务生态系统，该系统为开发分布式应用程序提供了 高效， 便捷的模块构建， 主要目的是 简化分布式系统的开发,它默认实现了 consul作为服务发现（2019年源码修改了默认使用 mdns），通过 http进行通信，通过 protobuf和 json进行编解码,可以方便开发者们非常简单的开发出微服务架构的项目，并且随着业务模块的增加和功能的增加，Go Micro还能够提供管理微服务环境的工具和功能。

2.go-micro 的主要功能

  1. 身份验证
  2. 动态配置
  3. 数据存储
  4. 服务发现: 自动服务注册和 名称解析,服务发现是 微服务开发的核心,当服务 A 需要与服务 B 通话时，它需要该服务的位置,默认发现机制是 多播 DNS (mdns)，一个 zeroconf 系统。
  5. 负载均衡
  6. 消息编码: 基于 内容类型的 动态消息编码,客户端和服务器将使用 编解码器和 内容类型无缝编码和解码 Go 类型,任何种类的消息都可以被编码并从不同的客户端发送,默认情况下，客户端和服务器会处理此问题,这默认包括 protobuf 和 json。
  7. RPC 客户端/服务器
  8. Async Messaging: PubSub 作为 异步通信和 事件驱动架构的一等公民内置, 事件通知是 微服务开发的核心模式,默认消息系统是 HTTP 事件消息代理。
  9. 事件流: 从偏移量和确认中消耗,Go Micro 包括对 NATS Jetstream 和 Redis 流的支持。
  10. 同步分布式系统通常以 最终一致的方式构建,对 分布式锁定和 领导(Leader)的支持作为同步接口内置,当使用 最终一致的数据库或 调度时，请使用 Sync 接口。
  11. Pluggable Interfaces: Go Micro 为每个分布式系统抽象使用 Go 接口,因此，这些接口是 可插拔的，并 允许 Go Micro 与运行时无关,可以插入任何底层技术。

3.go-micro 安装

go install github.com/go-micro/cli/cmd/go-micro@latest

在这里插入图片描述

在这里插入图片描述

4.go-micro 的使用

4.1 创建服务端
go-micro new service helloworld

在这里插入图片描述

在这里插入图片描述

#init里面的命令：引入需要的包
go get -u google.golang.org/protobuf/proto
go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
go install github.com/go-micro/generator/cmd/protoc-gen-micro@latest
#proto：执行生成对应的protobuf相关文件
protoc --proto_path=. --micro_out=. --go_out=:. proto/helloworld.proto

会生成相关 .pd.go 文件

在这里插入图片描述

go mod tidy

在这里插入图片描述

go get go-micro.dev/v4

在这里插入图片描述

4.2 配置服务端 consul
go get github.com/go-micro/plugins/v4/registry/consul

在这里插入图片描述

# 实例化consul
consulReg := consul.NewRegistry()# 注册consul
srv := micro.NewService(micro.Address("192.168.1.132:8080"),  // 选择注册服务器地址,默认为本机,也可以选择consul集群中的clientmicro.Name(service),micro.Version(version),micro.Registry(consulReg),
)

main.go

package mainimport ("helloworld/handler"pb "helloworld/proto""go-micro.dev/v4""go-micro.dev/v4/logger""github.com/go-micro/plugins/v4/registry/consul"
)var (service = "helloworld"version = "latest"
)func main() {//集成consulconsulReg := consul.NewRegistry()// Create servicesrv := micro.NewService(micro.Address("127.0.0.1:8080"),  //指定微服务的ip:  选择注册服务器地址,也可以不配置,默认为本机,也可以选择consul集群中的clientmicro.Name(service),micro.Version(version),//注册consulmicro.Registry(consulReg),)srv.Init(micro.Name(service),micro.Version(version),)// Register handlerif err := pb.RegisterHelloworldHandler(srv.Server(), new(handler.Helloworld)); err != nil {logger.Fatal(err)}// Run serviceif err := srv.Run(); err != nil {logger.Fatal(err)}
}

go run main.go

在这里插入图片描述

在这里插入图片描述

服务端配置操作完成

4.3 生成客户端
go-micro new client helloworld

在这里插入图片描述

在这里插入图片描述

需要把helloworld/proto修改为helloworld-client/proto

在这里插入图片描述

go mod tidygo get github.com/go-micro/plugins/v4/registry/consul

main.go

package mainimport ("context""time"pb "helloworld-client/proto""go-micro.dev/v4""go-micro.dev/v4/logger"   "go-micro.dev/v4/registry""github.com/go-micro/plugins/v4/registry/consul"
)var (service = "helloworld" //需要和微服务服务端对应的service名统一,这样才能调用该微服务version = "latest"
)func main() {//集成consulconsulReg := consul.NewRegistry(//指定微服务的ip:  选择注册服务器地址,默认为本机,也可以选择consul集群中的clientregistry.Addrs("127.0.0.1:8500"),)// Create servicesrv := micro.NewService(//注册consulmicro.Registry(consulReg),)srv.Init()// 创建客户端实例c := pb.NewHelloworldService(service, srv.Client())for {// Call service: CallRequest就是.proto中的rsp, err := c.Call(context.Background(), &pb.CallRequest{Name: "张三"})if err != nil {logger.Fatal(err)}logger.Info(rsp)//每隔一段时间请求time.Sleep(2 * time.Second)  // 每隔2秒请求}
}

客户端:

在这里插入图片描述

服务端:

在这里插入图片描述

客户端配置操作完成

5.goodsinfo 服务

5.1 服务端开发
go-micro new service goodsinfo

goodsinfo.proto

syntax = "proto3";package goodsinfo;option go_package = "./proto;goodsinfo";//商品相关方法
service Goodsinfo {//AddGoods: 定义增加商品的微服务, 这里的写法和gRPC中的写法一致rpc AddGoods(AddRequest) returns (AddResponse) {}
}//和gRPC中的写法一致
message AddRequest {string title = 1;string price = 2;string content = 3;
}//和gRPC中的写法一致
message AddResponse {string message = 1;bool success = 2;
}

#init：引入相关包
go get -u google.golang.org/protobuf/proto
go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
go install github.com/go-micro/generator/cmd/protoc-gen-micro@latest
#proto： 生成protobuf相关文件
protoc --proto_path=. --micro_out=. --go_out=:. proto/goodsinfo.proto

go get go-micro.dev/v4
go mod tidy

修改远程调用的方法handler/goodsinfo.go

package handlerimport ("context""go-micro.dev/v4/logger"pb "goodsinfo/proto"
)type Goodsinfo struct{}func (e *Goodsinfo) AddGoods(ctx context.Context, req *pb.AddRequest, rsp *pb.AddResponse) error {logger.Infof("request: %v", req)//书写返回的逻辑结果rsp.Message = "增加成功"rsp.Success = truereturn nil
}

引入consul

go get github.com/go-micro/plugins/v4/registry/consul

maiin.go

package mainimport ("goodsinfo/handler"pb "goodsinfo/proto""go-micro.dev/v4""go-micro.dev/v4/logger""github.com/go-micro/plugins/v4/registry/consul"
)var (service = "goodsinfo"version = "latest"
)func main() {//集成consulconsulReg := consul.NewRegistry()// Create servicesrv := micro.NewService(micro.Address("127.0.0.1:8080"),  //指定微服务的ip:  选择注册服务器地址,也可以不配置,默认为本机,也可以选择consul集群中的clientmicro.Name(service),micro.Version(version),//注册consulmicro.Registry(consulReg),)srv.Init(micro.Name(service),micro.Version(version),)// Register handlerif err := pb.RegisterGoodsinfoHandler(srv.Server(), new(handler.Goodsinfo)); err != nil {logger.Fatal(err)}// Run serviceif err := srv.Run(); err != nil {logger.Fatal(err)}
}

go run main.go

在这里插入图片描述

在这里插入图片描述

服务端开发成功

5.2 客户端开发

在这里插入图片描述

go get go-micro.dev/v4go get github.com/go-micro/plugins/v4/registry/consulgo mod tidy

main.go

package mainimport ("context""go-micro.dev/v4/registry""time"pb "goodsinfo-client/proto""go-micro.dev/v4""go-micro.dev/v4/logger""github.com/go-micro/plugins/v4/registry/consul"
)var (service = "goodsinfo"version = "latest"
)func main() {//集成consulconsulReg := consul.NewRegistry(//指定微服务的ip:  选择注册服务器地址,默认为本机,也可以选择consul集群中的clientregistry.Addrs("127.0.0.1:8500"),)// Create servicesrv := micro.NewService(//注册consulmicro.Registry(consulReg),)srv.Init()// 创建客户端服务c := pb.NewGoodsinfoService(service, srv.Client())// Call servicersp, err := c.AddGoods(context.Background(), &pb.AddRequest{Title: "我是一个商品",Price: "20.22",Content: "内容展示",})if err != nil {logger.Fatal(err)}logger.Info(rsp)
}

在这里插入图片描述

go run .\main.go

在这里插入图片描述

客户端开发成功, 并通过consul调用服务端的请求

在这里插入图片描述

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

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

相关文章

Java学习【IO流：深入理解与应用（上）】

Java学习【IO流：深入理解与应用（上）】

Java学习【IO流：深入理解与应用（上）】 🍃1.IO流体系结构🍃2.FileOutputStream🍁2.1FileOutputStream写数据的三种方式🍁2.2换行和续写 🍃3.FileInputStream🍁3.1每次读取…
阅读更多...
软考高项备考经验分享

软考高项备考经验分享

高项备考经验分享 在备考被论文卡两次后，这次终于通过了高项，分不是很高，比较幸运，对这次考试做个总结与分享，希望对同学们有所帮助。 1、备考时间 首先备考时间上不建议拉的太长，每天坚持看书3~6个月时…
阅读更多...
《编译原理》阅读笔记：p25-p32

《编译原理》阅读笔记：p25-p32

《编译原理》学习第 5 天，p25-p32总结，总计 8 页。 一、技术总结 1.lexical lexical这个单词后续会经常用到，所以首先要搞懂它的英文意思，不然看到中文的“词法，语法，文法”这三个词的时候就会懵了——l…
阅读更多...
异常实践1

异常实践1

只针对不正常的情况才使用异常 异常只应该被用于不正常的条件，它们永远不应该被用于正常的控制流。《阿里手册》中：【强制】Java 类库中定义的可以通过预检查方式规避的RuntimeException异常不应该通过catch 的方式来处理，比如：Nu…
阅读更多...
Java实现 现场评委给参赛选手打分的过程

Java实现 现场评委给参赛选手打分的过程

通过评委的积极参与和公正评分,可以提高评选活动的公信力和可信度。 透明性:参赛者和观众应该清楚了解评审标准和评分过程,以便能够理解评委的评判依据。 可靠性:评委评分应该具有一致性和可靠性,不受主观因素或随机误差的影响。 编写程序，Java代码实现&#xff1…
阅读更多...
计算机组成原理：海明校验

计算机组成原理：海明校验

在上图中，对绿色的7比特数据进行海明校验，需要添加紫色的4比特校验位，总共是蓝色的11比特。紫色的校验位pi分布于蓝色的hi的1, 2, 4, 8, 16, 32, 64位，是2i-1位。绿色的数据位bi分布于剩下的位。 在下图中，b1位于h3&a…
阅读更多...
Redis分布式锁详解：原理、实现与最佳实践

Redis分布式锁详解：原理、实现与最佳实践

Redis分布式锁详解：原理、实现与最佳实践 引言 在分布式系统中，经常需要对共享资源进行同步访问，以避免并发问题。Redis分布式锁提供了一种简单而高效的方式来实现这一需求。本文将深入探讨Redis分布式锁的工作原理、实现方法以及在实际应用…
阅读更多...
人工智能给文化安全带来挑战

人工智能给文化安全带来挑战

技术发展的双刃剑特性在人工智能时代尤为明显。基于人工智能的算法权力代表了新的权力结构，依托这些算法的平台正在逐渐形成一种能够单方面施加影响的新势力。由于算法技术的复杂性和专业性，加之公共权力机构在授权和监管上的不足，以及当前对…
阅读更多...
资料分析题目类型分类

资料分析题目类型分类

1、两期平均数比较问题（类比为两期比重比较问题） 例如：2020年，H省秋粮玉米和稻谷的市场平均交易价格分别为2.34元/公斤和2.74元/公斤，分别比上年上涨28.6%和8.7%。按此价格测算，2020年全省农户种植玉米、稻…
阅读更多...
浅谈安科瑞ACRELCLOUD-1200光伏发电系统在建筑节能中的应用

浅谈安科瑞ACRELCLOUD-1200光伏发电系统在建筑节能中的应用

摘要：21世纪以来，随着不可再生能源的逐渐减少，人们越来越重视能源的利用率，不断开发绿色能源。通过光伏发电系统，能够提升能源利用率，减少不可再生能源的开发。同时，也能加强我国建筑节能系统的…
阅读更多...
【React】第二个组件的一点小问题（JSX元素需要被包裹）

【React】第二个组件的一点小问题（JSX元素需要被包裹）

能看出为什么报错吗？ 它告诉我们JSX元素需要被包裹，此时只需在所有元素外套一层标签（空标签也可以哦） 专业点就是要有一个根元素 注释： ctrl / 效果是 {/* */}这样 三元运算符：同CPP 循环输出数组&#x…
阅读更多...
每日一道算法题 面试题 08.08. 有重复字符串的排列组合

每日一道算法题 面试题 08.08. 有重复字符串的排列组合

题目 面试题 08.08. 有重复字符串的排列组合 - 力扣（LeetCode） Python class Solution:def permutation(self, S: str) -> List[str]:# 以索引记录字符是否用过lelen(S)idx[_ for _ in range(le) ]# 组合得到的字符串combine[]*leans[]# 递归def fu…
阅读更多...
Go 中使用map时注意的问题

Go 中使用map时注意的问题

💝💝💝欢迎莅临我的博客，很高兴能够在这里和您见面！希望您在这里可以感受到一份轻松愉快的氛围，不仅可以获得有趣的内容和知识，也可以畅所欲言、分享您的想法和见解。 推荐:「stormsha的主页」…
阅读更多...
面对资质申请被拒，河南企业如何调整策略再次冲刺？

面对资质申请被拒，河南企业如何调整策略再次冲刺？

当乙级风力发电资质申请未通过时，不必过于焦虑，以下是一份详细的二次申请攻略，帮助你更有条理地准备和提交申请： 一、失败原因分析与总结 查询评审意见：在收到评审结果后，首先查询并仔细阅读专家评审意见&…
阅读更多...
利用python爬取上证指数股吧评论并保存到mongodb数据库

利用python爬取上证指数股吧评论并保存到mongodb数据库

大家好，我是带我去滑雪！ 东方财富网是中国领先的金融服务网站之一，以提供全面的金融市场数据、资讯和交易工具而闻名。其受欢迎的“股吧”论坛特别适合爬取股票评论，东方财富网的股吧聚集了大量投资者和金融分析师，他们…
阅读更多...
vue开发网站--关于window.print()调取打印

vue开发网站--关于window.print()调取打印

1.vue点击按钮调取打印 点击按钮&#xff1a; 调取打印该页面&#xff1a; <div click"clickDown()">下载</div>methods: {//下载-调取打印clickDown() {window.print()}, }<style>/* 点击打印的样式 */media print {.clickDown {display: no…
阅读更多...
推荐一款免费的GIF编辑器——【ScreenToGif编辑器】

推荐一款免费的GIF编辑器——【ScreenToGif编辑器】

读者大大们好呀&#xff01;&#xff01;!☀️☀️☀️ &#x1f440;期待大大的关注哦❗️❗️❗️ &#x1f680;欢迎收看我的主页文章➡️木道寻的主页 文章目录 &#x1f525;前言&#x1f680;素材准备&#x1f680;逐帧制作&#x1f680;保存图片⭐️⭐️⭐️总结 &#…
阅读更多...
Flask蓝图

Flask蓝图

Flask蓝图 蓝图&#xff08;Blueprint&#xff09;在 Flask 中是一个用于组织多个模块化子应用的强大工具。它允许开发者将不同的功能模块划分到不同的包或目录中&#xff0c;使得大型项目更加易于管理和维护。 一、不使用蓝图 在不使用蓝图的情况下&#xff0c;可能会将所有…
阅读更多...
被淘汰的.NET技术概览

被淘汰的.NET技术概览

最近看到一篇文章&#xff0c;讲的时.NET被淘汰的技术&#xff0c;文章大体内容如下&#xff1a; 被淘汰的.NET技术概览 1.NET Framework 4.8之前的版本 微软已于2019年11月发布了.NET Framework的最后一个版本4.8&#xff0c;并宣布在2023年11月停止对之前版本提供支持。 …
阅读更多...
java基础学习：Class类的isAssignableFrom方法

java基础学习：Class类的isAssignableFrom方法

文章目录 一、介绍2、示例 一、介绍 在Java中&#xff0c;Class类有一个名为isAssignableFrom()的方法。这个方法用于判断一个类对象是否表示指定的类的类对象、接口、超类或超接口。换句话说&#xff0c;它用于检查一个类是否是另一个类的子类、接口实现或它们本身就是同一个…
阅读更多...
最新文章

Copyright @ 2022~2023