Spring Cloud Consul作为配置中心实践

import org.springframework.cloud.bootstrap.config.PropertySourceLocator;
import org.springframework.core.env.Environment;
import org.springframework.core.env.MapPropertySource;
import com.ecwid.consul.v1.ConsulClient;
import com.ecwid.consul.v1.QueryParams;
import com.ecwid.consul.v1.kv.model.Pair;
 
public class ConsulPropertySourceLocator implements PropertySourceLocator {
 
    private ConsulClient consulClient;
    private String dataKey;
 
    public ConsulPropertySourceLocator(ConsulClient consulClient, String dataKey) {
        this.consulClient = consulClient;
        this.dataKey = dataKey;
    }
 
    @Override
    public PropertySource<?> locate(Environment environment) {
        Map<String, Object> propertiesMap = new HashMap<>();
        // 从Consul的KV存储中获取配置
        Pair response = consulClient.getKVValues(dataKey).getValue();
        if (response != null) {
            String properties = new String(response.getDecodedValue());
            // 解析配置，这里假设是YAML格式
            YamlPropertiesFactoryBean yaml = new YamlPropertiesFactoryBean();
            yaml.setResources(new ByteArrayResource(properties.getBytes()));
            Properties propertiesObject = yaml.getObject();
            propertiesMap.putAll(propertiesObject);
        }
 
        return new MapPropertySource("Consul", propertiesMap);
    }
}

这段代码定义了一个PropertySourceLocator的实现，用于从Consul的KV存储中加载配置。它使用了Consul的Java客户端库，并且假设配置是以YAML格式存储的。这个实现可以作为一个参考，用于创建自定义的配置服务。