[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集群中的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调用服务端的请求

在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

java热部署idea插件「jrebel安装教程」

java热部署idea插件「jrebel安装教程」

告别漫长的项目重启等待，让开发像写诗一样流畅~ jrebel安装包下载 jrebel版本需要下比较老的版本，我用的是22.4.1的版本（如果不差钱，可以支持一下正版，直接选择最新的版本即可） 下载地址：传送门…
阅读更多...
Python逻辑控制语句 之 判断语句--if else结构

Python逻辑控制语句 之 判断语句--if else结构

1.if else 的介绍 if else ：如果 ... 否则 .... 2.if else 的语法 if 判断条件: 判断条件成立，执行的代码 else: 判断条件不成立，执行的代码 （1）else 是关键字, 后⾯需要 冒号 （2）存在冒号…
阅读更多...
链表-求链表中环的入口结点（easy）

链表-求链表中环的入口结点（easy）

目录 一、问题描述 二、解题思路 三、代码实现 四、刷题链接 一、问题描述 二、解题思路 本题基本思路： 1.设置一个hashSet来存储已经访问过的链表结点地址，注意不要直接存储链表内元素，因为链表内元素可能存在重复的，地址是不…
阅读更多...
uniapp uniCloud云开发

uniapp uniCloud云开发

uniCloud概述 uniCloud 是 DCloud 联合阿里云、腾讯云、支付宝云，为开发者提供的基于 serverless 模式和 js 编程的云开发平台。 uniCloud 的 web控制台地址：https://unicloud.dcloud.net.cn 文档：https://doc.dcloud.net.cn/uniCloud/ un…
阅读更多...
【高考志愿】集成电路科学与工程

【高考志愿】集成电路科学与工程

目录 一、专业概述 二、课程设置 三、就业前景 四、适合人群 五、院校推荐 六、集成电路科学与工程专业排名 一、专业概述 集成电路科学与工程，这一新兴且引人注目的交叉学科，正在逐渐崭露头角。它集合了电子工程、计算机科学、材料科学等多个领域的…
阅读更多...
Kotlin中对空的很多处理

Kotlin中对空的很多处理

代码图片直观效果 逐行解释Kotlin中对空的各种情况的使用 private fun testNull() {val flag 1var name: String? nullvar user: User? // 有警告, 因为下面的赋值可以和这一行定义合并var zhangUser: User? User()var wangUser: User User() // 提示Explicitly given t…
阅读更多...
Unity 字体创建时候容易导致字体文件不正确的一种情况

Unity 字体创建时候容易导致字体文件不正确的一种情况

上面得到了两种字体格式，一种是TextMeshPro的，另一种是Unity UI系统中默认使用的字体资源。其原因是创建的位置不同导致的。 1.下面是TextMeshPro字体创建的位置 2：下面是Unity UI系统中默认使用的字体资源
阅读更多...
Java学习【IO流：深入理解与应用（上）】

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

Java学习【IO流：深入理解与应用（上）】 🍃1.IO流体系结构🍃2.FileOutputStream🍁2.1FileOutputStream写数据的三种方式🍁2.2换行和续写 🍃3.FileInputStream🍁3.1每次读取…
阅读更多...
pbootcms后台获取前端表单留言页面url

pbootcms后台获取前端表单留言页面url

pbootcms在线留言表单，用户在网页前端提交表单成功后，在网站后台如何获取表单留言页面的url这个参数呢？下面举例说明：首先，我们在PBootcms后台对应的表单，添加需要记录的表单字段，例如 添加liuy…
阅读更多...
微服务-网关Gateway

微服务-网关Gateway

个人对于网关路由的理解： 网关就相当于是一个项目里面的保安，主要作用就是做一个限制项。（zuul和gateway两个不同的网关） 在路由中进行配置过滤器 过滤器工厂：对请求或响应进行加工 其中filters：过滤器配置…
阅读更多...
停车场智能化管理：车位引导系统实现车位资源优化与数据分析

停车场智能化管理：车位引导系统实现车位资源优化与数据分析

随着城市汽车保有量的不断增长，停车难问题日益凸显。尤其是在高峰时段，寻找停车位和取车成为了许多车主的头疼问题。为了解决这一难题，维小帮智能车位引导系统应运而生，它利用先进的技术手段，帮助车主快速找到停车位&a…
阅读更多...
PySide(PyQt)在图像上画线

PySide(PyQt)在图像上画线

1、按鼠标左键任意画线 import sys from PySide6.QtWidgets import QApplication, QLabel, QVBoxLayout, QWidget from PySide6.QtGui import QPainter, QPixmap, QMouseEvent, QColor, QPen from PySide6.QtCore import Qt, QPointclass PaintLabel(QLabel):def __init__(self…
阅读更多...
Linux自动化交互脚本expect开发

Linux自动化交互脚本expect开发

在日常开发任务中，运行shell脚本有时候会提示输入密码的操作，如何让脚本自动输入密码呢？这时使用expect帮我们输入，Expect是基于Tcl发展而来的，它不仅可以进行交互，还可以根据程序的提示模拟标准输入&#…
阅读更多...
pytorch-01

pytorch-01

加载mnist数据集 one-hot编码实现 import numpy as np import torch x_train np.load("../dataset/mnist/x_train.npy") # 从网站提前下载数据集，并解压缩 y_train_label np.load("../dataset/mnist/y_train_label.npy") x torch.tensor(y…
阅读更多...
【JVM-01】引言

【JVM-01】引言

【JVM-01】引言 1. 什么是JVM？2. JDK、JRE、JVM比较3.常用的JVM有那些4.学习路线 1. 什么是JVM？ JVM即 Java Virtual Machine(Java虚拟机)，是Java程序运行的环境(Java 二进制字节码运行环境)。 好处： 一次编写，到处…
阅读更多...
【自然语言处理系列】掌握jieba分词器：从基础到实战，深入文本分析与词云图展示

【自然语言处理系列】掌握jieba分词器：从基础到实战，深入文本分析与词云图展示

本文旨在全面介绍jieba分词器的功能与应用，从分词器的基本情况入手，逐步解析全模式与精确模式的不同应用场景。文章进一步指导读者如何通过添加自定义词典优化分词效果，以及如何利用jieba分词器进行关键词抽取和词性标注，为后续的…
阅读更多...
Python数据分析案例48——二手房价格影响因素分析

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

案例背景 房价影响因素也是人们一直关注的问题，本次案例也适合各种学科的同学，无论你是经济管理类还是数学统计，还是电商物流类，都可以使用回归分析。通过数据分析回归分析分组聚合可视化等方法进行研究房价影响因素。 数据介绍 …
阅读更多...
【C++】数组、字符串

【C++】数组、字符串

六、数组、字符串 讨论数组离不开指针，指针基本上就是数组的一切的基础，数组和指针的相关内容参考我的C系列博文：【C语言学习笔记】四、指针_通过变量名访问内存单元中的数据缺点-CSDN博客【C语言学习笔记】三、数组-CSDN博客 1、数组就是&…
阅读更多...
高精密机械设备中滚珠导轨的表面处理工艺有哪些？

高精密机械设备中滚珠导轨的表面处理工艺有哪些？

滚珠导轨是机床传动和定位的传动元件，其表面处理方式对机床性能和使用寿命起着决定性的作用，不同的表面处理方法可以提高导轨的耐磨性、抗腐蚀性和整体性能。那么，滚珠导轨的表面处理方式有哪几种呢？ 1、磨削法：磨削技…
阅读更多...
数据结构--队列（图文）

数据结构--队列（图文）

队列是一种特殊的线性表，其核心特点是先进先出。 概念及特点： 概念 队列是一种只允许在一端进行插入数据操作，在另一端进行删除数据操作的线性表。进行插入操作的一端被称为队尾（Tail 或 Rear），进行删除…
阅读更多...
最新文章

Copyright @ 2022~2023