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

news2024/12/24 21:22:31

文章目录

      • 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集群中的client
    micro.Name(service),
    micro.Version(version),
    micro.Registry(consulReg),
)

main.go

package main
 
import (
    "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() {
    //集成consul
    consulReg := consul.NewRegistry()
    // Create service
    srv := micro.NewService(
        micro.Address("127.0.0.1:8080"),  //指定微服务的ip:  选择注册服务器地址,也可以不配置,默认为本机,也可以选择consul集群中的client
        micro.Name(service),
        micro.Version(version),
        //注册consul
        micro.Registry(consulReg),
    )
    srv.Init(
        micro.Name(service),
        micro.Version(version),
    )
 
    // Register handler
    if err := pb.RegisterHelloworldHandler(srv.Server(), new(handler.Helloworld)); err != nil {
        logger.Fatal(err)
    }
    // Run service
    if 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 tidy

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

main.go

package main
 
import (
    "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() {
    //集成consul
    consulReg := consul.NewRegistry(
        //指定微服务的ip:  选择注册服务器地址,默认为本机,也可以选择consul集群中的client
        registry.Addrs("127.0.0.1:8500"),
    )
    // Create service
    srv := micro.NewService(
        //注册consul
        micro.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 handler
 
import (
    "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 = true
    return nil
}

引入consul

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

maiin.go

package main
 
import (
 
    "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() {
    //集成consul
    consulReg := consul.NewRegistry()
    // Create service
    srv := micro.NewService(
        micro.Address("127.0.0.1:8080"),  //指定微服务的ip:  选择注册服务器地址,也可以不配置,默认为本机,也可以选择consul集群中的client
        micro.Name(service),
        micro.Version(version),
        //注册consul
        micro.Registry(consulReg),
    )
    srv.Init(
        micro.Name(service),
        micro.Version(version),
    )
 
    // Register handler
    if err := pb.RegisterGoodsinfoHandler(srv.Server(), new(handler.Goodsinfo)); err != nil {
        logger.Fatal(err)
    }
    // Run service
    if err := srv.Run(); err != nil {
        logger.Fatal(err)
    }
}

go run main.go

在这里插入图片描述

在这里插入图片描述

服务端开发成功

5.2 客户端开发

在这里插入图片描述

go get go-micro.dev/v4

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

go mod tidy

main.go

package main
 
import (
    "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() {
    //集成consul
    consulReg := consul.NewRegistry(
        //指定微服务的ip:  选择注册服务器地址,默认为本机,也可以选择consul集群中的client
        registry.Addrs("127.0.0.1:8500"),
        )
    // Create service
    srv := micro.NewService(
        //注册consul
        micro.Registry(consulReg),
    )
 
    srv.Init()
 
    // 创建客户端服务
    c := pb.NewGoodsinfoService(service, srv.Client())
 
    // Call service
    rsp, 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.coloradmin.cn/o/1876753.html

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

相关文章

stm32学习笔记---ADC模数转换器（理论部分）

stm32学习笔记---ADC模数转换器（理论部分）

目录 ADC简介 什么叫逐次逼近型？ STM32 ADC框图 模数转换器外围线路 ADC基本结构图 输入通道 规则组的四种转换模式 第一种：单次转换非扫描模式 第二种：连续转换，非扫描模式 第三种：单次转换，扫描…
阅读更多...
数据结构03 链表的基本操作【C++数组模拟实现】

数据结构03 链表的基本操作【C++数组模拟实现】

前言：本节内容主要了解链表的基本概念及特点，以及能够通过数组模拟学会链表的几种基本操作，下一节我们将通过STL模板完成链表操作，可以通过专栏进入查看下一节哦~ 目录 单链表及其特点 完整链表构成 完整链表简述 创建单链表 …
阅读更多...
MySQL自增主键踩坑记录

MySQL自增主键踩坑记录

对于MySQL的自增主键，本文记录、整理下在工作中实际遇到的问题。 下面示例均基于MySQL 8.0 修改列的类型后，自增属性消失 CREATE TABLE users (id INT AUTO_INCREMENT PRIMARY KEY,username VARCHAR(50) NOT NULL,email VARCHAR(100) NOT NULL );上面的…
阅读更多...
计算机监控软件有哪些？10款常年霸榜的计算机监控软件

计算机监控软件有哪些？10款常年霸榜的计算机监控软件

计算机监控软件是企业管理和保护信息安全的重要工具，它们帮助企业管理者监督员工的计算机使用行为，确保工作效率、数据安全以及合规性。在众多监控软件中，有些产品因其卓越的功能、易用性、安全性以及持续获得的良好市场反馈而常年占据行业领…
阅读更多...
什么是指令微调（LLM）

什么是指令微调（LLM）

经过大规模数据预训练后的语言模型已经具备较强的模型能力，能够编码丰富的世界知识，但是由于预训练任务形式所限，这些模型更擅长于文本补全，并不适合直接解决具体的任务。 指令微调是相对“预训练”来讲的，预训练的时…
阅读更多...
spring mvc实现一个自定义Formatter请求参数格式化

spring mvc实现一个自定义Formatter请求参数格式化

使用场景 在Spring Boot应用中，Formatter接口用于自定义数据的格式化，比如将日期对象格式化为字符串，或者将字符串解析回日期对象。这在处理HTTP请求和响应时特别有用，尤其是在展示给用户或从用户接收特定格式的数据时。下面通过…
阅读更多...
集合，Collection接口

集合，Collection接口

可动态保存任意多个对象，使用比较方便 提供了一系列方便操作对象的方法：add，remove，set，get等 使用集合添加删除新元素，代码简洁明了 单列集合 多列集合 Collection接口 常用方法 List list new Arra…
阅读更多...
【原创图解 算法leetcode 146】实现一个LRU缓存淘汰策略策略的数据结构

【原创图解 算法leetcode 146】实现一个LRU缓存淘汰策略策略的数据结构

1 概念 LRU是Least Recently Used的缩写，即最近最少使用，是一种常见的缓存淘汰算法。 其核心思想为：当内存达到上限时，淘汰最久未被访问的缓存。 2 LeetCode LeetCode: 146. LRU缓存 3 实现 通过上面LRU的淘汰策略可知&#…
阅读更多...
北京市大兴区餐饮行业协会成立暨职业技能竞赛总结大会成功举办

北京市大兴区餐饮行业协会成立暨职业技能竞赛总结大会成功举办

2024年6月27日下午，北京市大兴区营商服务中心B1层报告厅迎来了北京市大兴区餐饮行业协会成立仪式暨2024年北京市大兴区餐饮行业职工职业技能竞赛总结大会。此次活动不仅标志着大兴区餐饮行业协会的正式成立，也对在2024年大兴区餐饮行业职工职业技能竞赛中…
阅读更多...
Python自动化测试：web自动化测试——selenium API、unittest框架的使用

Python自动化测试：web自动化测试——selenium API、unittest框架的使用

web自动化测试2 1. 设计用例的方法——selenium API1.1 基本元素定位1）定位单个唯一元素2）定位一组元素3）定位多窗口/多框架4）定位连续层级5）定位下拉框6）定位div框 1.2 基本操作1.3 等待1.4 浏览器操作1.5…
阅读更多...
SpringBoot整合Quartz实现动态定时任务

SpringBoot整合Quartz实现动态定时任务

目录 1、Quartz简介1.1 Quartz的三大核心组件1.2 CronTrigger配置格式 2、SpringBoot整合Quartz框架2.1 创建项目2.2 实现定时任务 1、Quartz简介 Quartz是一个开源的任务调度服务，它可以独立使用，也可与其它的Java EE，Java SE应用整合使用。…
阅读更多...
Python数据分析案例48——二手房价格影响因素分析

Python数据分析案例48——二手房价格影响因素分析

案例背景 房价影响因素也是人们一直关注的问题，本次案例也适合各种学科的同学，无论你是经济管理类还是数学统计，还是电商物流类，都可以使用回归分析。通过数据分析回归分析分组聚合可视化等方法进行研究房价影响因素。 数据介绍 …
阅读更多...
2024下半年必追国漫片单，谁将问鼎巅峰？

2024下半年必追国漫片单，谁将问鼎巅峰？

随着2024年上半年的落幕，国漫市场再度迎来了百花齐放的盛况。从经典续作到全新IP，从玄幻到科幻，每一部作品都以其独特的魅力吸引着观众的目光。本期为大家盘点下半年值得一看的国漫佳作，大胆预测，谁将成为这场神仙打架…
阅读更多...
Grafana-11.0.0 在线部署教程

Grafana-11.0.0 在线部署教程

Grafana-11.0.0 在线部署教程 环境： 操作系统： ubuntugrafana版本： 11.0.0 （建议不要按照最新版）grafana要求的系统配置不高，建议直接部署在监控服务器上，比如zabbix服务器、prometheus服务器…
阅读更多...
【Stable Diffusion】创意与科技的完美结合：AI绘画副业让美术老师月入2w＋

【Stable Diffusion】创意与科技的完美结合：AI绘画副业让美术老师月入2w＋

前言 艺术与科技一直以来都是两个看似独立的领域，但如今，随着人工智能的发展，这两个领域正迎来一次前所未有的融合。在这个数字化时代，AI绘画成为了一项引人注目的副业，为美术老师们带来了新的机遇和收入。 儿童画 …
阅读更多...
实验场：在几分钟内使用 Elasticsearch 进行 RAG 应用程序实验

实验场：在几分钟内使用 Elasticsearch 进行 RAG 应用程序实验

作者：来自 Elastic Joe McElroy, Serena Chou 什么是 Playground（实验场）？ 我们很高兴发布我们的 Playground 体验 —- 一个低代码界面，开发人员可以在几分钟内使用自己的私人数据探索他们选择的 LLM。 在对对话式搜…
阅读更多...
“实时数据大屏2k、4k、8k”这样做【高级前端必备技能之一】

“实时数据大屏2k、4k、8k”这样做【高级前端必备技能之一】

🔥废话不多先上效果图 🔥划重点 新手程序员需要注意以下几点： 我们需要进行充分的技术调研，进行技术选型产品，UI，再三确认效果图是否确定，避免后续出现返工的情况 不能拿到效果图之后&#x…
阅读更多...
事务的概念-事务的概念、事务的定义（BEGIN TRANSACTION、COMMIT、ROLLBACK）

事务的概念-事务的概念、事务的定义（BEGIN TRANSACTION、COMMIT、ROLLBACK）

数据库系统中的事务，是保证系统在发生故障后或存在并发操作的情况下，数据库中的数据与企业业务结果相一致 一、事务的概念 在许多数据库应用系统中，数据库用来存储现实世界中一些企业的状态信息或其管理的数据 1、概念一 （1&a…
阅读更多...
《昇思25天学习打卡营第3天|张量 Tensor》

《昇思25天学习打卡营第3天|张量 Tensor》

文章目录 前言：今日所学：1. 创建张量2. 张量的属性3.张量索引与运算4. NumPy与Tensor的转换5. 稀疏张量 前言： 张量？张亮？张量是什么？ 张量是一个可以用来表示在一些矢量、标量和其他张量之间的线性关系的…
阅读更多...
博途TIA Portal「集成自动化软件」下载安装，TIA Portal 灵活多变的编程环境

博途TIA Portal「集成自动化软件」下载安装，TIA Portal 灵活多变的编程环境

在编程领域，博途TIA Portal以其卓越的编程工具和灵活多变的编程环境，为众多用户提供了前所未有的便利。这款软件不仅支持多种编程语言，如梯形图（Ladder Diagram）、功能块图（Function Block Diagram&#xf…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023