Apollo Java客戶端
阿新 • • 發佈：2019-02-16
1.指定環境
C:\opt\settings\server.properties
env=DEV
2.指定APP.ID
在classpath:/META-INF/app.properties檔案中指定
app.id=100000001
3.pom.xml
<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" 4.API方式
API方式獲取實時結果，因此不需要快取
（1）程式碼
new ClassPathXmlApplicationContext(
"application.xml");
Config config = ConfigService.getAppConfig(); //config instance is singleton for each namespace and is never null
String someKey = "redis.ip";
String someDefaultValue = "127.0.0.1";
String value = config.getProperty(someKey, someDefaultValue);
System.out.println(value);（2）管理中心配置
（3）執行結果
5.基於java config方式的配置動態更新
管理中心修改配置後，實時更新配置資訊
（1）程式碼
@RefreshScope
@Component("redisConfig")
public class RedisConfig {
@Value("${redis.ip:127.0.0.1}")
private String ip;
public String getIp() {
return ip;
}
public void setIp(String ip) {
this.ip = ip;
}
@PreDestroy
public void destroy(){
System.out.println("destroy");
}
}@Configuration
@EnableApolloConfig
//@Import(RefreshAutoConfiguration.class)
public class AppConfig {
}@Component
public class ApolloRefreshConfig {
private static final Logger logger = LoggerFactory.getLogger(ApolloRefreshConfig.class);
@Autowired
private RefreshScope refreshScope;
@ApolloConfigChangeListener("application")
private void onChange(ConfigChangeEvent changeEvent) {
if (changeEvent.isChanged("redis.ip")) {
//could also call refreshScope.refreshAll();
// refreshScope.refresh("redisConfig");
refreshScope.refreshAll();
}
}
}public class ApolloConfigCenter {
public static void main(String[] args) {
ApplicationContext ac = new ClassPathXmlApplicationContext(
"application.xml");
RedisConfig config = ac.getBean(RedisConfig.class);
while (true){
try {
System.out.println(config.getIp());
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}（2）application.xml配置
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
xmlns:apollo="http://www.ctrip.com/schema/apollo" xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
http://www.ctrip.com/schema/apollo http://www.ctrip.com/schema/apollo.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd">
<apollo:config order="10" />
<context:annotation-config />
<context:component-scan base-package="com.travelsky.pss" />
<!-- to support RefreshScope -->
<bean class="org.springframework.cloud.autoconfigure.RefreshAutoConfiguration"/>
</beans>（3）配置中心
（4）修改配置併發布
（5）監控結果
6.基於XML方式
（1）程式碼
public class XmlRedisConfig {
private String ip;
public String getIp() {
return ip;
}
public void setIp(String ip) {
this.ip = ip;
}
}//實時重新整理
public class ManualRefreshUtil {
private static final Logger logger = LoggerFactory.getLogger(ManualRefreshUtil.class);
@ApolloConfig
private Config config;
@Autowired
private XmlRedisConfig redisConfig;
@ApolloConfigChangeListener
private void onChange(ConfigChangeEvent changeEvent) {
if (changeEvent.isChanged("redis.ip")) {
logger.info("Manually refreshing redisConfig.ip");
redisConfig.setIp(config.getProperty("redis.ip", redisConfig.getIp()));
}
}
}（2）application.xml配置
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
xmlns:apollo="http://www.ctrip.com/schema/apollo" xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
http://www.ctrip.com/schema/apollo http://www.ctrip.com/schema/apollo.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd">
<apollo:config order="10" />
<context:annotation-config />
<context:component-scan base-package="com.travelsky.pss" />
<bean id="xmlRedisConfig" class="com.travelsky.pss.xml.bean.XmlRedisConfig">
<property name="ip" value="${redis.ip}" />
</bean>
<bean class="com.travelsky.pss.xml.refresh.ManualRefreshUtil"/>
</beans>（3）配置中心
（4）修改配置併發布
（5）監控結果
