由于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整个系统中发送出来的配置变更消息。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)