closes #63, closes #64, closes #65, closes #66.

spring-cloud-alicloud-acm/pom.xml

@@ -0,0 +1,71 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+
+    <parent>
+        <groupId>org.springframework.cloud</groupId>
+        <artifactId>spring-cloud-alibaba</artifactId>
+        <version>0.2.0.BUILD-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>spring-cloud-alicloud-acm</artifactId>
+
+    <dependencies>
+
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-alicloud-context</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.aliyun</groupId>
+            <artifactId>aliyun-java-sdk-core</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.aliyun</groupId>
+            <artifactId>aliyun-java-sdk-edas</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.alibaba.edas.acm</groupId>
+            <artifactId>acm-sdk</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-autoconfigure</artifactId>
+            <scope>provided</scope>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-actuator</artifactId>
+            <optional>true</optional>
+        </dependency>
+
+        <!-- Spring Cloud -->
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-context</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-commons</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-configuration-processor</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+</project>
+

spring-cloud-alicloud-acm/src/main/java/org/springframework/cloud/alicloud/acm/AcmAutoConfiguration.java

@@ -0,0 +1,73 @@
+/*
+ * Copyright (C) 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alicloud.acm;
+
+import com.taobao.diamond.client.Diamond;
+import org.springframework.beans.BeansException;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.cloud.alicloud.acm.endpoint.AcmHealthIndicator;
+import org.springframework.cloud.alicloud.acm.refresh.AcmContextRefresher;
+import org.springframework.cloud.alicloud.acm.refresh.AcmRefreshHistory;
+import org.springframework.cloud.alicloud.context.acm.AcmProperties;
+import org.springframework.cloud.context.refresh.ContextRefresher;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * Created on 01/10/2017.
+ *
+ * @author juven.xuxb
+ */
+@Configuration
+@ConditionalOnClass({Diamond.class})
+@EnableConfigurationProperties(AcmProperties.class)
+public class AcmAutoConfiguration implements ApplicationContextAware {
+
+    private ApplicationContext applicationContext;
+
+    @Bean
+    public AcmPropertySourceRepository acmPropertySourceRepository() {
+        return new AcmPropertySourceRepository(applicationContext);
+    }
+
+    @Bean
+    public AcmHealthIndicator acmHealthIndicator(AcmProperties acmProperties,
+                                                 AcmPropertySourceRepository acmPropertySourceRepository) {
+        return new AcmHealthIndicator(acmProperties, acmPropertySourceRepository);
+    }
+
+    @Bean
+    public AcmRefreshHistory acmRefreshHistory() {
+        return new AcmRefreshHistory();
+    }
+
+    @Bean
+    public AcmContextRefresher acmContextRefresher(AcmProperties acmProperties, ContextRefresher contextRefresher,
+                                                   AcmRefreshHistory refreshHistory,
+                                                   AcmPropertySourceRepository propertySourceRepository) {
+        return new AcmContextRefresher(contextRefresher, acmProperties, refreshHistory, propertySourceRepository);
+    }
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext)
+        throws BeansException {
+        this.applicationContext = applicationContext;
+    }
+}

spring-cloud-alicloud-acm/src/main/java/org/springframework/cloud/alicloud/acm/AcmPropertySourceRepository.java

@@ -0,0 +1,68 @@
+/*
+ * Copyright (C) 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alicloud.acm;
+
+import org.springframework.cloud.alicloud.acm.bootstrap.AcmPropertySource;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ConfigurableApplicationContext;
+import org.springframework.core.env.CompositePropertySource;
+import org.springframework.core.env.PropertySource;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author juven.xuxb, 5/17/16.
+ */
+public class AcmPropertySourceRepository {
+
+	private final ApplicationContext applicationContext;
+
+	public AcmPropertySourceRepository(ApplicationContext applicationContext) {
+		this.applicationContext = applicationContext;
+	}
+
+	/**
+	 * get all acm properties from application context
+	 * @return
+	 */
+	public List<AcmPropertySource> getAll() {
+		List<AcmPropertySource> result = new ArrayList<>();
+		ConfigurableApplicationContext ctx = (ConfigurableApplicationContext) applicationContext;
+		for (PropertySource p : ctx.getEnvironment().getPropertySources()) {
+			if (p instanceof AcmPropertySource) {
+				result.add((AcmPropertySource) p);
+			}
+			else if (p instanceof CompositePropertySource) {
+				collectAcmPropertySources((CompositePropertySource) p, result);
+			}
+		}
+		return result;
+	}
+
+	private void collectAcmPropertySources(CompositePropertySource composite,
+			List<AcmPropertySource> result) {
+		for (PropertySource p : composite.getPropertySources()) {
+			if (p instanceof AcmPropertySource) {
+				result.add((AcmPropertySource) p);
+			}
+			else if (p instanceof CompositePropertySource) {
+				collectAcmPropertySources((CompositePropertySource) p, result);
+			}
+		}
+	}
+}

spring-cloud-alicloud-acm/src/main/java/org/springframework/cloud/alicloud/acm/bootstrap/AcmPropertySource.java

@@ -0,0 +1,55 @@
+/*
+ * Copyright (C) 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alicloud.acm.bootstrap;
+
+import org.springframework.core.env.MapPropertySource;
+
+import java.util.Date;
+import java.util.Map;
+
+/**
+ * @author juven.xuxb
+ * @author xiaolongzuo
+ */
+public class AcmPropertySource extends MapPropertySource {
+
+    private final String dataId;
+
+    private final Date timestamp;
+
+    private final boolean groupLevel;
+
+    AcmPropertySource(String dataId, Map<String, Object> source, Date timestamp,
+                      boolean groupLevel) {
+        super(dataId, source);
+        this.dataId = dataId;
+        this.timestamp = timestamp;
+        this.groupLevel = groupLevel;
+    }
+
+    public String getDataId() {
+        return dataId;
+    }
+
+    public Date getTimestamp() {
+        return timestamp;
+    }
+
+    public boolean isGroupLevel() {
+        return groupLevel;
+    }
+}

spring-cloud-alicloud-acm/src/main/java/org/springframework/cloud/alicloud/acm/bootstrap/AcmPropertySourceBuilder.java

@@ -0,0 +1,96 @@
+/*
+ * Copyright (C) 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alicloud.acm.bootstrap;
+
+import com.alibaba.edas.acm.ConfigService;
+import com.alibaba.edas.acm.exception.ConfigException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.config.YamlPropertiesFactoryBean;
+import org.springframework.core.io.ByteArrayResource;
+import org.springframework.util.StringUtils;
+
+import java.io.StringReader;
+import java.util.*;
+
+/**
+ * @author juven.xuxb
+ * @author xiaolongzuo
+ */
+class AcmPropertySourceBuilder {
+
+    private Logger logger = LoggerFactory.getLogger(AcmPropertySourceBuilder.class);
+
+    /**
+     * 传入 ACM 的 DataId 和 groupID，获取到解析后的 AcmProperty 对象
+     *
+     * @param dataId
+     * @param diamondGroup
+     * @param groupLevel
+     * @return
+     */
+    AcmPropertySource build(String dataId, String diamondGroup, boolean groupLevel) {
+        Properties properties = loadDiamondData(dataId, diamondGroup);
+        if (properties == null) {
+            return null;
+        }
+        return new AcmPropertySource(dataId, toMap(properties), new Date(), groupLevel);
+    }
+
+    private Properties loadDiamondData(String dataId, String diamondGroup) {
+        try {
+            String data = ConfigService.getConfig(dataId, diamondGroup, 3000L);
+            if (StringUtils.isEmpty(data)) {
+                return null;
+            }
+            if (dataId.endsWith(".properties")) {
+                Properties properties = new Properties();
+                logger.info(String.format("Loading acm data, dataId: '%s', group: '%s'",
+                    dataId, diamondGroup));
+                properties.load(new StringReader(data));
+                return properties;
+            } else if (dataId.endsWith(".yaml") || dataId.endsWith(".yml")) {
+                YamlPropertiesFactoryBean yamlFactory = new YamlPropertiesFactoryBean();
+                yamlFactory.setResources(new ByteArrayResource(data.getBytes()));
+                return yamlFactory.getObject();
+            }
+        } catch (Exception e) {
+            if (e instanceof ConfigException) {
+                logger.error("DIAMOND-100500:" + dataId + ", " + e.toString(), e);
+            } else {
+                logger.error("DIAMOND-100500:" + dataId, e);
+            }
+        }
+        return null;
+    }
+
+    @SuppressWarnings("unchecked")
+    private Map<String, Object> toMap(Properties properties) {
+        Map<String, Object> result = new HashMap<>();
+        Enumeration<String> keys = (Enumeration<String>)properties.propertyNames();
+        while (keys.hasMoreElements()) {
+            String key = keys.nextElement();
+            Object value = properties.getProperty(key);
+            if (value != null) {
+                result.put(key, ((String)value).trim());
+            } else {
+                result.put(key, null);
+            }
+        }
+        return result;
+    }
+}

spring-cloud-alicloud-acm/src/main/java/org/springframework/cloud/alicloud/acm/bootstrap/AcmPropertySourceLocator.java

@@ -0,0 +1,142 @@
+/*
+ * Copyright (C) 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alicloud.acm.bootstrap;
+
+import com.taobao.diamond.maintenance.DiamondHealth;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cloud.alicloud.acm.diagnostics.analyzer.DiamondConnectionFailureException;
+import org.springframework.cloud.alicloud.context.acm.AcmProperties;
+import org.springframework.cloud.bootstrap.config.PropertySourceLocator;
+import org.springframework.core.env.CompositePropertySource;
+import org.springframework.core.env.Environment;
+import org.springframework.core.env.PropertySource;
+import org.springframework.util.StringUtils;
+
+import static com.taobao.diamond.client.impl.ServerHttpAgent.addressPort;
+import static com.taobao.diamond.client.impl.ServerHttpAgent.domainName;
+
+/**
+ * @author juven.xuxb
+ * @author xiaolongzuo
+ */
+public class AcmPropertySourceLocator implements PropertySourceLocator {
+
+	private final Logger logger = LoggerFactory.getLogger(AcmPropertySourceLocator.class);
+
+	private static final String DIAMOND_PROPERTY_SOURCE_NAME = "diamond";
+
+	private static String defaultDiamondGroup = "DEFAULT_GROUP";
+
+	private AcmPropertySourceBuilder acmPropertySourceBuilder = new AcmPropertySourceBuilder();
+
+	@Autowired
+	private AcmProperties acmProperties;
+
+	@Override
+	public PropertySource<?> locate(Environment environment) {
+		checkDiamondHealth();
+
+		String applicationName = environment.getProperty("spring.application.name");
+		logger.info("Initialize spring.application.name '" + applicationName + "'.");
+		String applicationGroup = environment.getProperty("spring.application.group");
+
+		if (StringUtils.isEmpty(applicationName)) {
+			throw new IllegalStateException(
+					"'spring.application.name' must be configured.");
+		}
+
+		CompositePropertySource compositePropertySource = new CompositePropertySource(
+				DIAMOND_PROPERTY_SOURCE_NAME);
+
+		loadGroupConfigurationRecursively(compositePropertySource, applicationGroup);
+
+		loadApplicationConfiguration(compositePropertySource, environment,
+				applicationGroup, applicationName);
+
+		return compositePropertySource;
+	}
+
+	private void checkDiamondHealth() {
+		logger.info("Checking ACM health");
+		try {
+			if (!"UP".equals(DiamondHealth.getHealth())) {
+				throw new DiamondConnectionFailureException(domainName, addressPort,
+						DiamondHealth.getHealth());
+			}
+		}
+		catch (Throwable t) {
+			throw new DiamondConnectionFailureException(domainName, addressPort,
+					"ACM Health error", t);
+		}
+	}
+
+	private void loadGroupConfigurationRecursively(
+			CompositePropertySource compositePropertySource, String applicationGroup) {
+		if (StringUtils.isEmpty(applicationGroup)) {
+			return;
+		}
+		String[] parts = applicationGroup.split("\\.");
+		for (int i = 1; i < parts.length; i++) {
+			String subGroup = parts[0];
+			for (int j = 1; j <= i; j++) {
+				subGroup = subGroup + "." + parts[j];
+			}
+			String dataId = subGroup + ":application." + acmProperties.getFileExtension();
+			loadDiamondDataIfPresent(compositePropertySource, dataId, defaultDiamondGroup,
+					true);
+		}
+	}
+
+	private void loadApplicationConfiguration(
+			CompositePropertySource compositePropertySource, Environment environment,
+			String applicationGroup, String applicationName) {
+
+		if (!StringUtils.isEmpty(applicationGroup)) {
+			String dataId = applicationGroup + ":" + applicationName + "."
+					+ acmProperties.getFileExtension();
+			loadDiamondDataIfPresent(compositePropertySource, dataId, defaultDiamondGroup,
+					false);
+			for (String profile : environment.getActiveProfiles()) {
+				dataId = applicationGroup + ":" + applicationName + "-" + profile + "."
+						+ acmProperties.getFileExtension();
+				loadDiamondDataIfPresent(compositePropertySource, dataId,
+						defaultDiamondGroup, false);
+			}
+
+		}
+		String dataId = applicationName + "." + acmProperties.getFileExtension();
+		loadDiamondDataIfPresent(compositePropertySource, dataId, defaultDiamondGroup,
+				false);
+		for (String profile : environment.getActiveProfiles()) {
+			dataId = applicationName + "-" + profile + "."
+					+ acmProperties.getFileExtension();
+			loadDiamondDataIfPresent(compositePropertySource, dataId, defaultDiamondGroup,
+					false);
+		}
+	}
+
+	private void loadDiamondDataIfPresent(final CompositePropertySource composite,
+			final String dataId, final String diamondGroup, final boolean groupLevel) {
+		AcmPropertySource ps = acmPropertySourceBuilder.build(dataId, diamondGroup,
+				groupLevel);
+		if (ps != null) {
+			composite.addFirstPropertySource(ps);
+		}
+	}
+}

spring-cloud-alicloud-acm/src/main/java/org/springframework/cloud/alicloud/acm/diagnostics/analyzer/DiamondConnectionFailureAnalyzer.java

@@ -0,0 +1,40 @@
+/*
+ * Copyright (C) 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alicloud.acm.diagnostics.analyzer;
+
+import org.springframework.boot.diagnostics.AbstractFailureAnalyzer;
+import org.springframework.boot.diagnostics.FailureAnalysis;
+
+/**
+ * A {@code FailureAnalyzer} that performs analysis of failures caused by a
+ * {@code DiamondConnectionFailureException}.
+ *
+ * @author juven.xuxb, 07/11/2016.
+ */
+public class DiamondConnectionFailureAnalyzer
+		extends AbstractFailureAnalyzer<DiamondConnectionFailureException> {
+
+	@Override
+	protected FailureAnalysis analyze(Throwable rootFailure,
+			DiamondConnectionFailureException cause) {
+		return new FailureAnalysis(
+				"Application failed to connect to Diamond, unable to access http://"
+						+ cause.getDomain() + ":" + cause.getPort()
+						+ "/diamond-server/diamond",
+				"config the right endpoint", cause);
+	}
+}

spring-cloud-alicloud-acm/src/main/java/org/springframework/cloud/alicloud/acm/diagnostics/analyzer/DiamondConnectionFailureException.java

@@ -0,0 +1,52 @@
+/*
+ * Copyright (C) 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alicloud.acm.diagnostics.analyzer;
+
+/**
+ * A {@code DiamondConnectionFailureException} is thrown when the application fails to
+ * connect to Diamond Server.
+ *
+ * @author juven.xuxb, 07/11/2016.
+ */
+public class DiamondConnectionFailureException extends RuntimeException {
+
+	private final String domain;
+
+	private final String port;
+
+	public DiamondConnectionFailureException(String domain, String port, String message) {
+		super(message);
+		this.domain = domain;
+		this.port = port;
+	}
+
+	public DiamondConnectionFailureException(String domain, String port, String message,
+			Throwable cause) {
+		super(message, cause);
+		this.domain = domain;
+		this.port = port;
+	}
+
+	String getDomain() {
+		return domain;
+	}
+
+	String getPort() {
+		return port;
+	}
+
+}

spring-cloud-alicloud-acm/src/main/java/org/springframework/cloud/alicloud/acm/endpoint/AcmEndpoint.java

@@ -0,0 +1,77 @@
+/*
+ * Copyright (C) 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alicloud.acm.endpoint;
+
+import org.springframework.boot.actuate.endpoint.annotation.Endpoint;
+import org.springframework.boot.actuate.endpoint.annotation.ReadOperation;
+import org.springframework.cloud.alicloud.acm.AcmPropertySourceRepository;
+import org.springframework.cloud.alicloud.acm.bootstrap.AcmPropertySource;
+import org.springframework.cloud.alicloud.acm.refresh.AcmRefreshHistory;
+import org.springframework.cloud.alicloud.context.acm.AcmProperties;
+
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Created on 01/10/2017.
+ *
+ * @author juven.xuxb
+ */
+@Endpoint(id = "acm")
+public class AcmEndpoint {
+
+    private final AcmProperties properties;
+
+    private final AcmRefreshHistory refreshHistory;
+
+    private final AcmPropertySourceRepository propertySourceRepository;
+
+    private DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+    public AcmEndpoint(AcmProperties properties, AcmRefreshHistory refreshHistory,
+                       AcmPropertySourceRepository propertySourceRepository) {
+        this.properties = properties;
+        this.refreshHistory = refreshHistory;
+        this.propertySourceRepository = propertySourceRepository;
+    }
+
+    @ReadOperation
+    public Map<String, Object> invoke() {
+        Map<String, Object> result = new HashMap<>();
+        result.put("config", properties);
+
+        Map<String, Object> runtime = new HashMap<>();
+        List<AcmPropertySource> all = propertySourceRepository.getAll();
+
+        List<Map<String, Object>> sources = new ArrayList<>();
+        for (AcmPropertySource ps : all) {
+            Map<String, Object> source = new HashMap<>();
+            source.put("dataId", ps.getDataId());
+            source.put("lastSynced", dateFormat.format(ps.getTimestamp()));
+            sources.add(source);
+        }
+        runtime.put("sources", sources);
+        runtime.put("refreshHistory", refreshHistory.getRecords());
+
+        result.put("runtime", runtime);
+        return result;
+    }
+}

spring-cloud-alicloud-acm/src/main/java/org/springframework/cloud/alicloud/acm/endpoint/AcmEndpointAutoConfiguration.java

@@ -0,0 +1,52 @@
+/*
+ * Copyright (C) 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alicloud.acm.endpoint;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.actuate.autoconfigure.endpoint.condition.ConditionalOnEnabledEndpoint;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;
+import org.springframework.cloud.alicloud.acm.AcmPropertySourceRepository;
+import org.springframework.cloud.alicloud.acm.refresh.AcmRefreshHistory;
+import org.springframework.cloud.alicloud.context.acm.AcmProperties;
+import org.springframework.context.annotation.Bean;
+
+/**
+ * @author xiaojing
+ */
+@ConditionalOnWebApplication
+@ConditionalOnClass(name = "org.springframework.boot.actuate.autoconfigure.web.ManagementContextConfiguration")
+public class AcmEndpointAutoConfiguration {
+
+    @Autowired
+    private AcmProperties acmProperties;
+
+    @Autowired
+    private AcmRefreshHistory acmRefreshHistory;
+
+    @Autowired
+    private AcmPropertySourceRepository acmPropertySourceRepository;
+
+    @ConditionalOnMissingBean
+    @ConditionalOnEnabledEndpoint
+    @Bean
+    public AcmEndpoint acmEndpoint() {
+        return new AcmEndpoint(acmProperties, acmRefreshHistory,
+            acmPropertySourceRepository);
+    }
+}

spring-cloud-alicloud-acm/src/main/java/org/springframework/cloud/alicloud/acm/endpoint/AcmHealthIndicator.java

@@ -0,0 +1,71 @@
+/*
+ * Copyright (C) 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alicloud.acm.endpoint;
+
+import com.alibaba.edas.acm.ConfigService;
+import org.springframework.boot.actuate.health.AbstractHealthIndicator;
+import org.springframework.boot.actuate.health.Health;
+import org.springframework.cloud.alicloud.acm.AcmPropertySourceRepository;
+import org.springframework.cloud.alicloud.acm.bootstrap.AcmPropertySource;
+import org.springframework.cloud.alicloud.context.acm.AcmProperties;
+import org.springframework.util.StringUtils;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author leijuan
+ * @author juven
+ */
+public class AcmHealthIndicator extends AbstractHealthIndicator {
+
+    private final AcmProperties acmProperties;
+
+    private final AcmPropertySourceRepository acmPropertySourceRepository;
+
+    private final List<String> dataIds;
+
+    public AcmHealthIndicator(AcmProperties acmProperties,
+                              AcmPropertySourceRepository acmPropertySourceRepository) {
+        this.acmProperties = acmProperties;
+        this.acmPropertySourceRepository = acmPropertySourceRepository;
+
+        this.dataIds = new ArrayList<>();
+        for (AcmPropertySource acmPropertySource : this.acmPropertySourceRepository
+            .getAll()) {
+            this.dataIds.add(acmPropertySource.getDataId());
+        }
+    }
+
+    @Override
+    protected void doHealthCheck(Health.Builder builder) throws Exception {
+        for (String dataId : dataIds) {
+            try {
+                String config = ConfigService.getConfig(dataId, acmProperties.getGroup(),
+                    acmProperties.getTimeout());
+                if (StringUtils.isEmpty(config)) {
+                    builder.down().withDetail(String.format("dataId: '%s', group: '%s'",
+                        dataId, acmProperties.getGroup()), "config is empty");
+                }
+            } catch (Exception e) {
+                builder.down().withDetail(String.format("dataId: '%s', group: '%s'",
+                    dataId, acmProperties.getGroup()), e.getMessage());
+            }
+        }
+        builder.up().withDetail("dataIds", dataIds);
+    }
+}

spring-cloud-alicloud-acm/src/main/java/org/springframework/cloud/alicloud/acm/refresh/AcmContextRefresher.java

@@ -0,0 +1,125 @@
+/*
+ * Copyright (C) 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alicloud.acm.refresh;
+
+import com.alibaba.edas.acm.ConfigService;
+import com.alibaba.edas.acm.listener.ConfigChangeListener;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.context.event.ApplicationReadyEvent;
+import org.springframework.cloud.alicloud.acm.AcmPropertySourceRepository;
+import org.springframework.cloud.alicloud.acm.bootstrap.AcmPropertySource;
+import org.springframework.cloud.alicloud.context.acm.AcmProperties;
+import org.springframework.cloud.context.refresh.ContextRefresher;
+import org.springframework.context.ApplicationListener;
+import org.springframework.core.env.Environment;
+import org.springframework.util.StringUtils;
+
+import java.io.UnsupportedEncodingException;
+import java.math.BigInteger;
+import java.security.MessageDigest;
+import java.security.NoSuchAlgorithmException;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * On application start up, AcmContextRefresher add diamond listeners to all application
+ * level dataIds, when there is a change in the data, listeners will refresh
+ * configurations.
+ *
+ * @author juven.xuxb, 5/13/16.
+ */
+public class AcmContextRefresher implements ApplicationListener<ApplicationReadyEvent> {
+
+	private Logger logger = LoggerFactory.getLogger(AcmContextRefresher.class);
+
+	private final ContextRefresher contextRefresher;
+
+	private final AcmProperties properties;
+
+	private final AcmRefreshHistory refreshHistory;
+
+	private final AcmPropertySourceRepository acmPropertySourceRepository;
+
+	private Map<String, ConfigChangeListener> listenerMap = new ConcurrentHashMap<>(16);
+
+	@Autowired
+	private Environment environment;
+
+	public AcmContextRefresher(ContextRefresher contextRefresher,
+			AcmProperties properties, AcmRefreshHistory refreshHistory,
+			AcmPropertySourceRepository acmPropertySourceRepository) {
+		this.contextRefresher = contextRefresher;
+		this.properties = properties;
+		this.refreshHistory = refreshHistory;
+		this.acmPropertySourceRepository = acmPropertySourceRepository;
+	}
+
+	@Override
+	public void onApplicationEvent(ApplicationReadyEvent event) {
+		this.registerDiamondListenersForApplications();
+	}
+
+	private void registerDiamondListenersForApplications() {
+		if (properties.isRefreshEnabled()) {
+			for (AcmPropertySource acmPropertySource : acmPropertySourceRepository
+					.getAll()) {
+				if (acmPropertySource.isGroupLevel()) {
+					continue;
+				}
+				String dataId = acmPropertySource.getDataId();
+				registerDiamondListener(dataId);
+			}
+			if (acmPropertySourceRepository.getAll().isEmpty()) {
+
+				String applicationName = environment
+						.getProperty("spring.application.name");
+				String dataId = applicationName + "." + properties.getFileExtension();
+
+				registerDiamondListener(dataId);
+			}
+		}
+	}
+
+	private void registerDiamondListener(final String dataId) {
+
+		ConfigChangeListener listener = listenerMap.computeIfAbsent(dataId,
+				i -> new ConfigChangeListener() {
+					@Override
+					public void receiveConfigInfo(String configInfo) {
+						String md5 = "";
+						if (!StringUtils.isEmpty(configInfo)) {
+							try {
+								MessageDigest md = MessageDigest.getInstance("MD5");
+								md5 = new BigInteger(1,
+										md.digest(configInfo.getBytes("UTF-8")))
+												.toString(16);
+							}
+							catch (NoSuchAlgorithmException
+									| UnsupportedEncodingException e) {
+								logger.warn("unable to get md5 for dataId: " + dataId, e);
+							}
+						}
+						refreshHistory.add(dataId, md5);
+						contextRefresher.refresh();
+					}
+				});
+		ConfigService.addListener(dataId, properties.getGroup(), listener);
+	}
+
+}

spring-cloud-alicloud-acm/src/main/java/org/springframework/cloud/alicloud/acm/refresh/AcmRefreshHistory.java

@@ -0,0 +1,72 @@
+/*
+ * Copyright (C) 2018 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.alicloud.acm.refresh;
+
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.LinkedList;
+
+/**
+ * @author juven.xuxb, 5/16/16.
+ */
+public class AcmRefreshHistory {
+
+	private static final int MAX_SIZE = 20;
+
+	private LinkedList<Record> records = new LinkedList<>();
+
+	private DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+
+	public void add(String dataId, String md5) {
+		records.addFirst(new Record(dateFormat.format(new Date()), dataId, md5));
+		if (records.size() > MAX_SIZE) {
+			records.removeLast();
+		}
+	}
+
+	public LinkedList<Record> getRecords() {
+		return records;
+	}
+}
+
+class Record {
+
+	private final String timestamp;
+
+	private final String dataId;
+
+	private final String md5;
+
+	public Record(String timestamp, String dataId, String md5) {
+		this.timestamp = timestamp;
+		this.dataId = dataId;
+		this.md5 = md5;
+	}
+
+	public String getTimestamp() {
+		return timestamp;
+	}
+
+	public String getDataId() {
+		return dataId;
+	}
+
+	public String getMd5() {
+		return md5;
+	}
+}

spring-cloud-alicloud-acm/src/main/resources/META-INF/additional-spring-configuration-metadata.json

@@ -0,0 +1,9 @@
+{
+  "properties": [
+    {
+      "name": "spring.application.group",
+      "type": "java.lang.String",
+      "description": "spring application group."
+    }
+  ]
+}

spring-cloud-alicloud-acm/src/main/resources/META-INF/spring.factories

@@ -0,0 +1,9 @@
+org.springframework.cloud.bootstrap.BootstrapConfiguration=\
+org.springframework.cloud.alicloud.acm.bootstrap.AcmPropertySourceLocator
+
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
+org.springframework.cloud.alicloud.acm.AcmAutoConfiguration,\
+org.springframework.cloud.alicloud.acm.endpoint.AcmEndpointAutoConfiguration
+
+org.springframework.boot.diagnostics.FailureAnalyzer=\
+org.springframework.cloud.alicloud.acm.diagnostics.analyzer.DiamondConnectionFailureAnalyzer