前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >微服务配置 Config 与消息总线

微服务配置 Config 与消息总线

作者头像
wsuo
发布2020-10-10 11:14:14
5370
发布2020-10-10 11:14:14
举报
文章被收录于专栏:技术进阶之路

所以我们需要一个模块作为分布式配置中心,供其他服务调用。


他有如下几个作用:

  1. 不同环境不同配置,动态化的配置更新,分环境部署比如 dev/test/prod/beta/release
  2. 运行期间动态调整配置,不再需要在每个服务部署的机器上编写配置文件,服务会向配置中心统一拉取配置自己的信息;
  3. 当配置发生变动时,服务 不需要重启 即可感知到配置的变化并应用新的配置。

服务端编码实现

首先在 pom 中引入依赖:

代码语言:javascript
复制
<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-config-server</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
        <scope>runtime</scope>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

然后配置信息,这里主要是指定 github 上的配置文件仓库地址:

代码语言:javascript
复制
server:
  port: 3344
spring:
  application:
    name: cloud-config-center
  cloud:
    config:
      server:
        git:
          uri:  https://github.com/wsuo/springcloud-config.git
          search-paths:
            - springcloud-config
      label: master
eureka:
  client:
    service-url:
      defaultZone:  http://localhost:7001/eureka

然后编写主启动类即可启动项目:

代码语言:javascript
复制
@SpringBootApplication
@EnableConfigServer
@EnableEurekaClient
public class ConfigCenterMain3344 {
    public static void main(String[] args) {
        SpringApplication.run(ConfigCenterMain3344.class, args);
    }
}

启动之后访问 http://localhost:3344/master/config-dev.yml 查看打印出来的信息:

这正是我们在 git 仓库中的文件内容。

代码语言:javascript
复制
/master/config-dev.yml

这种写法是读取配置的规则。

能访问到信息就说明搭建成功了,到此为止服务端创建完成。


客户端编码实现

首先导入 pom 依赖:

代码语言:javascript
复制
<dependencies>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-config</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
        <scope>runtime</scope>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

接下来要引入一个 bootstrap yml 文件。

文件的内容配置如下:

代码语言:javascript
复制
server:
  port: 3355

spring:
  application:
    name: config-client
  cloud:
    config:
      label: master
      name: config
      profile: dev
      uri: http://localhost:3344
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka

然后我们写完主启动类之后编写一个接口:

代码语言:javascript
复制
@SpringBootApplication
@EnableEurekaClient
public class ConfigClientMain3355 {
    public static void main(String[] args) {
        SpringApplication.run(ConfigClientMain3355.class, args);
    }
}


@RestController
@Slf4j
public class ConfigClientController {

    @Value("${config.info}")
    private String configInfo;

    @GetMapping("/configInfo")
    public String getConfigInfo() {
        return configInfo;
    }
}

该接口可以读取到从远程仓库中获取的配置信息。

我们先在本地修改 version=2 ,然后提交到 git

这个时候启动 3355 作为客户端。

访问之后查看结果:

但是如果此时我们再次修改文件的内容,那么此时 3344 只需刷新页面之后就能显示出新的数据,但是 3355 需要重启服务器才行。

  1. 修改 GitHub 上的配置文件内容做调整;
  2. ConfigServer 配置中心 立刻响应;
  3. ConfigServer 客户端 没有任何响应。

这样肯定是不行的,所以我们需要修改配置。

动态刷新

我们需要使用动态刷新解决客户端配置不同步的问题。

首先我们要确保在 3355 模块中有这个依赖,它负责监控:

代码语言:javascript
复制
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

bootstrap.yml 中添加配置,起到暴露端口的作用:

代码语言:javascript
复制
management:
  endpoints:
    web:
      exposure:
        include: "*"

然后在控制器上添加一个 @RefreshScope 注解:

代码语言:javascript
复制
@RestController
@Slf4j
@RefreshScope
public class ConfigClientController {

    @Value("${config.info}")
    private String configInfo;

    @GetMapping("/configInfo")
    public String getConfigInfo() {
        return configInfo;
    }
}

但是此时刷新 3355 客户端改动还是不能动态生效。

这个时候我们需要发一个 POST 请求激活一下:

代码语言:javascript
复制
curl -X POST "http://localhost:3355/actuator/refresh"

但是每次都发一次请求去激活配置未免太麻烦,我们可以使用消息总线来完成广播。

消息总线

Spring Cloud Bus 配合 Spring Cloud Config 使用可以实现配置的动态刷新:

Bus 支持两种消息代理: RabbitMQKafka

它又两种方式,一种是将消息推送到一个主机上,然后让主机根据局域网传播给其他主机,另一种方式是直接推送到配置中心上,让配置中心发送给其他主机。

首先我们需要启动 RabbitMQ。

  1. 进入安装目录的 sbin 目录,PS D:\develop\RabbitMQ\RabbitMQ_Server\rabbitmq_server-3.7.4\sbin>
  2. 输入命令启动服务 rabbitmq-plugins enable rabbitmq_management

这个时候在浏览器访问 http://localhost:15672/ 即可看到页面。

给 3344 配置中心服务端添加消息总线支持:

在服务端添加一依赖:

代码语言:javascript
复制
<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

修改配置文件:

代码语言:javascript
复制
server:
  port: 3344
spring:
  application:
    name: cloud-config-center
  cloud:
    config:
      server:
        git:
          uri:  https://github.com/wsuo/springcloud-config.git
          search-paths:
            - springcloud-config
      label: master
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

eureka:
  client:
    service-url:
      defaultZone:  http://localhost:7001/eureka

management:
  endpoints:
    web:
      exposure:
        include: 'bus-refresh'

然后给客户端的 pomyml 文件也添加同样的内容。

最后我们启动服务,执行下面的命令向配置中心发送 POST 请求,即可激活所有的客户端,即动态刷新。

代码语言:javascript
复制
curl -X POST "http://localhost:3344/actuator/bus-refresh"
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2020/09/29 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 服务端编码实现
  • 客户端编码实现
  • 动态刷新
  • 消息总线
相关产品与服务
微服务引擎 TSE
微服务引擎(Tencent Cloud Service Engine)提供开箱即用的云上全场景微服务解决方案。支持开源增强的云原生注册配置中心(Zookeeper、Nacos 和 Apollo),北极星网格(腾讯自研并开源的 PolarisMesh)、云原生 API 网关(Kong)以及微服务应用托管的弹性微服务平台。微服务引擎完全兼容开源版本的使用方式,在功能、可用性和可运维性等多个方面进行增强。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档