Spring Cloud【Finchley】实战-05配置中心的搭建(配合使用Eureka)和Config Server高可用

本文涉及的产品
日志服务 SLS,月写入数据量 50GB 1个月
简介: Spring Cloud【Finchley】实战-05配置中心的搭建(配合使用Eureka)和Config Server高可用

概述


入门文章请看我之前整理的博客: Spring Cloud【Finchley】-19Spring Cloud Config之Config Server和Config Client


搭建Config Server


总结下Spring Cloud的三部曲

1. 增加依赖

2. 启用注解@EnableXXX

3. 配置文件


Step1: 新建Config Server微服务,添加依赖

关键依赖如下:

    <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>


Step2: 将Config Server 注册到Eureka Server上

2.1启动类增加 @EnableEurekaClient 注解 ,作为Eureka Client 注册到注册中心上去

20190404150510429.png


2.2application.yml 新增配置如下

spring:
  application:
    name: artisan-config
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/


Step3: 启动@EnableConfigServer,将服务变更为Config Server


2.1启动类增加 @EnableConfigServer注解


20190404150717893.png

2.2application.yml 新增配置如下


20190404151043424.png

又加了个指定端口 9898 和 force-pull 属性 。 完整配置如下


20190404170119156.png



Cannot pull from remote the working tree is not clean. 这种报错可以通过配置强制拉属性force-pull: true 。 由于Spring Cloud配置服务器会复制远程git存储库,如果本地副本变得不干净,那么Spring Cloud配置服务器就不能更新远程存储库中的本地副本。通过设置强制拉属性为true,使Spring Cloud配置服务器从远程存储库中强制pull。


官方指导: https://github.com/spring-cloud/spring-cloud-config/blob/master/docs/src/main/asciidoc/spring-cloud-config.adoc#force-pull-in-git-repositories


Step5: 新建远端Git工程,用于存放配置文件


之前创建了一个远端Git, 地址为: https://github.com/yangshangwei/spring-cloud-config-center 我们就直接拿来用吧

搭建过程: 搭建Config Server的后端存储

为了测试下,我们新建几个order的配置文件 ,放些配置进去



20190404165743708.png


Step6: 启动测试


启动Eureka Server 和 该工程

访问Eureka http://localhost:8761/


20190404151135864.png


访问: http://localhost:9898/artisan-order-dev.yml


20190404170010503.png

basedir的配置看日志

20190404170202849.png


20190404170324136.png

搭建Config Client


上面我们把Order微服务的配置文件放到了远端的Git,自然而然本地的工程直接使用远端存储的配置文件既可以了,本地的配置自然而言就应该不需要了。


Step1.添加spring-cloud-config-client依赖

在Order工程中添加 spring-cloud-config-client 依赖

      <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-config-client</artifactId>
        </dependency>


Step2. 新建bootstrap.yml

spring:
  application:
    name: artisan-order
  cloud:
    config:
      profile: dev
      # 可配置多个,不推荐使用,因为需要设置具体的ip.服务端修改或者新增IP后,要同步修改
      # uri: http://localhost:9898/,http://localhost:9999/
      discovery:
        # 指定Config Server在服务发现中的service Id ,默认为configserver
        service-id: ARTISAN-CONFIG
        # 表示使用服务发现组件中的Config Server,而不自己指定Config Server的uri,默认为false
        enabled: true


上述配置信息一定要写到bootstrap.yml中。 如果配到了application.yml中,spring.cloud.config.uri 就会访问默认的8888端口,而非配置的端口了。


bootstrap.yml 是被一个父级的 Spring ApplicationContext 加载的,在加载application.yml 的 ApplicationContext之前。配置在 bootstrap.yml 中的属性优先级更高,默认情况下不能被本地配置覆盖。


当启动不了的时候,比如从远端加载不到配置文件的时候,注意观察日志:

2019-04-04 16:42:41.844  INFO 27888 --- [  restartedMain] c.c.c.ConfigServicePropertySourceLocator : Fetching config from server at : http://localhost:9898/
2019-04-04 16:42:45.426  INFO 27888 --- [  restartedMain] c.c.c.ConfigServicePropertySourceLocator : Located environment: name=artisan-order, profiles=[dev], label=null, version=16152eaaf132cd054c2ac538a11fe4bb7fff6583, state=null
2019-04-04 16:42:45.427  INFO 27888 --- [  restartedMain] b.c.PropertySourceBootstrapConfiguration : Located property source: CompositePropertySource {name='configService', propertySources=[MapPropertySource {name='configClient'}, MapPropertySource {name='https://github.com/yangshangwei/spring-cloud-config-center/artisan-order.yml'}]}


Step3. 启动artisan-order

启动后观察是否注册到Eureka上


20190404170606231.png

Step4. 验证

package com.artisan.order.controller;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class ConfigController {
    @Value("${spring.datasource.url}")
    private String url;
    @GetMapping("/value")
    public String getValueFromGit(){
        return url;
    }
}


获取 spring.datasource.url的值


20190408105447573.png

访问 http://localhost:8081/value

20190408105414397.png

配置中心的高可用

Config Server注册到注册中心上的场景

这种情况最简单,启动多个Config Server即可。 下面我们来验证下

20190408112229724.png


配置中心再启动另外一个端口


20190408110624362.png

可以看到我们启动了两个进程

20190408110725682.png

去Eureka Server上看也可以。

20190408111318881.png

然后重启下artisan-order微服务,观察日志 中的 server url

Multiple Config Server Urls found listed.
Fetching config from server at : http://localhost:9898/
Located environment: name=artisan-order, profiles=[dev], label=null, version=06a183a4820a618cc1dc53b33d77e22106a9c4e4, state=null
Located property source: CompositePropertySource {name='configService', propertySources=[MapPropertySource {name='configClient'}, MapPropertySource {name='https://github.com/yangshangwei/spring-cloud-config-center/artisan-order-dev.yml'}, MapPropertySource {name='https://github.com/yangshangwei/spring-cloud-config-center/artisan-order.yml'}]}

再次重启下 ,或者多重启几次

Multiple Config Server Urls found listed.
Fetching config from server at : http://localhost:9999/
Located environment: name=artisan-order, profiles=[dev], label=null, version=06a183a4820a618cc1dc53b33d77e22106a9c4e4, state=null
Located property source: CompositePropertySource {name='configService', propertySources=[MapPropertySource {name='configClient'}, MapPropertySource {name='https://github.com/yangshangwei/spring-cloud-config-center/artisan-order-dev.yml'}, MapPropertySource {name='https://github.com/yangshangwei/spring-cloud-config-center/artisan-order.yml'}]}


停掉9898节点 ,再次重启下artisan-order服务 ,观察日志

20190408111800278.png


Config Server未注册到注册中心上的场景

借助负载均衡设备即可 ,比如 Nginx , F5,A10等等


20190408112327423.png

修改Eureka Server的默认端口8761的情况


如果我们不使用Eureka Server默认的端口呢? 比如我们使用8762

先把Eureka Server的端口改为8762


20190408144551789.png


其他eureka client客户端将 defaultZone修改为 8762端口对应的url .


Step1. 将Eureka的配置下沉到客户端上

改完默认的端口,我们启动Eureka Server , artisan-config , 发现都可以起来

访问: http://localhost:8762/

20190408144906723.png

紧接着我们启动 artisan-order ,报错了。。。。

2019-04-08 14:47:29.463 ERROR 30340 --- [  restartedMain] c.n.d.s.t.d.RedirectingEurekaHttpClient  : Request execution error
com.sun.jersey.api.client.ClientHandlerException: java.net.ConnectException: Connection refused: connect
  at com.sun.jersey.client.apache4.ApacheHttpClient4Handler.handle(ApacheHttpClient4Handler.java:187) ~[jersey-apache-client4-1.19.1.jar:1.19.1]
  ........
Caused by: java.net.ConnectException: Connection refused: connect
  at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method) ~[na:1.8.0_191]
2019-04-08 14:47:29.466  WARN 30340 --- [  restartedMain] c.n.d.s.t.d.RetryableEurekaHttpClient    : Request execution failed with message: java.net.ConnectException: Connection refused: connect
2019-04-08 14:47:29.468 ERROR 30340 --- [  restartedMain] com.netflix.discovery.DiscoveryClient    : DiscoveryClient_ARTISAN-ORDER/localhost:artisan-order - was unable to refresh its cache! status = Cannot execute request on any known server
com.netflix.discovery.shared.transport.TransportException: Cannot execute request on any known server
  at com.netflix.discovery.shared.transport.decorator.RetryableEurekaHttpClient.execute(RetryableEurekaHttpClient.java:112) ~[eureka-client-1.9.2.jar:1.9.2]
  ....
  at org.springframework.boot.devtools.restart.RestartLauncher.run(RestartLauncher.java:49) ~[spring-boot-devtools-2.0.3.RELEASE.jar:2.0.3.RELEASE]
2019-04-08 14:47:29.474  WARN 30340 --- [  restartedMain] com.netflix.discovery.DiscoveryClient    : Using default backup registry implementation which does not do anything.
2019-04-08 14:47:29.476  INFO 30340 --- [  restartedMain] com.netflix.discovery.DiscoveryClient    : Not registering with Eureka server per configuration
2019-04-08 14:47:29.480  INFO 30340 --- [  restartedMain] com.netflix.discovery.DiscoveryClient    : Discovery Client initialized at timestamp 1554706049479 with initial instances count: 0
2019-04-08 14:47:29.590  WARN 30340 --- [  restartedMain] lientConfigServiceBootstrapConfiguration : Could not locate configserver via discovery
java.lang.IllegalStateException: No instances found of configserver (ARTISAN-CONFIG)
  at org.springframework.cloud.config.client.ConfigServerInstanceProvider.getConfigServerInstances(ConfigServerInstanceProvider.java:25) ~[spring-cloud-config-client-2.0.0.RELEASE.jar:2.0.0.RELEASE]
  ....


一看就知道是Eureka 的问题,我们想到,统一配置中心上artisan-order-dev.yml的Eureka Server的端口还没改,改下再试试吧


20190408145354225.png

访问下 http://localhost:9898/artisan-order-dev.yml 看下效果

20190408145446253.png

再次启动artisan order ,还是报错

20190408150606837.png


访问了配置中心的默认端口8888 ,

这样的话 我们把Eureka的配置

# Eureka
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8762/eureka/


下沉到artisan order 中

20190408150934994.png

意思就是:启动的时候会优先加载bootstrap中的配置,从该配置文件中找到注册中心的地址,然后再注册中心上去找配置中心的service-id .

同时把配置中心artisan-order-dev.yml 中的eureka的配置注释或者删掉。

20190408150815788.png

Step2. 注释掉默认配置文件的配置

再次访问下 http://localhost:9898/artisan-order-dev.yml 看下


20190408150850908.png


怎么又是8761了。。。。

我们来观察下 artisan cofig的日志

20190408151147765.png

当我们按照这种格式访问 http://localhost:9898/artisan-order-dev.yml 配置文件时,config server同时也会把默认配置文件的artisan-order中的配置合并后返回。

那看下 artisan-order.yml的配置看下吧


20190408151346727.png


把artisan-order.yml的配置注释掉吧


20190408151522200.png

再次访问 http://localhost:9898/artisan-order-dev.yml


20190408151551824.png


可以发现已经没有eureka的相关信息了。

再次启动artisan order ,启动成功。 查看注册中心 http://localhost:8762/


20190408151839781.png


遗留问题


修改配置自动刷新,还是没有实现,仅仅实现了从远端Git读取配置的功能,下一篇我们来实战下如何通过Spring Cloud Bus自动刷新配置


代码


配置文件远端存储Git: https://github.com/yangshangwei/spring-cloud-config-center

artisan order : https://github.com/yangshangwei/springcloud-o2o/tree/master/artisan_order

artisan config: https://github.com/yangshangwei/springcloud-o2o/tree/master/artisan_config

eureka server : https://github.com/yangshangwei/springcloud-o2o/tree/master/eureka-server

相关实践学习
通过日志服务实现云资源OSS的安全审计
本实验介绍如何通过日志服务实现云资源OSS的安全审计。
相关文章
|
10月前
|
存储 JavaScript 开发工具
基于HarmonyOS 5.0(NEXT)与SpringCloud架构的跨平台应用开发与服务集成研究【实战】
本次的.HarmonyOS Next ,ArkTS语言,HarmonyOS的元服务和DevEco Studio 开发工具,为开发者提供了构建现代化、轻量化、高性能应用的便捷方式。这些技术和工具将帮助开发者更好地适应未来的智能设备和服务提供方式。
基于HarmonyOS 5.0(NEXT)与SpringCloud架构的跨平台应用开发与服务集成研究【实战】
|
11月前
|
JSON Java 测试技术
SpringCloud2023实战之接口服务测试工具SpringBootTest
SpringBootTest同时集成了JUnit Jupiter、AssertJ、Hamcrest测试辅助库,使得更容易编写但愿测试代码。
320 3
|
消息中间件 Java 开发者
Spring Cloud微服务框架:构建高可用、分布式系统的现代架构
Spring Cloud是一个开源的微服务框架,旨在帮助开发者快速构建在分布式系统环境中运行的服务。它提供了一系列工具,用于在分布式系统中配置、服务发现、断路器、智能路由、微代理、控制总线、一次性令牌、全局锁、领导选举、分布式会话、集群状态等领域的支持。
393 5
|
Java API 开发工具
Spring Boot与Spring Cloud Config的集成
Spring Boot与Spring Cloud Config的集成
|
负载均衡 Java 开发者
Spring Cloud实战:构建分布式系统解决方案
Spring Cloud实战:构建分布式系统解决方案
|
Java Spring
Spring Cloud中,Eureka常见问题总结
Spring Cloud中,Eureka常见问题总结。 指定Eureka的Environment eureka.environment: 指定环境 参考文档:https://github.
1599 0
|
3月前
|
Java Spring 容器
SpringBoot自动配置的原理是什么?
Spring Boot自动配置核心在于@EnableAutoConfiguration注解,它通过@Import导入配置选择器,加载META-INF/spring.factories中定义的自动配置类。这些类根据@Conditional系列注解判断是否生效。但Spring Boot 3.0后已弃用spring.factories,改用新格式的.imports文件进行配置。
747 0
|
7月前
|
前端开发 Java 数据库
微服务——SpringBoot使用归纳——Spring Boot集成Thymeleaf模板引擎——Thymeleaf 介绍
本课介绍Spring Boot集成Thymeleaf模板引擎。Thymeleaf是一款现代服务器端Java模板引擎,支持Web和独立环境,可实现自然模板开发,便于团队协作。与传统JSP不同,Thymeleaf模板可以直接在浏览器中打开,方便前端人员查看静态原型。通过在HTML标签中添加扩展属性(如`th:text`),Thymeleaf能够在服务运行时动态替换内容,展示数据库中的数据,同时兼容静态页面展示,为开发带来灵活性和便利性。
326 0
|
7月前
|
XML Java 数据库连接
微服务——SpringBoot使用归纳——Spring Boot集成MyBatis——基于 xml 的整合
本教程介绍了基于XML的MyBatis整合方式。首先在`application.yml`中配置XML路径,如`classpath:mapper/*.xml`,然后创建`UserMapper.xml`文件定义SQL映射,包括`resultMap`和查询语句。通过设置`namespace`关联Mapper接口,实现如`getUserByName`的方法。Controller层调用Service完成测试,访问`/getUserByName/{name}`即可返回用户信息。为简化Mapper扫描,推荐在Spring Boot启动类用`@MapperScan`注解指定包路径避免逐个添加`@Mapper`
318 0
|
7月前
|
Java 测试技术 微服务
微服务——SpringBoot使用归纳——Spring Boot中的项目属性配置——少量配置信息的情形
本课主要讲解Spring Boot项目中的属性配置方法。在实际开发中,测试与生产环境的配置往往不同,因此不应将配置信息硬编码在代码中,而应使用配置文件管理,如`application.yml`。例如,在微服务架构下,可通过配置文件设置调用其他服务的地址(如订单服务端口8002),并利用`@Value`注解在代码中读取这些配置值。这种方式使项目更灵活,便于后续修改和维护。
101 0