SpringBoot中如何是实现分布式配置?

经验文章nimo972025-03-07 17:40:1210A⁺A^-

分布式配置是一种在分布式系统中管理和分发配置数据的方法。实现分布式配置可以通过多种方式来完成，通常涉及到集中管理配置、分布式配置服务和版本控制等。它的目的是确保在一个多节点、多服务的环境中，配置数据的一致性和可用性。

常见实现分布式配置的方法有如下一些。

Spring Cloud Config
Apache Zookeeper
Consul
etcd

典型架构

集中式配置管理

通过Git或者数据库将配置文件或者是配置项的键值对存储在一个集中的存储库中，然后通过Spring Cloud Config这样的工具来读取配置文件中的配置的数据，提供给客户端进行REST API的调用。在客户端启动的时候就可以通过配置服务获取到配置的数据，并且将其应用到服务本身。

分布式键值存储

分布式键值存储例如etcd、Consul、Zookeeper等这些都是基于分布式键值存储实现，将配置文件中的数据以键值对的形式存储在分布式系统中，提供高可用的配置，然后客户端系统可以与分布式存储系统进行交互，直接读取到键值对的信息，然后应用到自身的系统中。

使用示例

使用Spring Cloud Config

根据上面的介绍配置文件存储在Git仓库中，接下就是配置服务，通过@EnableConfigServer注解来标识，如下所示。

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

编写配置文件

server:
  port: 8888

spring:
  cloud:
    config:
      server:
        git:
          uri: https://github.com/your-repo/config-repo

客户端的配置文件，需要添加配置中心的地址。

spring:
  application:
    name: config-client
  cloud:
    config:
      uri: http://localhost:8888

客户端进行调用，如下所示。

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

@RestController
@RefreshScope
class MessageRestController {

    @Value("${message:Hello default}")
    private String message;

    @GetMapping("/message")
    public String getMessage() {
        return this.message;
    }
}

使用etcd

存储配置数据存储在etcd集群中，首先就需要往Etcd集群中写入数据如下所示。注意是以键值对的形式写入。

etcdctl put /config/message "Hello from etcd"

通过Python代码进行演示调用。

import etcd3

client = etcd3.client()

# 读取配置数据
message = client.get('/config/message')[0].decode('utf-8')

print(f"Configuration message: {message}")

# 监听配置变化
def watch_callback(event):
    print(f"Configuration changed: {event.events[0].kv.value.decode('utf-8')}")

client.add_watch_callback('/config/message', watch_callback)

注意这里是个伪代码，不能直接使用，但是思路就是这样子的，从etcd集群中读取到数据之后，然后添加到应用程序的配置中进行使用。