配置中心

为什么需要配置中心

平时我们写一个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)
}

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