做钢丝绳外贸的网站,咸阳微网站建设,edge网页视频怎么下载,海口市龙华区核酸检测为什么需要配置中心
平时我们写一个demo的时候#xff0c;或者说一个单体的应用#xff0c;都会有一个配置文件#xff0c;不管是 json文件或者yaml文件#xff0c;里面包含了redis,mysql,es等信息#xff0c;如果我们修改了配置文件#xff0c;往往我们需要重启#x…为什么需要配置中心
平时我们写一个demo的时候或者说一个单体的应用都会有一个配置文件不管是 json文件或者yaml文件里面包含了redis,mysql,es等信息如果我们修改了配置文件往往我们需要重启为了避免重启后来引入了viper,可以实现热更新。但并不是所有的项目都支持viper。 如果是一个分布式系统肯定是有很多服务模块做支撑的而且服务是可伸缩的可能有几十台服务也可能有几百台服务。如果每个服务模块下面都有自己的配置文件那么如果mysql更新了端口号运维人员就得一个一个文件的改。而且还可能不小心出错了。 所以综上对于服务的配置大概有这么三个痛点
修改配置项后需要重启服务对于生产环境来说这是不能接受的。运维人员需要到各个项目下修改配置文件。效率低不安全。一般公司中都有开发环境、测试环境、预生产环境以及生产环境。不同环境下的配置如何隔离
为了解决上面的问题配置中心应运而生。那么什么是配置中心呢
配置中心
配置统一管理 配置项的修改编辑统一在配置中心页面进行还包括统一的配置版本管理、环境隔离、灰度发布以及热发布在不重启应用的情况下使得修改的配置可以生效起作用。权限统一控制 主要控制其配置的读取权限以及修改权限通过统一的权限管理提升运维效率。操作统一审计 记录用户操作修改配置的历史信息这样在出现问题的时候可以进行复盘回查同时进行操作审计。
配置中心的选型
目前最主流的分布式配置中心主要是有spring cloud config apollo和nacosspring 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 --privilegedtrue -e JVM_XMS256m -e JVM_XMX256m -e MODEstandalone nacos/nacos-server:latest
-d 后台启动--name 为容器指定名称-p指定端口号–privilegedtrue 扩大容器内的权限将容器内的权限变为root权限-e JVM_XMS256m 为jvm启动时分配的内存-e JVM_XMX256m 为jvm运行过程中分配的最大内存-e MODEstandalone 使用 standalone模式单机模式,MODE值有cluster集群模式/standalone模式两种MODE必须大写
控制台
启动后访问http://127.0.0.1:8848/nacos/ 组 配置集 命名空间
我们新建一个配置看一下 命名空间
我们可以通过命名空间区分不同的微服务 组
我们通过命名空间可以实现服务的隔离但是我们怎么把开发、测试和生成环境的配置也隔离起来呢。这就用到了组
dataid
一般来说一个配置文件对应一个dataid,单并不是说dataid必须是唯一的我们只要保证NamespaceGroupDataId组合是唯一的即可
通过api访问nacos
相关参考
nacos作为配置中心我们最长用的就是下面几个功能 此处我们举一个例子获取user的dev的配置文件其中dataId对应的就是dataIdgroup是分组tenant是命名空间的id
$ curl -X GET http://127.0.0.1:8848/nacos/v1/cs/configs?dataIduser-devgroupdevtenant311387f1-790b-4045-8787-571addb6c9fd
database:driver: mysqlhost: 192.168.2.251port: 13309username: testdbname: cnk_userpassword: user
更新文件 $ curl -X POST http://127.0.0.1:8848/nacos/v1/cs/configs -d dataIduser-devgroupdevtenant311387f1-790b-4045-8787-571addb6c9fdcontenttest
true在这里插入图片描述
在Go中的集成
我们在go中怎么使用呢我们看一下简单的代码
package mainimport (fmtgithub.com/nacos-group/nacos-sdk-go/clientsgithub.com/nacos-group/nacos-sdk-go/common/constantgithub.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) //字符串 - yamlerr 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 dataIduser-devgroupdevtenant311387f1-790b-4045-8787-571addb6c9fdcontenttest1111
true看到修改的文件已经被监控到了 那么我们怎么解析和修改yaml文件呢比如我们现在有这样一个配置 我们先把它解析成一个结构体再进行解析
package mainimport (fmtgithub.com/nacos-group/nacos-sdk-go/clientsgithub.com/nacos-group/nacos-sdk-go/common/constantgithub.com/nacos-group/nacos-sdk-go/vogopkg.in/yaml.v2
)func main() {ch : make(chan int)ch - 1
}type DatabaseNew struct {Driver string yaml:driverHost string yaml:hostPort int yaml:portUsername string yaml:usernameDbname string yaml:dbnamePassword string yaml:password
}
type ConfigNew struct {Database DatabaseNew//数据库的配置
}var GlobalConfig ConfigNewfunc 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)
}
我们通过控制台面板修改配置
