转载

原 荐 Spring Cloud自动推送配置到Consul配置中心

Consul 是一个集配置管理、服务注册和发现于一体的微服务基础组件,它提供的这些功能我们在微服务开发中都用到了。在实践中,我们发现 Spring Cloud 没有提供在启动时自动加载某一个配置文件到 Consul 配置中心的功能,于是参照 Consul 社区的一个开源项目 cfg4j-pusher 进行了二次开发,实现了 Spring Boot 应用启动时自动加载指定配置文件到 Consul 配置中心的功能。以下是软件环境:

  • JDK 1.8
  • Maven 3.3.9
  • Spring Boot 2.0.0.RELEASE
  • Spring cloud Finchley.M8
  • Consul 1.2.2

实现过程

在这里我新建一个工程来说明实现过程,整个工程的结构如下:

原 荐 Spring Cloud自动推送配置到Consul配置中心

整个工程依照 Spring Boot 工程的目录结构创建,在 com.consul.pusher 包下有四个类,其中 ConsulApplication 的作用就不用说了,它是整个服务的启动类。剩下的三个类说明如下:

  • ConsulConfig :提供加载配置到 Consul 中的操作。它定义了一个私有的 init 方法,这个方法被 @PostConstruct 注解所标记,主要作用是在 ConsulConfig 依赖注入完成之后读取指定配置文件,将文件里的配置信息推送到 Consul 配置中心中。该方法在整个应用生命周期中只执行一次,定义为私有的主要是不允许外部调用,保证安全性

  • ConsulServiceConsulServiceImplConsulServiceImpl 实现了 ConsulService 接口,主要提供 Consul 配置中心业务逻辑操作,它主要封装了 Consul java client 的一些方法。

resources 目录下的 bootstrap.ymlapplication.yml 分别为微服务全局配置文件和业务信息配置文件。在服务启动期间, application.yml 配置文件的内容会被 ConsulConfig 类的 init 方法读取并推送到 Consul 配置中心。在这里我们没有将 bootstrap.yml 的文件内容推送到 Consul 配置中心,主要是考虑到:

  • bootstrap.yml 里定义的配置信息不经常修改

  • Spring Boot 天生不支持动态修改数据库、 ES 连接信息。 bootstrap.yml 里的定义的数据库连接、 ES 连接等信息通过 Consul 配置中心修改后不能生效,还需要重启应用才能生效。并且,需要修改数据库连接、 ES 连接信息的场景的大部分是因为当前服务不可用产生的,服务的高可用不应由 Consul 来维护

重构升级

经过与团队成员讨论,开发配置自动推送功能的初衷有两个:

  1. 方便 devops 团队进行自动化运维。微服务部署过程中,配置的管理和修改是一件让人头疼的事情,无论是开发和运维,都希望减少手动修改配置的次数,通过自动推送配置功能,可以轻松解决这个问题。 Consul 官方虽然提供了 HTTP API 供使用者加载指定配置到 Consul 中,但是需要开发给运维提供配置文件,再由运维手动执行命令加载这些配置文件到 Consul 中,不仅容易出错,管理也不便

  2. 无论是分布式服务还是微服务,都应该有一套工具化、通用化的公共服务类库。服务开发中,有很多重复的、可以封装成工具类的代码,我们可以构建一个公共服务类库,将这些代码组织起来,供大家使用。这样既解决了代码重复的问题,也使服务更加健壮和高可用。业内优秀的例子比如 Apache commons 、Google guava 系列类库

基于第二点初衷,产品发布了几版之后,我将自动推送配置的代码抽取了出来,封装成一个公共服务类库。封装之后,工程目录结构如下:

原 荐 Spring Cloud自动推送配置到Consul配置中心

因为公共服务类库不是一个可运行的微服务应用,所以需要去除 ConsulApplication 类,基础库单元测试通过之后,就可以推送到我们的 maven 私服中。接下来,就是使用这个基础库了,使用步骤如下:

  • 首先确保服务引入了 Consul 依赖:
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-Consul-discovery</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-Consul-config</artifactId>
</dependency>
  • 将自定义的配置统一提取到 application.yml 里。注意: yml 文件里如果有空的 value 值,请用单引号 '' 代替,否则 yml 解析会报错

  • pom 文件里引入 consul-pusher 公共服务类库, consul-pusher 类库的 Consul 配置加载类在服务启动时自动加载配置到 Consul 中:

<dependency>
	<groupId>com.Consul.pusher</groupId>
	<artifactId>Consul-pusher</artifactId>
	<version>1.0</version>
</dependency>
  • 在对应服务的 Application 启动类上,加入 @ComponentScan(value = "com.Consul.pusher") ,使公共类库相关的类被 Spring Boot 扫描到,比如:
@SpringBootApplication
@EnableDiscoveryClient
@EnableScheduling // 启用定时调度功能,Consul需要使用此功能来监控配置改变
@ComponentScan(value = "com.Consul.pusher")
public class ExampleApplication {
    public static void main(String[] args) {
        SpringApplication.run(ExampleApplication.class);
    }
}
  • 加载配置:

使用 @Value 注入配置,在类添加 @RefreshScope 实现业务参数的热更新:

@RefreshScope
@Service
public class StockMarketServiceImpl implements StockMarketService {
 
	private Logger logger = LoggerFactory.getLogger(this.getClass());
	 
	@Value(value = "${kline.host}")
	private String kLineHost;
 
}

至此,整个工程的重构和使用完成。引入 consul-pusher 的服务启动后,在 Consul 配置中心创建的配置信息截图如下,以 consul-pusher 服务本身为例:

原 荐 Spring Cloud自动推送配置到Consul配置中心

源码下载&参考资料

源码链接: consul-pusher

Consul 整合参考链接:

Spring Cloud(二)Consul 服务治理实现

快递中心的spring cloud实践

consul配置中心使用指南

原文  https://my.oschina.net/dabird/blog/1935941
正文到此结束
Loading...