Spring Cloud Config 使用 JDBC 方式

本是古典何须时尚 2022-05-22 00:25 171阅读 0赞

## Config Server ##

<dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jdbc</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-config-server</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka</artifactId>
            </dependency>
    
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <scope>runtime</scope>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>

添加 @EnableConfigServer

@EnableConfigServer
    @SpringBootApplication
    public class ConfigServerJdbcApplication { 
    
        public static void main(String[] args) {
            SpringApplication.run(ConfigServerJdbcApplication.class, args);
        }
    }

application.properties

management.security.enabled=false
    #config默认支持git模式,但是同时也提供了svn,vault,jdbc三种配置模式
    spring.profiles.active=jdbc
    #数据库配置
    spring.datasource.url=jdbc:mysql://127.0.0.1:3306/qinwei?useUnicode=true&characterEncoding=UTF-8
    spring.datasource.username=root
    spring.datasource.password=123456
    spring.datasource.driverClassName=com.mysql.jdbc.Driver
    #config配置
    spring.cloud.config.label=master
    spring.cloud.config.server.jdbc=true
    #重写SQL,因为KEY为mysql关键字,在mysql需要使用反引号来表示其为字段
    spring.cloud.config.server.jdbc.sql=SELECT `KEY`, `VALUE` from PROPERTIES where APPLICATION=? and PROFILE=? and LABEL=?

application.yml

server:
      port: 8090
    eureka:
      client:
        service-url:
          defaultZone: http://localhost:8081/eureka-server/eureka/
    spring:
      application:
        name: config-server-jdbc

mysql数据库中创建 properties 表

CREATE TABLE `properties` ( `id` int(11) NOT NULL, `key` varchar(50) DEFAULT NULL, `value` varchar(500) DEFAULT NULL, `application` varchar(50) DEFAULT NULL, `label` varchar(50) DEFAULT NULL, `profile` varchar(50) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;

![这里写图片描述][70]

## Config Client ##

bootstrap.properties

server.port=8088
    eureka.client.service-url.defaultZone=http://localhost:8081/eureka-server/eureka/
    spring.cloud.config.label=master
    spring.cloud.config.profile=dev
    spring.cloud.config.discovery.enabled=true
    spring.cloud.config.discovery.service-id=config-server-jdbc
    #设为true，如果无法连接config server，启动时会抛异常，并停止服务
    spring.cloud.config.failFast=true
    #关闭权限验证
    management.security.enabled=false
    #显示每个服务实例发送的所有事件和所有的ack
    spring.cloud.bus.trace.enabled=true

// 必须在使用的地方加上 @RefreshScope 注解,否则无效
    @RefreshScope
    @RestController
    @EnableDiscoveryClient
    @SpringBootApplication
    public class ConfigClientApplication { 
    
        public static void main(String[] args) {
            SpringApplication.run(ConfigClientApplication.class, args);
        }
    
        @Value("${msg}")
        String msg;
        @Value("${name}")
        String name;
        @Value("${version}")
        String version;
    
        @RequestMapping("/hello")
        public String getConfig() {
            return "msg = " + msg + "; name = " + name + "; version = " + version;
        }
    }

POST 请求调用 [http://localhost:8088/refresh][http_localhost_8088_refresh] ，可以看到配置刷新了  
![这里写图片描述][70 1]

如果使用消息总线，可以通过POST 请求调用 [http://localhost:8088/bus/refresh][http_localhost_8088_bus_refresh] ，刷新整个 client 集群  
![这里写图片描述][70 2]

[http://localhost:8088/bus/refresh][http_localhost_8088_bus_refresh] 可以添加 destination 参数刷新指定的服务，如/bus/refresh?destination=config-client:8089  
![这里写图片描述][70 3]

***注意：***我总共启了3个client，端口分别是8087、8089、8089，如果请求[http://localhost:8088/bus/refresh][http_localhost_8088_bus_refresh] ?destination=config-client:8089，则8088和8089会刷新配置，而8087不会。也就是说你调用哪个服务的POST请求，那个服务肯定会刷新。  
**destination参数的值指的是 服务的ApplicationContext ID，默认情况下，ApplicationContext ID是spring.application.name:server.port**

[70]: /images/20220522/62f15a117eba492a83d8d791365a8d45.png
[http_localhost_8088_refresh]: http://localhost:8088/refresh
[70 1]: /images/20220522/3ac85f51130f4f75b5ce07f26d266c44.png
[http_localhost_8088_bus_refresh]: http://localhost:8088/bus/refresh
[70 2]: /images/20220522/0031fa323dcb45e9b0df43be2ed9e407.png
[70 3]: /images/20220522/54cccdd9a49b4921ab7915833a57fbcb.png