? ? ? ? 由于apollo的特性,使其在配置变化的时候,我们可以监听他的变化,从而作出一些类似配置触发器的系列操作。
? ? ? ? 比如我们现有的需求,假如发送队列的配置开关开启了,则启动一个测试程序,去测试队列的容量和服务连通情况,并且这个操作只在配置发生改变的时候触发一次,这个时候就需要用到apollo配置监听了。
import com.ctrip.framework.apollo.model.ConfigChange;
import com.ctrip.framework.apollo.model.ConfigChangeEvent;
import com.ctrip.framework.apollo.spring.annotation.ApolloConfigChangeListener;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
/**
* @author wangxiao
*/
@Slf4j
@Component
public class AutomaticApolloWatcher {
@ApolloConfigChangeListener
public void watchSingle(ConfigChangeEvent changeEvent) {
for (String key : changeEvent.changedKeys()) {
ConfigChange change = changeEvent.getChange(key);
// do something
}
}
}
? ? ? ? 我们使用这段代码注入到spring中作为监听,就可以监听到配置的变化了,其中for循环的是变化的配置key列表,然后我们可以从中获取配置变化的具体信息。
? ? ? ? change就是我们配置的一系列信息,包括key相关的app,namespace,原值,修改之后的值等,详见下图:
? ? ? ? ?从另一个角度,我们也可以看出来,apollo的这个设计也用到了设计模式中的观察者模式,通过订阅发布的方式来监听apollo整个系统中发送出来的配置变更消息。
|