白话SpringCloud | 第八章：分布式配置中心的服务化及动态刷新-低调大师

白话SpringCloud | 第八章：分布式配置中心的服务化及动态刷新

2018-10-11 831

前言

上一章节，简单介绍了分布式配置中心Spring Cloud Config的使用。同时，我们也遗漏了一些问题，比如如何配置实时生效，当服务端地址变更或者集群部署时，如何指定服务端地址？回想，在服务注册章节，服务提供者和服务消费者，同时往注册中心进行注册和获取服务地址，而本身注册中心又支持高可用配置。所以，对于配置中心，我们也可以将Server端和Client端往注册中心进行注册，借此实现配置中心的服务化，无需指定具体的ip地址，直接根据服务名称进行调用。

前言

关于高可用

将配置中心服务化，本身是为了实现高可用。而实现高可用的手段是很多的，最常用的就是负载均衡。客户端不直连服务端，而是访问负载均衡服务，由负载均衡来动态选择需要访问的服务端。只是Spring Cloud Config天然的就能进行服务化配置，所以，实际中可以根据实际的业务需求来进行合理化抉择的。

其次，对于使用了git或者svn作为存储方式时，本身配置仓库的高可用也是一个需要考虑的事项。本身如github或者码云这些第三方git仓库而言，已经实现了高可用了。但一般上部署的微服务都是内网服务，所以一般上是使用如gitlab开源的git仓库管理系统进行自建，此时就需要考虑本身仓库的高可用了。

注意：本身教程为了不混淆各知识点，所以都是独立项目进行实例，而不是在原工程上进行修改。本章节教程采用了多模块工程进行构建实例。父类项目名为：spring-cloud-config-ha。同时创建服务化的配置文件：my-config-client-ha-dev.properties和my-config-client-ha-test.properties

my-config-client-ha-dev.properties

config=this is dev!

my-config-client-ha-dev.properties

config=this is test!

Server端

创建子工程：spring-cloud-confg-ha-server 0.加入pom依赖。

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

1.配置文件加入注册中心相关配置。

spring.application.name=spring-cloud-config-ha-server
server.port=15678

#配置文件git配置
spring.cloud.config.server.git.uri=https://github.com/xie19900123/spring-cloud-learning.git
# 搜索路径，即配置文件的目录，可配置多个，逗号分隔。默认为根目录。
spring.cloud.config.server.git.searchPaths=spring-cloud-config-repo
# git用户名和密码 针对私有仓库而言需要填写
spring.cloud.config.server.git.username=
spring.cloud.config.server.git.password=

#添加注册中心配置
# 注册中心地址 -此为单机模式
eureka.client.service-url.defaultZone=http://127.0.0.1:1000/eureka
# 启用ip配置 这样在注册中心列表中看见的是以ip+端口呈现的
eureka.instance.prefer-ip-address=true
# 实例名称  最后呈现地址：ip:15678
eureka.instance.instance-id=${spring.cloud.client.ip-address}:${server.port}

2.启动类加入@EnableDiscoveryClient和@EnableConfigServer,前者开启服务发现功能，后者声明一个config server。

/**
 * config server 服务化
 * 
 * @author oKong
 *
 */
@SpringBootApplication
@EnableConfigServer
//注意这里也可使用@EnableEurekaClient
//但由于springcloud是灵活的，注册中心支持eureka、consul、zookeeper等
//若写了具体的注册中心注解，则当替换成其他注册中心时，又需要替换成对应的注解了。
//所以 直接使用@EnableDiscoveryClient 启动发现。
//这样在替换注册中心时，只需要替换相关依赖即可。
@EnableDiscoveryClient
@Slf4j
public class ConfigServerHaApplication {
    public static void main(String[] args) throws Exception {
        SpringApplication.run(ConfigServerHaApplication.class, args);
        log.info("spring-cloud-config-ha-server启动!");
    }
}

关于Eureka相关知识点，可以查看：《第二章：服务注册与发现(Eureka)-上》和《第三章：服务注册与发现(Eureka)-下》，这里就不加以阐述了。

3.启动应用，同时启动Eureka服务端。访问下Eureka服务端地址：http://127.0.0.1:1000/ ，可以看见服务注册成功了。

访问：http://127.0.0.1:15678/my-config-client-ha-dev.properties 可以看见配置信息了。

Client端

创建子工程：spring-cloud-confg-ha-client 0.加入pom依赖。

        <!-- config client 依赖 -->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-config</artifactId>
        </dependency>
        <!-- eureka client 依赖 -->
        <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>

1.配置文件修改，bootstrap.properties添加注册中心配置。 bootstrap.properties

# 设置分支
spring.cloud.config.label=master
# 环境变量
spring.cloud.config.profile=dev
# 是否使用注册中心方式进行获取
spring.cloud.config.discovery.enabled=true
# 服务端地址 
# 在不使用注册中心模式下 直接填写实际地址
#spring.cloud.config.uri=http://127.0.0.1:5678
# 注册中心应用id
spring.cloud.config.discovery.service-id=spring-cloud-config-ha-server

#添加注册中心配置
# 注册中心地址 -此为单机模式
eureka.client.service-url.defaultZone=http://127.0.0.1:1000/eureka
# 启用ip配置 这样在注册中心列表中看见的是以ip+端口呈现的
eureka.instance.prefer-ip-address=true
# 实例名称  最后呈现地址：ip:15678
eureka.instance.instance-id=${spring.cloud.client.ip-address}:${server.port}

application.properties

# 设置应用名称，需要和配置文件匹配
spring.application.name=my-config-client-ha
server.port=15666

注意：注册中心的相关配置需要放在bootstrap.properties中，这样才能利用注册中心进行服务端服务地址获取。

2.启动类，加入@EnableDiscoveryClient，开启服务发现功能。

/**
 * 服务化方式调用config server
 * 
 * @author oKong
 *
 */
@SpringBootApplication
@EnableDiscoveryClient
@Slf4j
public class ConfigClientHaApplication {
    public static void main(String[] args) throws Exception {
        SpringApplication.run(ConfigClientHaApplication.class, args);
        log.info("spring-cloud-config-ha-client启动!");
    }

}

3.创建控制层，测试配置参数。

/**
 * config client 简单示例
 * @author oKong
 *
 */
@RestController
public class DemoController {

    @Value("${config}")
    String config;
    
    @GetMapping("/")
    public String demo() {
        return "返回的config参数值为:" + config;
    }
}

4.启动应用。一般上应用能启动成功，就说明服务化已经成功了。启动时，可以看见已经往注册中心去获取服务端地址了。

2018-10-10 23:15:15.302  INFO 26412 --- [           main] c.c.c.ConfigServicePropertySourceLocator : Fetching config from server at : http://192.168.2.102:15678/
2018-10-10 23:15:20.728  INFO 26412 --- [           main] c.c.c.ConfigServicePropertySourceLocator : Located environment: name=my-config-client-ha, profiles=[dev], label=master, version=f2645253a37db433d806914b1d04d6aba428831c, state=null

此时，我们访问：http://127.0.0.1:15666/ ，即可看见配置信息返回了。

refresh实现刷新

在默认情况下，客户端是不会自动感知配置的变化的。此时，我们可以使用/refresh端点来进行配置更新。现在，我们改造下客户端。 0.加入端点依赖。

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>

1.修改下变量使用类，加入@RefreshScope注解，标记在访问/refresh时，进行变量的更新操作。

/**
 * config client 简单示例
 * @author oKong
 *
 */
@RestController
@RefreshScope//使用该注解的类，会在接到SpringCloud配置中心配置刷新的时候，自动将新的配置更新到该类对应的字段中。
public class DemoController {

    @Value("${config}")
    String config;
    
    @GetMapping("/")
    public String demo() {
        return "返回的config参数值为:" + config;
    }
}

重点就是注解@RefreshScope了。 2.配置文件开启端点refresh。这里需要注意,2.0之后，默认只开启了端点info、health。其他的需要通过management.endpoints.web.exposure.include进行额外配置。

#开启监控端点
management.endpoints.web.exposure.include=refresh

3.启动应用，此时，动态修改下远程仓库的参数值为：config=this is dev refresh!!!，使用Postman使用POST访问：http://127.0.0.1:15666/actuator/refresh。

返回值即为有变动的参数值。

再次访问：http://127.0.0.1:15666/ 可以看见已经是最新的配置参数值了。

参考资料

总结

本章节主要讲解了如何将配置中心注册为一个服务，客户端像普通的服务消费者一样，根据服务名即可获取服务端地址，进而进行参数的获取。同时讲解了当属性参数有变时，客户端如何进行感知变化进行参数动态更新。大家应该可以想到，当我们客户端越来越多时，一个个去执行refresh时不太现实的，虽然我们可以通过类似webhook功能当有提交记录时，主动去触发各客户端的refresh方法，在前期项目比较少的情况下，不失为一个好方法，只需要维护一份待更新的客户端地址列表即可。但当服务越来越多时，维护此列表也是令人头疼的。此时，我们可以使用Spring cloud bus消息总线进行通知。由于目前Spring cloud bus知识点尚未开始讲解，同时作者也比较少使用消息总线，所以待查阅相关之后介绍Spring Cloud bus章节时，再来进行讲解如何使用消息总线进行全自动的配置更新操作。

最后

目前互联网上大佬都有分享SpringCloud系列教程，内容可能会类似，望多多包涵了。原创不易，码字不易，还希望大家多多支持。若文中有错误之处，还望提出，谢谢。

老生常谈

个人QQ：499452441
微信公众号：lqdevOps

个人博客：http://blog.lqdev.cn

源码示例：https://github.com/xie19900123/spring-cloud-learning

原文地址：http://blog.lqdev.cn/2018/10/11/SpringCloud/chapter-eight/

微信关注我们

原文链接：https://my.oschina.net/xiedeshou/blog/2243313

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

从源码分析如何优雅的使用 Kafka 生产者

前言在上文设计一个百万级的消息推送系统中提到消息流转采用的是 Kafka 作为中间件。其中有朋友咨询在大量消息的情况下 Kakfa 是如何保证消息的高效及一致性呢？正好以这个问题结合 Kakfa 的源码讨论下如何正确、高效的发送消息。内容较多，对源码感兴趣的朋友请系好安全带(源码基于 v0.10.0.0 版本分析)。同时最好是有一定的 Kafka 使用经验，知晓基本的用法。简单的消息发送在分析之前先看一个简单的消息发送是怎么样的。以下代码基于 SpringBoot 构建。首先创建一个 org.apache.kafka.clients.producer.Producer 的 bean。主要关注 bootstrap.servers，它是必填参数。指的是 Kafka 集群中的 broker 地址，例如 127.0.0.1:9094。其余几个参数暂时不做讨论，后文会有详细介绍。接着注入这个 bean 即可调用它的发送函数发送消息。这里我给某一个 Topic 发送了 10W 条数据，运行程序消息正常发送。但这仅仅只是做到了消息发送，对消息是否成功送达完全没管，等于是...

2018-10-11

751

通信服务提供接口是web3如何与区块链交互的关键。接口接受JSON-RPC请求并返回响应。这通常通过将请求提交给基于HTTP或IPC套接字的服务器来完成。如果你已经愉快地连接到你的以太坊节点，那么你可以跳过这部分内容。选择如何连接到你的节点大多数节点都有多种连接方式。如果你尚未确定要使用哪种节点，请转到如何选择要使用的节点？连接节点的最常用方法是： 1.IPC（使用本地文件系统：最快，最安全） 2.Websockets（远程工作，比HTTP更快） 3.HTTP（更多节点支持它）如果你不确定如何决定，请选择以下方式：如果你可以选择在与节点相同的计算机上运行Web3.py，请选择IPC。如果必须连接到其他计算机上的节点，请使用Websockets。如果你的节点不支持Websockets，请使用HTTP。大多数节点都有“关闭”连接选项的方法。我们建议你关闭所有未使用的连接选项。这提供了更安全的设置：它减少了恶意黑客可以试图窃取你的以太币的方式。确定连接后，可以使用通信服务提供接口Provider指定详细信息。通信服务提供接口Provider程序是为所需类型的连接配置的We...

2018-10-11

861

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。