SpringCloudConfig是什么?
SpringCloudConfig为微服务架构中的微服务提供集中化的外部配置支持,配置服务器为各个不同微服务应用的所有环境提供了一个中心化的外部配置.
SpringCloudConfig为分布式系统中的外部配置提供服务器和客户端支持。Config Server在所有环境中管理应用程序的外部属性。服务器存储后端的默认使用git,支持标签版本的配置环境。
最简单的配置中心就是启动一个服务作为服务方,之后各个需要获取配置的服务作为客户端来这个服务方获取配置。
1.在github创建仓库springcloud-config,在master分支下创建两个文件:config-dev.yml,config-test.yml对应实际开发中的测试分支和开发分支.
服务端获取github上的配置信息
创建SpringBoot项目,作为服务端,项目名称:springcloud-config-server-3344
1.pom.xml中引入maven依赖
2.创建bootstrap.yml,application.yml.
bootstrap.yml和application.yml两个文件的区别:
application.yml是用户级别的配置项
bootstrap.yml是系统级别的,优先级更高。
Spring Cloud会创建一个“Bootstrap Context”,作为Spring应用的Application Context的上下文,初始化的时候,Bootstrap负责从外部源加载配置属性并解析配置,这两个上下文共享一个从外部获取的Environment。Bootstrap属性有更高的优先级,默认情况下,他们不会被本地配置覆盖。BootstrapContext和AppliactionContext有着不同的约定,所以新增了一个bootstrap.yml文件,保证Bootstrap.Context和ApplicationContext的配置分离.
要将Client模块下的application.yml文件改为application.yml是很关键的。因为bootstrap.yml是比application.yml先加载的,而且优先级更高。
3.SpringCloudConfigServer启动类
4.运行,测试。Server获取github上的配置信息。
Spring Cloud Config 有它的一套访问规则,通过这套规则在浏览器上直接访问就可以。
/{application}/{profile}[/{label}]
/{application}-{profile}.yml
/{label}/{application}-{profile}.yml
/{application}-{profile}.properties
/{label}/{application}-{profile}.properties
{application} 就是应用名称,对应到配置文件上来,就是配置文件的名称部分.
{profile} 就是配置文件的版本,项目有开发版本、测试环境版本、生产环境版本,对应到配置文件上来就是以 application-{profile}.yml 加以区分,例如application-dev.yml、application-sit.yml、application-prod.yml。
{label} 表示 git 分支,默认是 master 分支,如果项目是以分支做区分也是可以的,那就可以通过不同的 label 来控制访问不同的配置文件了
客户端从服务端获取GitHub上的配置信息
1.创建Client项目,名称springcloud-config-client-3355,从服务端springcloud-config-server-3344获取配置信息。
(1)pom.xml导入maven依赖。客户端导入的是config,服务端导入server
(2)创建bootstrap.yml,application.yml
label:对应GitHub上的分支;name:文件的名称;profile:文件版本后缀;uri:服务端访问连接.拼凑起来就是之前测试的链接http://localhost:3344/config-dev.yml
(3)创建controller包,创建ConfigController类,属性对应github文件里面的字段
(4)创建SpringCloudConfigClient启动类
(5)运行,测试http://localhost:3355/configInfo,客户端从服务端获取GitHub上的配置信息
通过以上步骤,client可以通过server获取GitHub上的配置信息。但是当配置改变是,client不能立刻反应过来,即时刷新。
spring cloud bus实现自动刷新配置
Spring Cloud Bus提供了批量刷新配置的机制,它使用轻量级的消息代理(例如RabbitMQ、Kafka等)连接分布式系统的节点,这样就可以通过Spring Cloud Bus广播配置的变化或者其他的管理指令。
什么是总线
在微服务架构的系统中,通常会使用轻量级的消息代理来构建一个共用的消息主题,并让系统中所有微服务实例都连接上来。由于该主题中产生的消息会被所有实例监听和消费,所以称它为消息总线,在总线上的各个实例,都可以方便地广播一些需要让其他连接在该主题上的实例都知道的消息。
基本原理
ConfigClient实例都监听MQ中同一个topic(默认是SpringCloudBus)当一个服务刷新数据的时候,它会把这个信息放入topic中,这样其他监听同一Topic的服务就能得到通知,然后去更新自身的配置。
(1)安装RabbitMQ,配置环境。
什么是RabbitMQ
两个(多个)系统间需要通过定时任务来同步某些数据,异构系统的不同进程间相互调用、通讯,消息服务让你可以解决这些问题。
消息服务擅长于解决多系统、异构系统间的数据交换(消息通知/通讯)问题,也可以把它用于系统间服务的相互调用(RPC)。RabbitMQ就是当前最主流的消息中间件之一。
1.RabbitMQ是一个由erlang开发的AMQP(Advanced Message Queue 高级消息队列协议 )的开源实现,能够实现异步消息处理
(1)RabbitMQ是一个消息代理:它接受和转发消息。
优点:异步消息处理
业务解耦错峰流控
灵活的路由(Flexible Routing) :在消息进入队列之前,通过 Exchange 来路由消息的。对于典型的路由功能,RabbitMQ 已经提供了一些内置的 Exchange 来实现。针对更复杂的路由功能,可以将多个 Exchange 绑定在一起,也通过插件机制实现自己的 Exchange 。
RabbitMQ网站端口号:15672,程序里面实现的端口为:5672
(2)queue队列
Queue(队列)RabbitMQ的作用是存储消息,队列的特性是先进先出。生产者生产消息最终被送到RabbitMQ的内部对象Queue中去,而消费者则是从Queue队列中取出数据。
(3)消息队列
消息(Message)是指在应用间传送的数据。消息可以非常简单,比如只包含文本字符串,也可以更复杂,可能包含嵌入对象。
消息队列(Message Queue)是一种应用间的通信方式,消息发送后可以立即返回,
由消息系统来确保消息的可靠传递。消息发布者只管把消息发布到 MQ 中而不用管谁来取,消息使用者只管从 MQ 中取消息而不管是谁发布的。这样发布者和使用者都不用知道对方的存在。
(4)消息队列中间件:kafka rabbitMQ activeMQ rocketMQ(可以处理分布式事务)
2.在第一个项目springcloud-config-server-3344中添加入动态刷新功能
2.1pom.xml增加bus依赖
2.2bootstrap.yml增加rabbitmq配置和热部署
启动类不用进行修改
3.在第二个项目springcloud-config-3355中引入动态刷新功能
3.1pom.xml引入一样的依赖
3.2bootstrap.yml
3.3Contrller类中加入@RefreshScope注解
(4)开始测试
4.1启动rabbit-server
4.2修改github上的配置信息
4.3打开cmd,运行curl -X POST "http://localhost:3344/actuator/bus-refresh"前面一部分是访问服务端的连接
4.4刷新客户端页面,查看是否更新
5.定点局部刷新,某些客户端的配置更新,某些不更新。在POST请求后面加上特定更新的客户端名称和端口号。
curl -X POST "http://localhost:3344/actuator/bus-refresh/config-client:3355"