栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Spring Cloud完整组件搭建之路 第五篇 -Spring Cloud Config

Spring Cloud完整组件搭建之路 第五篇 -Spring Cloud Config

Spring Cloud完整组件搭建之路 第五篇 -Spring Cloud Config

SpringCloud配置系列目录:前置知识

配置中心包括3个部分 创建存放配置文件信息的git仓库

git文件命名规范 创建新的Spring Cloud Config工程引入相关依赖新建并编辑application.yml配置文件

创建application.yml文件编辑application.yml文件 实现自动刷新

erlang安装

配置erlang环境变量 RabbitMQ安装

启动RabbitMQ进入RabbitMQ管理界面在新建工程的配置文件application.yml添加内容 在新建工程的添加启动类相关注解Config Client(USER-PROVIDER组的微服务)配置

修改Controller方法添加配置文件内容修改配置文件名称添加相关依赖 Spring Cloud Config启动测试

Spring Cloud Config注册成功查看当前git仓库中文件内容查看当前访问请求打印信息修改git文件信息并提交查看CONFIG-SERVER服务的actuator监控信息更新USER-PROVIDER中的配置信息为git中最新的内容

打开Postman并发送post请求查看当前访问请求打印信息

书接上回【Spring Cloud完整组件搭建之路 第四篇 -Zuul】,我们搭建的微服务组件有了Eureka、OpenFeign、Ribbon、Hystrix、Zuul,并且一共已经有了六个服务,现在,有一个问题,如果我想把我微服务中所有USER-CONSUMER和USER-PROVIDER组的微服务的配置文件修改一个共同的内容,我该怎么办?一个个修改yml,并且一个个重启服务?我们现在USER-CONSUMER和USER-PROVIDER组的微服务一共就三个,操作也不麻烦,但如果一共10个呢?20个呢?

所以,我们需要一个能修改指定的所有微服务配置文件的组件,这样,我们就引入了Spring Cloud Config,接下来我们一起配置一下。

SpringCloud配置系列目录:

【Spring Cloud完整组件搭建之路-Eureka】
【Spring Cloud完整组件搭建之路 第二篇 -OpenFeign、Ribbon整合】
【Spring Cloud完整组件搭建之路 第三篇 -OpenFeign、Hystrix整合】
【Spring Cloud完整组件搭建之路 第四篇 -Zuul】

前置知识 配置中心包括3个部分
    存放配置的地方:git 等。config server。从 1 读取配置。config client。是 config server 的客户端 消费配置,也就是要修改配置文件的微服务。
创建存放配置文件信息的git仓库

就是普通创建git仓库的步骤

git文件命名规范

获取配置规则:根据前缀匹配
/{name}-{profiles}.properties
/{name}-{profiles}.yml
/{name}-{profiles}.json
/{label}/{name}-{profiles}.yml
name 服务名称
profile 环境名称,开发、测试、生产:dev qa prd
lable 仓库分支、默认master分支

我创建的文件名是user-provider-dev.yml,代表user-provider服务下的dev环境

匹配原则:从前缀开始。

创建新的Spring Cloud Config工程

根据【Spring Cloud完整组件搭建之路-Eureka】博客中的创建工程的步骤,选择Eureka Discovery Client、Config Server依赖创建完成。

引入相关依赖

    org.springframework.boot
    spring-boot-starter-actuator



    org.springframework.cloud
    spring-cloud-starter-bus-amqp
    3.1.0

新建并编辑application.yml配置文件 创建application.yml文件

在src/mian/resource目录下创建application.yml文件即可。

编辑application.yml文件
server:
  port: 8888
# 打开actuator所有监控参数
management:
  endpoints:
    web:
      exposure:
        include: '*'
# 配置git信息
spring:
  cloud:
    config:
      server:
        git:
          uri: https://gitee.com/hepai123/spring-cloud-config-center.git
          username: 账号
          password: 密码
      # git分支
      label: dev
  application:
    name: CONFIG-SERVER
# 连接eureka服务器
eureka:
  client:
    serviceUrl:
      defaultZone: http://euk-server-two.com:7000/eureka/
实现自动刷新

上面的依赖中可以看到我们引入了bus-amqp,这个是用来统一通知所有config-client来进行指定操作的,包括全部刷新本服务的配置文件信息的指令,但是amqp的底层是一个消息队列MQ,直接有这个amqp功能,也就是能和amqp无缝整合的消息中间件有Kafka和RabbitMQ,RabbitMQ面向应用级开发,Kafka则是用于大的数据文件中转开发,所以我们集成RabbitMQ就可以了,所以我们需要进行如下操作:

erlang安装

http://www.erlang.org/downloads

配置erlang环境变量

path中添加 %ERLANG_HOME%bin

RabbitMQ安装

http://www.rabbitmq.com/install-windows.html

启动RabbitMQ

在安装目录的bin目录下cmd,按顺序执行以下内容:

# 开启RabbitMQ节点
rabbitmqctl start_app

# 开启RabbitMQ管理模块的插件,并配置到RabbitMQ节点上
rabbitmq-plugins enable rabbitmq_management
进入RabbitMQ管理界面

访问地址:http://localhost:15672
用户名密码均为guest

在新建工程的配置文件application.yml添加内容
spring:
  # 配置rabbitmq信息
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
在新建工程的添加启动类相关注解
@EnableEurekaClient
@EnableConfigServer
Config Client(USER-PROVIDER组的微服务)配置 修改Controller方法

在博客【Spring Cloud完整组件搭建之路 第二篇 -OpenFeign、Ribbon整合】中,我们创建了UserProviderController测试接口类,我们将其进行修改,修改后代码如下:

import org.apache.commons.lang.builder.ToStringBuilder;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;
import java.util.Map;

@RestController
@RefreshScope
public class UserProviderController {
    @Value("${server.port}")
    private String port;
    
 	@Value("${hepai.say}")
    private String say;

    
    @RequestMapping(value = "/aliveGet",method = RequestMethod.GET)
    public String aliveGet(@RequestParam("id") Integer id){
        return id + "---"+ port + "aliveGet";
    }

    
    @RequestMapping(value = "/noParamGet",method = RequestMethod.GET)
    public String noParamGet(){
        return port + "aliveGet:" + say;
    }

    
    @RequestMapping(value = "/alivePost",method = RequestMethod.POST)
    public String alivePost(@RequestBody Map map){
        return ToStringBuilder.reflectionToString(map) + "---"+ port + "alivePost";
    }

    
    @RequestMapping(value = "/alivePostParam",method = RequestMethod.POST)
    public String alivePostParam(@RequestParam Map map){
        return ToStringBuilder.reflectionToString(map) + "---"+ port + "alivePostParam";
    }
}

代码修改点:

    添加@RefreshScope注解添加对${hepai.say}配置信息的引入对noParamGet方法的修改,打印最新say信息
添加配置文件内容

注意spring.cloud.config.profile是git文件名的最后一个杠(-)后面的内容
注意spring.cloud.config.label是要更新的git文件所在的git分支
注意spring.cloud.config.discovery.service-id是配置中心的服务名称

spring:
  # 使用git仓库中dev结尾的文件,并配置config服务器
  cloud:
    config:
      profile: dev
      label: dev
      # 可在eureka自动找寻config服务端
      discovery:
        enabled: true
        service-id: CONFIG-SERVER
  # 配置rabbitmq信息
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest
management:
  endpoints:
    # 开启Actuator监控eureka服务所有信息,不加此配置只打开health和info
    web:
      exposure:
        include: '*'
修改配置文件名称

由application.yml修改为bootstrap.yml

添加相关依赖

    org.springframework.cloud
    spring-cloud-starter-bootstrap
    3.1.0



    org.springframework.cloud
    spring-cloud-starter-bus-amqp
    3.1.0



    org.springframework.cloud
    spring-cloud-config-client
    3.1.0


   org.springframework.boot
    spring-boot-starter-actuator

Spring Cloud Config启动测试 Spring Cloud Config注册成功

查看当前git仓库中文件内容

查看当前访问请求打印信息

修改git文件信息并提交

查看CONFIG-SERVER服务的actuator监控信息

这个busrefresh就是我们要用到的自动刷新的核心方法。
现在这个时候我们的访问请求打印信息依然没有变,还是原先的内容

更新USER-PROVIDER中的配置信息为git中最新的内容 打开Postman并发送post请求

请求地址:http://config-serverIP:端口号/actuator/busrefresh

查看当前访问请求打印信息

最终,在没有重启服务的情况下,配置信息更新成功。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/706424.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号