Spring Cloud Config Server如何将纯文本文件推送到Config Client应用程序？

Question

到目前为止，我实施的是：

1. 具有“原生”存储库的Spring Cloud配置服务器。

<代码>Spring。配置文件。活动：本机

<代码>Spring。云配置。服务器出生地的搜索位置：文件：/path/to/config repo

配置服务器正在通过RabbitMQ将通知推送到配置客户端应用程序，如下所示http://cloud.spring.io/spring-cloud-config/spring-cloud-config.html#_push_notifications_and_spring_cloud_bus

配置客户端应用程序在Service bean上注释了@刷新范围。

因此 /config-repo有3个文件-application.yaml、client.yaml和client.json所有yaml属性更改都将由Config Client App自动重新加载。但是，client.json没有。

基于https://github.com/spring-cloud/spring-cloud-config/issues/147，我可以使用/{appname}/{profile}/{label}/Client通过对配置服务器的REST api调用在配置客户端应用程序上获取文件。json

问题是：

1） 配置服务器是否通过“本机”监视此纯文本文件的更改？

2） 如何配置客户端应用程序自动重新加载此客户端。json一旦更新？（我可以安排任务调用配置服务器，但这并不理想。）

Answer 1

配置客户端：restTemplate。getForObject（“”http://localhost:8080/application/default/master/testing-dev.json“，String.class）；

可以获取。json后缀文件内容，但我认为它没有获取文件内容，有其他方法获取文件内容

Answer 2

我像这样不修边幅（还没有鳍）：我有Spring。云配置。服务器出生地的以逗号分隔的URI列表形式显示的serach位置

file:/c:/repo/a,file:/c:/repo/b

我创建了FileMonitorConfiguration bean（但它有一些问题，因为它被调度了2次，一个bean本身和一个spring增强的实例，我对此并不熟悉）

并实现（只是草稿）NativeProperty tyPathNotificationExtractor

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

    @Bean
    NativePropertyPathNotificationExtractor nativePropertyPathNotificationExtractor(@Autowired(required = false) NativeEnvironmentRepository nativeRepo) {
        return new NativePropertyPathNotificationExtractor(nativeRepo);
    }

    @Bean
    FileMonitorConfiguration fileMonitorConfiguration() {
        return new FileMonitorConfiguration();
    }
}

@Order(Ordered.LOWEST_PRECEDENCE - 500)
public class NativePropertyPathNotificationExtractor implements PropertyPathNotificationExtractor {
    private final Set<Path> searchPaths;

    public NativePropertyPathNotificationExtractor(NativeEnvironmentRepository nativeRepo) {
        searchPaths = searchLocations(nativeRepo);
    }

    @Override
    public PropertyPathNotification extract(MultiValueMap<String, String> headers, Map<String, Object> payload) {

        // FileMonitor with empty headers, so if some there, ignore
        if (false == headers.isEmpty()) {
            return null;
        }
        if (null == searchPaths) {
            return null;
        }

        Path path = pathFromPayload(payload);
        if (null == path) {
            return null;
        }

        for (Path searchPath : searchPaths) {
            Path relative = searchPath.relativize(path);
            // just a try ;-)
            if (true == relative.startsWith("..")) {
                continue;
            }

            return new PropertyPathNotification(relative.toString());
        }

        return null;
    }

    private Path pathFromPayload(Map<String, Object> payload) {
        if (null == payload) {
            return null;
        }
        if (true == payload.isEmpty()) {
            return null;
        }
        if (false == payload.containsKey("path")) {
            return null;
        }
        if (null == payload.get("path")) {
            return null;
        }
        if (true == StringUtils.isEmpty(payload.get("path").toString())) {
            return null;
        }
        return Paths.get(payload.get("path").toString()).normalize().toAbsolutePath();
    }

    private Set<Path> searchLocations(NativeEnvironmentRepository nativeRepo) {
        if (null == nativeRepo) {
            return null;
        }
        if (null == nativeRepo.getSearchLocations()) {
            return null;
        }

        final Set<Path> paths = new LinkedHashSet<>();
        for (String location : nativeRepo.getSearchLocations()) {
            try {
                paths.add(Paths.get(new URI(location)).normalize().toAbsolutePath());
            } catch (Exception e) {
                System.err.println("Nevalidne search location uri: " + location);
            }
        }
        return paths;

    }
}