go集成nacos配置中心并读取配置信息

2023-05-29 20:32:52 313 林溪

配置中心

为什么需要配置中心

平时我们写一个demo的时候,或者说一个单体的应用,都会有一个配置文件,不管是 json文件或者yaml文件,里面包含了redis,mysql,es等信息,如果我们修改了配置文件,往往我们需要重启,为了避免重启,后来引入了viper,可以实现热更新。但并不是所有的项目都支持viper。 如果是一个分布式系统,肯定是有很多服务模块做支撑的,而且服务是可伸缩的,可能有几十台服务,也可能有几百台服务。如果每个服务模块下面都有自己的配置文件,那么如果mysql更新了端口号,运维人员就得一个一个文件的改。而且还可能不小心出错了。 所以综上,对于服务的配置,大概有这么三个痛点

  • 修改配置项后需要重启服务,对于生产环境来说,这是不能接受的。
  • 运维人员需要到各个项目下修改配置文件。效率低,不安全。
  • 一般公司中都有开发环境、测试环境、预生产环境以及生产环境。不同环境下的配置如何隔离?

为了解决上面的问题,配置中心应运而生。那么什么是配置中心呢?

配置中心

  • 配置统一管理 配置项的修改编辑统一在配置中心页面进行,还包括统一的配置版本管理、环境隔离、灰度发布以及热发布,在不重启应用的情况下使得修改的配置可以生效起作用。
  • 权限统一控制 主要控制其配置的读取权限以及修改权限,通过统一的权限管理提升运维效率。
  • 操作统一审计 记录用户操作修改配置的历史信息,这样在出现问题的时候可以进行复盘回查,同时进行操作审计。

配置中心的选型

目前最主流的分布式配置中心主要是有spring cloud config apollo和nacos,spring cloud属于java的spring体系,我们就考虑apollo和nacos。apollo与nacos 都为目前比较流行且维护活跃的2个配置中心。apollo是协程开源,nacos是阿里开源

  • apollo大而全,功能完善。nacos小而全,可以对比成diango和flask的区别
  • 部署nacos更加简单。
  • nacos不止支持配置中心还支持服务注册和发现。
  • 都支持各种语言,不过apollo是第三方支持的,nacos是官方支持各种语言,所以我们也选用nacos作为配置中心

Nacos

  • 安装 为了方便,我们直接使用docker开启Nacos服务
docker run -d --name nacos -p 8848:8848   --privileged=true -e JVM_XMS=256m -e JVM_XMX=256m -e MODE=standalone nacos/nacos-server:latest

  • -d 后台启动
  • --name 为容器指定名称
  • -p指定端口号
  • –privileged=true : 扩大容器内的权限,将容器内的权限变为root权限
  • -e JVM_XMS=256m : 为jvm启动时分配的内存
  • -e JVM_XMX=256m : 为jvm运行过程中分配的最大内存
  • -e MODE=standalone : 使用 standalone模式(单机模式),MODE值有cluster(集群)模式/standalone模式两种,MODE必须大写
控制台
  • 启动后访问http://127.0.0.1:8848/nacos/

组 配置集 命名空间

我们新建一个配置看一下

命名空间

  • 我们可以通过命名空间区分不同的微服务

  • 我们通过命名空间可以实现服务的隔离,但是我们怎么把开发、测试和生成环境的配置也隔离起来呢。这就用到了组

dataid

  • 一般来说,一个配置文件,对应一个dataid,单并不是说dataid必须是唯一的,我们只要保证Namespace+Group+DataId组合是唯一的即可

通过api访问nacos

相关参考

  • nacos作为配置中心,我们最长用的就是下面几个功能
  • 此处我们举一个例子,获取user的dev的配置文件,其中dataId对应的就是dataId,group是分组,tenant是命名空间的id
$   curl -X GET 'http://127.0.0.1:8848/nacos/v1/cs/configs?dataId=user-dev&group=dev&tenant=311387f1-790b-4045-8787-571addb6c9fd'
database:
  driver: mysql
  host: 192.168.2.251
  port: 13309
  username: test
  dbname: cnk_user
  password: user

  • 更新文件
 $   curl -X POST 'http://127.0.0.1:8848/nacos/v1/cs/configs' -d 'dataId=user-dev&group=dev&tenant=311387f1-790b-4045-8787-571addb6c9fd&content=test'
true
在这里插入图片描述

在Go中的集成

  • 我们在go中怎么使用呢?我们看一下简单的代码
package main

import (
 "fmt"
 "github.com/nacos-group/nacos-sdk-go/clients"
 "github.com/nacos-group/nacos-sdk-go/common/constant"
 "github.com/nacos-group/nacos-sdk-go/vo"
)

func main() {
 ch:=make(chan int)
 ch<-1
}

func init() {
 sc := []constant.ServerConfig{{
  IpAddr: "127.0.0.1",
  Port:   8848,
 }}

 cc := constant.ClientConfig{
  NamespaceId:         "311387f1-790b-4045-8787-571addb6c9fd", // 如果需要支持多namespace,我们可以场景多个client,它们有不同的NamespaceId。当namespace是public时,此处填空字符串。
  TimeoutMs:           5000,
  NotLoadCacheAtStart: true,
  LogDir:              "log",
  CacheDir:            "cache",
  LogLevel:            "debug",
 }

 configClient, err := clients.CreateConfigClient(map[string]interface{}{
  "serverConfigs": sc,
  "clientConfig":  cc,
 })
 if err != nil {
  fmt.Println(err.Error())
 }

 content, err := configClient.GetConfig(vo.ConfigParam{
  DataId: "user-dev",
  Group:  "dev",
 })

 if err != nil {
  fmt.Println(err.Error())
 }
 fmt.Println(content) //字符串 - yaml
 err = configClient.ListenConfig(vo.ConfigParam{
  DataId: "user-dev",
  Group:  "dev",
  OnChange: func(namespace, group, dataId, data string) {
   fmt.Println("配置文件发生了变化...")
   fmt.Println("group:" + group + ", dataId:" + dataId + ", data:" + data)
  },
 })
}

  • 我们通过api去修改配置文件
$ curl -X POST 'http://127.0.0.1:8848/nacos/v1/cs/configs' -d 'dataId=user-dev&group=dev&tenant=311387f1-790b-4045-8787-571addb6c9fd&content=test1111'
true
  • 看到修改的文件已经被监控到了
  • 那么我们怎么解析和修改yaml文件呢?比如我们现在有这样一个配置
  • 我们先把它解析成一个结构体,再进行解析
package main

import (
 "fmt"
 "github.com/nacos-group/nacos-sdk-go/clients"
 "github.com/nacos-group/nacos-sdk-go/common/constant"
 "github.com/nacos-group/nacos-sdk-go/vo"
 "gopkg.in/yaml.v2"
)

func main() {
 ch := make(chan int)
 ch <- 1
}

type DatabaseNew struct {
 Driver   string `yaml:"driver"`
 Host     string `yaml:"host"`
 Port     int    `yaml:"port"`
 Username string `yaml:"username"`
 Dbname   string `yaml:"dbname"`
 Password string `yaml:"password"`
}
type ConfigNew struct {
 Database DatabaseNew//数据库的配置
}

var GlobalConfig ConfigNew

func init() {
 sc := []constant.ServerConfig{{
  IpAddr: "127.0.0.1",
  Port:   8848,
 }}

 cc := constant.ClientConfig{
  NamespaceId:         "311387f1-790b-4045-8787-571addb6c9fd", // 如果需要支持多namespace,我们可以场景多个client,它们有不同的NamespaceId。当namespace是public时,此处填空字符串。
  TimeoutMs:           5000,
  NotLoadCacheAtStart: true,
  LogDir:              "log",
  CacheDir:            "cache",
  LogLevel:            "debug",
 }

 configClient, err := clients.CreateConfigClient(map[string]interface{}{
  "serverConfigs": sc,
  "clientConfig":  cc,
 })
 if err != nil {
  fmt.Println(err.Error())
 }

 content, err := configClient.GetConfig(vo.ConfigParam{
  DataId: "user",
  Group:  "prod",
 })
 SetConfig(content)

 if err != nil {
  fmt.Println(err.Error())
 }
 err = configClient.ListenConfig(vo.ConfigParam{
  DataId: "user",
  Group:  "prod",
  OnChange: func(namespace, group, dataId, data string) {
   fmt.Println("配置文件发生了变化...")
   fmt.Println("group:" + group + ", dataId:" + dataId + ", data:" + data)
   SetConfig(data)
  },
 })
}

func SetConfig(content string) {
 fmt.Println(content)
 err := yaml.Unmarshal([]byte(content), &GlobalConfig)
 if err != nil {
  fmt.Println(err)
 }
 fmt.Printf("%+v", GlobalConfig)
}

我们通过控制台面板修改配置

在这里插入图片描述