（6）go-micro微服务consul配置、注册中心

news2024/11/26 11:39:48

文章目录

  • 一 Consul介绍
      • 1. 注册中心Consul基本介绍
      • 2.注册中心Consul关键功能
      • 3.注册中心Consul两个重要协议
  • 二 Consul安装
      • 1.使用docker拉取镜像
  • 三 Config配置
  • 四 Consul代码编写
      • 1.设置consul配置中心
      • 2.获取consul配置中心的数据
      • 3.consul可视化界面数据编写
      • 4. main.go代码编写
  • 五 最后

一 Consul介绍

Consul是HashiCorp公司推出的开源工具，用于实现分布式系统的服务发现与配置。 Consul是分布式的、高可用的、可横向扩展的。

1. 注册中心Consul基本介绍

  • Consul是一种服务网格解决方案

  • 提供具有服务发现,配置和分段功能的全功能控制平面

  • Consul 附带-个简单的内置代理,可以开箱即用

2.注册中心Consul关键功能

  • 服务发现:

    • 客户端可以注册服务，程序可以轻松找到它们所依赖的服务

  • 运行状况检查:

    • Consul客户端可以提供任意数量的运行状况检查

  • KV 存储:

    • 应用程序可以将Consul的层级键/值存储用于任何目的，包括动态配置，功能标记，协调，领导者选举等

  • 安全服务通信:

    • Consul 可以为服务生成和分发TLS证书，建立相互的TLS连接

  • 多数据中心:

    • Consul 支持多个数据中心

3.注册中心Consul两个重要协议

  • Gossip Protocol (八卦协议)

  • Raft Protocol ( 选举协议)

对于想要学习Consul原理的，可以自行百度详细了解这两个协议。

二 Consul安装

1.使用docker拉取镜像

  • 打开终端，输入以下命令：
docekr pull consul

等待一段时间后拉取成功

  • 启动命令：
docker run -d -p 8500:8500 consul

consul会被运行在本机的8500端口上

  • 检查是否运行
docker ps
  • 可视化界面

打开浏览器，输入http://127.0.0.1:8500

image.png

三 Config配置

  • 在config目录下新建一个config.yaml

可以把配置相关信息先放在config.yaml里，之后放在consul中。

  • 编写代码：
name: "Account"
title: "账号功能"
mode: "dev"
port: 9580
version: "v0.0.1"

log:
  level: "debug"
  filename: "Account.log"
  max_size: 200
  max_age: 30
  max_backips: 7

mysql:
  host: "127.0.0.1"
  port: 3306
  user: "root"
  password: "xxx"
  dbname: "micro"
  max_open_conns: 200
  max_idle_conns: "50"

redis:
  host: "127.0.0.1"
  port: 6379
  password: "xxx"
  db: 4
  pool_size: 100

email:
  user: "xxx@qq.com"
  pass: "xxx"
  host: "smtp.qq.com"
  port: 465
  rename: "Account"

# 配置、注册中心
consul:
  host: "localhost"
  port: 8500
  prefix: "/micro/config"
  consulRegistry: "127.0.0.1:8500"

# 链路追踪
jaeger:
  serviceName: "go.micro.service.account"
  addr: "localhost:6831"

# 监控服务
prometheus:
  host: "0.0.0.0"
  port: 9089

# 限流
ratelimit:
  QPS: 1000

# 微服务
micro:
  name: "go.micro.service.account"
  version: "latest"
  address: ":9580"
  • 注意，以下字段自行修改：
    • mysql.password
    • redis.password
    • email.user
    • email.pass

四 Consul代码编写

  • 在micro目录下新建一个consul.go文件

1.设置consul配置中心

// GetConsulConfig 设置配置中心
func GetConsulConfig(host string, port int64, prefix string) (config.Config, error) {
   consulSource := consul.NewSource(
      //设置配置中心的地址
      consul.WithAddress(host+":"+strconv.FormatInt(port, 10)),
      //设置前缀，不设置默认前缀 /micro/config
      consul.WithPrefix(prefix),
      //是否移除前缀，这里是设置为true，表示可以不带前缀直接获取对应配置
      consul.StripPrefix(true),
   )
   //配置初始化
   newConfig, err := config.NewConfig()
   if err != nil {
      return newConfig, err
   }
   //加载配置
   err = newConfig.Load(consulSource)
   return newConfig, err
}

2.获取consul配置中心的数据

  • 编写结构体（嵌套结构）
type Account struct {
   Name    string `json:"name"`
   Title   string `json:"title"`
   Mode    string `json:"mode"`
   Port    int64  `json:"port"`
   Version string `json:"version"`
}

type Mysql struct {
   Host     string `json:"host"`
   User     string `json:"user"`
   Pwd      string `json:"pwd"`
   Database string `json:"database"`
   Port     int64  `json:"port"`
}

type Log struct {
   Level string `json:"level"`
   Filename string `json:"filename"`
   MaxSize int64 `json:"max_size"`
   MaxAge int64 `json:"max_age"`
   MaxBackips int64 `json:"max_backips"`
}

type Redis struct {
   Host string `json:"host"`
   Port int64 `json:"port"`
   Password string `json:"password"`
   Db int64 `json:"db"`
   PoolSize int64 `json:"pool_size"`
}

type Email struct {
   User string `json:"user"`
   Pass string `json:"pass"`
   Host string `json:"host"`
   Port int64 `json:"port"`
   Rename string `json:"rename"`
}

type Consul struct {
   Host string `json:"host"`
   Port int64 `json:"port"`
   Prefix string `json:"prefix"`
   ConsulRegistry string `json:"consulRegistry"`
}

type Jaeger struct {
   ServiceName string `json:"serviceName"`
   Addr string `json:"addr"`
}

type Prometheus struct {
   Host string `json:"host"`
   Port int64 `json:"port"`
}

type Ratelimit struct {
   QPS int64 `json:"QPS"`
}

type Micro struct {
   Name string `json:"name"`
   Version string `json:"version"`
   Address string `json:"address"`
}

type ConsulConfig struct {
   Account Account `json:"account"`
   Mysql Mysql `json:"mysql"`
   Log Log `json:"log"`
   Redis Redis `json:"redis"`
   Email Email `json:"email"`
   Consul Consul `json:"consul"`
   Jaeger Jaeger `json:"jaeger"`
   Prometheus Prometheus `json:"prometheus"`
   Ratelimit Ratelimit `json:"ratelimit"`
   Micro Micro `json:"micro"`
}
  • 获取consul数据
var(
   ConsulInfo *ConsulConfig
)

// GetAccountFromConsul 获取 consul 的配置
func GetAccountFromConsul(config config.Config, path ...string) error {
   consulData := &ConsulConfig{}
   config.Get(path...).Scan(consulData)
   ConsulInfo = consulData
   return nil
}

3.consul可视化界面数据编写

  • 点击Key/Value，再点击Create
    image.png
  • 输入项目名称： micro/config/account
  • 选择JSON
    image.png
  • 输入以下代码：
{
"account":{

"name": "Account",

"title": "账号功能",

"mode": "dev",

"port": 9580,

"version": "v0.0.1"

},
"log":{

"level": "debug",

"filename": "Account.log",

"max_size": 200,

"max_age": 30,

"max_backips": 7

},
"mysql":{

"host":"127.0.0.1",

"user":"root",

"pwd":"xxx",

"database":"micro",

"port":3306

},
"redis":{

"host": "127.0.0.1",

"port": 6379,

"password": "123456",

"db": 4,

"pool_size": 100

},
"consul":{

"host": "localhost",

"port": 8500,

"prefix": "/micro/config",

"consulRegistry": "127.0.0.1:8500"

},
"email":{

"user": "xxx@qq.com",

"pass": "xxx",

"host": "smtp.qq.com",

"port": 465,

"rename": "Account"

},
"jaeger":{

"serviceName": "go.micro.service.account",

"addr": "localhost:6831"

},
"prometheus":{

"host": "0.0.0.0",

"port": 9089

},
"ratelimit":{

"QPS": 1000

},
"micro":{

"name": "go.micro.service.account",

"version": "latest",

"address": ":9580"

}
}
  • 注意JSON格式，点击Save

4. main.go代码编写

// 1.配置中心
consulConfig, err := micro.GetConsulConfig("localhost", 8500, "/micro/config")
if err != nil {
   fmt.Printf("Init consulConfig failed, err: %v\n", err)
}
// 2.注册中心
consulRegistry := consul.NewRegistry(func(options *registry.Options) {
   options.Addrs = []string{
      "127.0.0.1:8500",
   }
})
if err := micro.GetAccountFromConsul(consulConfig, "account"); err != nil {
   fmt.Printf("Init consul failed, err: %v\n", err)
}
fmt.Println(micro.ConsulInfo)
  • 这时候，micro中的ConsulInfo可以用来使用consul中的数据了，使用 . 取数据

五 最后

  • 至此，go-micro微服务consul配置、注册中心开发工作就正式完成。

  • 接下来就开始Mysql的代码编写了，希望大家关注博主和关注专栏，第一时间获取最新内容，每篇博客都干货满满。

欢迎大家加入 夏沫の梦的学习交流 进行学习交流经验，点击 夏沫の梦学习交流

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

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

相关文章

微信小程序-页面导航

微信小程序-页面导航

小程序实现页面导航的两种方式 声明式导航(tabBar 页面&#xff0c;在app.json中配置) 在页面上声明一个<navigator>导航组件通过点击<navigator> 组件实现页面跳转 app.json中 "tabBar": {"list": [{"pagePath": "pages/home…
阅读更多...
【胖虎的逆向之路】02——Android整体加壳原理详解实现

【胖虎的逆向之路】02——Android整体加壳原理详解实现

【胖虎的逆向之路】(02)——Android整体加壳原理详解&实现 Android Apk的加壳原理流程及详解 文章目录【胖虎的逆向之路】(02)——Android整体加壳原理详解&实现前言一、加壳前的知识储备1. Android 应用的启动流程2. Android 应用的安装3. Android应用的启动流程&…
阅读更多...
09-JAVA四种引用类型?

09-JAVA四种引用类型?

在JDK1.2版之后&#xff0c;Java对引用的概念进行了扩充&#xff0c;将引用分为强引用&#xff08;Strongly Reference&#xff09;、软引用&#xff08;Soft Reference&#xff09;、弱引用&#xff08;Weak Reference&#xff09;和虚引用&#xff08;Phantom Reference&…
阅读更多...
使用Deep Q-Network学习如何玩《飞行的小鸟》游戏

使用Deep Q-Network学习如何玩《飞行的小鸟》游戏

目录概述效果需要的依赖如何运行算法原理实验输入处理网络结构训练代码概述 使用DQN实现《飞行的小鸟》游戏&#xff0c;代码可修改扩展为其他游戏&#xff0c;适合学习研究用。 效果 需要的依赖 Python 2.7 or 3 TensorFlow 0.7 pygame OpenCV-Python 如何运行 运行主函数…
阅读更多...
目标追踪综述

目标追踪综述

目标追踪综述 - 知乎目标跟踪是计算机视觉领域的一个重要问题&#xff0c;目前广泛应用在体育赛事转播、安防监控和无人机、无人车、机器人等领域。下面是一些应用的例子。 体育赛事转播 无人车 目标跟踪任务分类了解了目标跟踪的用途&#xff0c;我们接下…https://zhuanlan.z…
阅读更多...
Java(SpringBoot)项目打包(构建)成`Docker`镜像的几种方式

Java(SpringBoot)项目打包(构建)成`Docker`镜像的几种方式

前置说明 最为原始的打包方式spring-boot-maven-plugin插件jib-maven-plugin插件dockerfle-maven-plugin插件 最为原始的方式 也就是使用Docker的打包命令去打包&#xff0c;麻烦&#xff0c;我这里不多说。 spring-boot-maven-plugin插件打包 SpringBoot自己内置了一个Docker镜…
阅读更多...
有了这些软件测试面试话术，offer想不拿到都难

有了这些软件测试面试话术，offer想不拿到都难

软件测试是一个复杂且重要的技术岗位&#xff0c;因此&#xff0c;大多数互联网企业在面试时&#xff0c;都会严谨对待每一个面试者。而&#xff0c;作为即将去进行面试测试人来说&#xff0c;想要在面试中&#xff0c;沉着稳定地回答好面试官们提出的问题&#xff0c;前期的软…
阅读更多...
P5 内积 -- 通讯原理

P5 内积 -- 通讯原理

目录内积内积和傅里叶变换正交能量帕瑟瓦尔定理互能量一 内积定义&#xff1a;任意信号 内积定义为&#xff1a;如果都是实信号例&#xff1a;二 内积和傅里叶变换的关系傅里叶变换 和逆变换 本质上就是求两个函数的内积傅里叶变换傅里叶逆变换时域的内积等于频域的内积假设 则…
阅读更多...
再获殊荣！维视智造斩获2022年度光能杯最具影响力“智造”企业奖

再获殊荣！维视智造斩获2022年度光能杯最具影响力“智造”企业奖

近日&#xff0c;由光伏行业权威媒体和机构——索比光伏网、索比咨询联合主办的2022年度“光能杯”影响力大奖榜单发布&#xff0c;维视智造凭借硬件与AI算法能力、凭借在光伏行业具有创新性的智能制造产品方案与落地的标杆案例&#xff0c;斩获“2022年最具影响力“智造”企业…
阅读更多...
Windows下Canal.deployer-1.1.6安装部署

Windows下Canal.deployer-1.1.6安装部署

canal [kənl]&#xff0c;译意为水道/管道/沟渠&#xff0c;主要用途是基于 MySQL 数据库增量日志解析&#xff0c;提供增量数据订阅和消费 早期阿里巴巴因为杭州和美国双机房部署&#xff0c;存在跨机房同步的业务需求&#xff0c;实现方式主要是基于业务 trigger 获取增量变…
阅读更多...
多线程之线程控制与互斥

多线程之线程控制与互斥

1.线程的缺点有哪些&#xff1f; 第一点 健壮性低------ 一个线程挂了容易影响另外的线程 第二点 缺乏访问控制----- 不像进程是独立的&#xff0c;可以写时拷贝&#xff0c;线程随进随出有点危险哦 第三点 编写难度上升----- 编写一个多线程的代码和调试可比单线程难多了 ——…
阅读更多...
strlen 的三种模拟方法

strlen 的三种模拟方法

欢迎来到 Claffic 的博客 &#x1f49e;&#x1f49e;&#x1f49e; 前言&#xff1a; 在C/C 中&#xff0c;strlen函数是一种计算字符串长度的库函数&#xff0c;要模拟此函数有多种方法&#xff0c;这里总结三种模拟方法。 1. strlen 函数介绍 cplusplus - strlen strlen 函数…
阅读更多...
正点原子-Linux嵌入式开发学习-第二期06

正点原子-Linux嵌入式开发学习-第二期06

第十四讲&#xff1a;主频和时钟配置 分析一个芯片的时钟&#xff0c;肯定先知道它的时钟来源&#xff0c;一般来源于外部晶振&#xff0c;内部晶振很少使用 时钟来源分析 RTC的时钟并不是其他外设的晶振来源 24MHz 晶振是 I.MX6U 内核和其它外设的时钟源&#xff0c;也是我…
阅读更多...
K8s入门

K8s入门

K8s入门K8s入门k8s介绍k8s功能概述k8s架构k8s核心概念服务器配置要求部署方式使用kubeadm搭建一个k8s集群所有节点安装 Docker/kubeadm/kubeletK8s入门 你好&#xff01; 这是你第一次使用 Markdown编辑器 所展示的欢迎页。如果你想学习如何使用Markdown编辑器, 可以仔细阅读这…
阅读更多...
84.【Vue--初刷】

84.【Vue--初刷】

vue.js(一)、vue.js简介1.简介(1).MVVM模式的实现(2).为什么要使用Vue.js(3).为什么要使用MVVC2.应用场景3.JavaScipt框架(1).JQuery :(2).Angular(3).React(4).Vue(5).Axios4.UI框架【可视化】5.JavaScript 构建工具6.三端开发(1).混合开发(Hybrid App)(2).微信小程序7.后端技…
阅读更多...
LeetCode题解 回溯（一）：77 组合；216 组合总和III

LeetCode题解 回溯（一）：77 组合；216 组合总和III

回溯 从今天开始进入回溯&#xff0c;其实此前也接触过几道使用了该思想的题目 回溯的思想是“倒退到上一个状态”&#xff0c;通常结合递归&#xff0c;解决的问题多是“从众多组合中找出符合条件的组合”的问题&#xff0c;随想录中给出了题目大纲&#xff1a; 回溯算法解决…
阅读更多...
Linux学习笔记——ZooKeeper集群安装部署

Linux学习笔记——ZooKeeper集群安装部署

5.8、ZooKeeper集群安装部署 5.8.1、简介 Zookeeper是一个分布式的、开放源码的分布式应用程序协调服务&#xff0c;是Hadoop和HBase的重要组件。它是一个为分布式应用提供一致性服务的软件&#xff0c;提供的功能包括&#xff1a;配置维护、域名服务、分布式同步、组服务等。…
阅读更多...
CHAPTER 2 Docker镜像

CHAPTER 2 Docker镜像

docker镜像2.1 docker image 获取2.1.1 命令格式&#xff08;pull&#xff09;2.1.2 层(layer)2.1.3 镜像重名2.2 查看镜像信息&#xff08;ls&#xff0c;tag&#xff0c;inspect&#xff0c;history&#xff09;2.2.1 使用images命令列出镜像&#xff08;ls&#xff09;2.2.2…
阅读更多...
uni-app:小程序开发总结

uni-app:小程序开发总结

内容持续更新中~~~&#x1f618;uniapp项目起步:工具下载在Dcloud 官网上下载 HBuilderX 开发工具,以及微信开发者工具.(同时你要在微信开发者文档进行小程序注册,拿到 ID, HBuilderX 和 微信开发者工具 你都要进行注册登录)项目创建我们可以通过HBuilderX 来进行基础版的项目创…
阅读更多...
【阶段三】Python机器学习12篇：机器学习项目实战：朴素贝叶斯模型的算法原理与朴素贝叶斯分类模型

【阶段三】Python机器学习12篇：机器学习项目实战：朴素贝叶斯模型的算法原理与朴素贝叶斯分类模型

本篇的思维导图： 朴素贝叶斯模型的算法原理 朴素贝叶斯是贝叶斯模型当中最简单的一种，其算法核心为如下所示的贝叶斯公式： 其中P（A）为事件A发生的概率，P（B）为事件B发生的概率，P（A|B）表示在事件B发生的条件下事件A发生的概率，同理P（B|A）则表示在事件A发…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023