SpringCloud系列之分布式配置中心学习

　　1、分布式配置中心简介
　　在实际的项目开发中，配置文件是使用比较多的，很多项目有测试环境（TEST）、开发环境（DEV）、规范的项目还有集成环境（UAT）、生产环境（PROD），每个环境就一个配置文件。
　　这个在单体应用的项目里是没什么问题，如果是分布式微服务项目，就会有很多的模块，比如微服务A、微服务B等等，每个工程都有一套配置文件，随着业务增长，肯定会有很多配置，分散管理，不能实现统一的管理，所以就有了微服务的配置文件统一管理组件，比如springcloud官方的springcloudconfig、携程的Apollo，还有最近比较火的阿里nacos，每款产品各有自己的特点，不过本博客只介绍springcloudconfig
　　作为一款分布式的配置中心，其基本的功能应该有统一的配置文件管理，至于怎么存储可以自行设计，客户端可以从配置中心下拉配置数据，还有一个重要功能就是推送，有了推送功能，才能做到将数据统一发给客户端及时更新，总不能让客户端自己pull，如果在客户端很多的情况，这种肯定是不合理的，简单画图表示：
　　2、什么是SpringCloudConfig？
　　ok，前面简单介绍了分布式配置中心的基本概念，现在看看springcloud提供的这块分布式配置中心springcloudconfig是怎么设计？简单归纳其特点：文件存储：默认Git仓库（github、gitlab等等）版本关联：默认Git权限控制：需要Git支持多环境（profile）：配置文件指定动态更新：需要基于Springcloudconfigbus定时更新：需要自行拓展管理后台：默认不带
　　所以有一个明显的特点，springcloudconfig默认就是基于git仓库来实现配置文件统一管理的，所以很明显其有如下角色：配置仓库：git仓库配置服务端：configserver，负责从git仓库下拉配置文件到本地，然后可以统一推送给客户端配置客户端：各微服务业务客户端，可以从配置服务端pull配置数据
　　ok，简单画图表示其架构，如图所示：
　　3、例子实验环境准备
　　环境准备：JDK1。8SpringBoot2。2。3SpringCloud（Hoxton。SR7）Maven3。2开发工具IntelliJIDEAsmartGit
　　github远程仓库创建，可以在github上创建一个springCloudExamples项目，然后新建一个文件夹，命名为configrepository4、ConfigServer代码实现
　　创建一个SpringBootInitialize项目，详情可以参考我之前博客：SpringBoot系列之快速创建项目教程
　　如图：选择configServer
　　也可以自行在maven引入如下配置：dependencygroupIdorg。springframework。cloudgroupIdspringcloudconfigserverartifactIddependency
　　使用注解EnableConfigServer表示这个config服务端工程packagecom。example。springcloud。server；importorg。springframework。boot。SpringApplication；importorg。springframework。boot。autoconfigure。SpringBootApplication；importorg。springframework。cloud。config。server。EnableConfigServer；SpringBootApplicationEnableConfigServerpublicclassSpringcloudConfigServerApplication｛publicstaticvoidmain（String〔〕args）｛SpringApplication。run（SpringcloudConfigServerApplication。class，args）；｝｝
　　新建bootstrap。yml配置文件，指定github仓库的地址：server：port：8761spring：application：name：springcloudconfigservercloud：config：server：git：uri：https：github。comyourgithubaccountspringCloudExamplesusername：yourgithubaccountpassword：yourgithubpasswordsearchpaths：configrepository5、ConfigClient代码实现
　　同样新建SpringBootInitialize项目，快速创建
　　pom配置文件：dependencygroupIdorg。springframework。bootgroupIdspringbootstarterwebartifactIddependencydependencygroupIdorg。springframework。cloudgroupIdspringcloudstarterconfigartifactIddependency
　　yaml配置，uri指定为configserver的地址，profile是环境变量，可以指定为dev（开发环境），label表示分支，master是指github的主干分支server：port：8082spring：application：name：springcloudconfigclientcloud：config：uri：http：127。0。0。1：8761profile：devlabel：master
　　然后，我们要在github仓库新建配置文件：命名规范必须是客户端的spring。application。name加上profile
　　在配置文件，随便写点：config。client。profilespringcloudconfigclientdev
　　测试：要先启动configserver，然后再启动configclient，写个例子测试，要加上RefreshScope实现刷新功能RestControllerRefreshScopepublicclassConnfigClientController｛Value（｛config。client。profile｝）privateStringprofile；GetMapping（valuetest）publicStringtest（）｛returnthis。profile；｝｝
　　启动SpringBoot项目，测试：
　　在configserver启动过程，可以看到configserver从github下拉配置文件到本地缓存，具体是C盘AppData目录
　　6、客户端pull刷新实现
　　客户端要实现下拉配置数据，怎么实现？可以集成springbootstarteractuator来实现：
　　pom配置：dependencygroupIdorg。springframework。bootgroupIdspringbootstarteractuatorartifactIddependency
　　springbootstarteractuator配置：include加上rehresh配置management：endpoints：web：前缀名，默认也是actuatorbasepath：actuator默认只开放info，health的方式访问，加上refreshexposure：include：info，health，refreshendpoint：health：showdetails：alwaysrefresh：enabled：true
　　访问客户端的链接，注意要用post方式，http：localhost：8082actuatorrefresh
　　github配置文件没更新的情况：
　　修改配置文件，commit和push到github
　　调用接口时候，可以看到configclient从configserver获取数据：
　　7、消息总线SpringCloudBus什么是总线？
　　在微服务架构的系统中，通常会使用轻量级的消息代理来构建一个共用的消息主题，并让系统中所有微服务实例都链接上来。由于该主题中产生的消息会被所有实例监听和消费，所以称它为消息总线。什么是SpringCloudBus？
　　SpringCloudBus是用来将分布式系统的节点与轻量级消息系统链接起来的框架，它整合了Java的事件处理机制和消息中间件的功能
　　SpringCloudBus能管理和传播分布式消息间的消息，就像一个分布式执行器，可用于广播状态更改、事件推送等，也可以当作微服务间的通信通道
　　看了理论，貌似不理解？所以还是从前面学习说起，前面介绍说明作为一个分布式的配置中心，至少应该有推送消息的功能，所以这个配置中心的角色可以由configserver充当，实现的效果是configserver（配置中心）一刷新数据，客户端都能同步更新，画图进行说明：
　　1、配置中心（configserver）执行busrefresh，springcloudbus提供的刷新接口，配置中心就从git仓库下拉数据到本地git仓库2、执行busrefresh之后，将消息发给springcloudbus（消息总线），消息总线将消息写到消息队列（rabbitMQ）的topic中3、只要订阅这个消息队列topic的都能监听到springcloudbus的消息（基于rabbitmq）4、监听到之后，configclient从configserverpull更新配置数据
　　其实简而言之，ConfigClient实例都监听RabbitMQ中同一个topic，当一个服务刷新数据的时候，它会把这个信息放入到Topic中，这样其它监听同一Topic的服务就能得到通知，然后去更新自身的配置，当然这个刷新操作不一定要放在configserver，也可以放在某个客户端触发，只要将消息发送给消息总线就可以8、Docker安装部署RabbitMQ
　　主要介绍一下Docker版本，常用的docker镜像操作：
　　查询rabbitMQ镜像：
　　management版本，不指定默认为最新版本latestdockersearchrabbitmq：management
　　拉取镜像：dockerpullrabbitmq：management
　　查看docker镜像列表：dockerimages
　　Docker容器操作：
　　ok，上面命令执行后，镜像就已经拉取到本地仓库了，然后可以进行容器操作，启动rabbitMQ
　　简单版dockerrundp5672：5672p15672：15672namerabbitmqrabbitmq：management1d后台运行p隐射端口name指定rabbitMQ名称
　　复杂版（设置账户密码，hostname）dockerrundp15672：15672p5672：5672eRABBITMQDEFAULTUSERadmineRABBITMQDEFAULTPASSadminnamerabbitmqhostnamerabbitmqhostonerabbitmq：management1d后台运行p隐射端口name指定rabbitMQ名称RABBITMQDEFAULTUSER指定用户账号RABBITMQDEFAULTPASS指定账号密码
　　执行如上命令后访问：http：ip：15672
　　默认账号密码：guestguest
　　其它常用容器命令：
　　查看运行中的容器查看所有的容器用命令dockerpsadockerps
　　启动容器eg：dockerstart9781cb2e64bddockerstartCONTAINERID〔容器ID〕
　　stop容器dockerstopCONTAINERID〔容器ID〕
　　删除一个容器dockerrmCONTAINERID〔容器ID〕
　　查看Docker容器日志eg：dockerlogs9781cb2e64bddockerlogscontainername〔容器名〕containerid〔容器ID〕9、SpringCloudBus动态刷新
　　有了前面的学习，接着进行代码例子实践，configserverpom配置：dependencygroupIdorg。springframework。bootgroupIdspringbootstarteractuatorartifactIddependencydependencygroupIdorg。springframework。cloudgroupIdspringcloudstarterbusamqpartifactIddependency
　　yaml配置：开放busrefreshmanagement：endpoints：web：basepath：actuatorexposure：include：info，health，refresh，busrefreshendpoint：health：showdetails：alwaysrefresh：enabled：true
　　加上rabbitmq配置RabbitMQ配置rabbitmq：host：192。168。6。155port：5672username：guestpassword：guest
　　ConfigClient代码例子改造，pom配置：dependencygroupIdorg。springframework。cloudgroupIdspringcloudstarterbusamqpartifactIddependency
　　也要加上rabbitMQ配置，这样才能订阅更新：RabbitMQ配置rabbitmq：host：192。168。6。155port：5672username：guestpassword：guestvirtualhost：
　　客户端必须修改，refresh、enabled都要改为true，trace是进行跟踪的，可以根据需要开启spring：cloud：bus：enabled：truerefresh：enabled：truetrace：enabled：true
　　注意点：为了实时更新，必须加上RefreshScope
　　配置中心进行busrefresh
　　订阅的客户端都进行实时更新：