java客户端线上Apollo服务端的实现

java客户端线上Apollo服务端的实现

1.指定环境

1.1 在C:\opt\settings\下有server.properties

env=DEV是对应服务器上的如下图

apollo.meta=http://192.168.1.143:8070是你服务端的端口号

1.2 在C:\opt\data\babel023\config-cache有这四个文件

2.在META-INF下创建app.properties

3.创建个SimpleApolloConfig

package com.fqgj.rest;

import com.google.common.base.Charsets;

import com.ctrip.framework.apollo.Config;

import com.ctrip.framework.apollo.ConfigChangeListener;

import com.ctrip.framework.apollo.ConfigService;

import com.ctrip.framework.apollo.model.ConfigChange;

import com.ctrip.framework.apollo.model.ConfigChangeEvent;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import java.io.BufferedReader;

import java.io.IOException;

import java.io.InputStreamReader;

/**

* @author Jason Song(song_s@ctrip.com)

*/

public class SimpleApolloConfigDemo {

private static final Logger logger = LoggerFactory.getLogger(SimpleApolloConfigDemo.class);

private String DEFAULT_VALUE = "undefined";

private Config config;

public SimpleApolloConfigDemo() {

ConfigChangeListener changeListener = new ConfigChangeListener() {

@Override

public void onChange(ConfigChangeEvent changeEvlvohxvtent) {

logger.info("Changes for namespace {}", changeEvent.getNamespace());

for (String key : changeEvent.changedKeys()) {

ConfigChange change = changeEvent.getChange(key);

logger.info("Change - key: {}, oldValue: {}, newValue: {}, changeType: {}",

change.getPropertyName(), change.getOldValue(), change.getNewValue(),

change.getChangeType());

}

}

};

config = ConfigService.getAppConfig();

config.addChangeListener(changeListener);

}

private String getConfig(String key) {

String result = config.getProperty(key, DEFAULT_VALUE);

logger.info(String.format("Loading key : %s with value: %s", key, result));

return result;

}

public static void main(String[] args) throws IOException {

SimpleApolloConfigDemo apolloConfigDemo = new SimpleApolloConfigDemo();

System.out.println(

"Apollo Config Demo. Please input key to get the value. Input quit to exit.");

while (true) {

System.out.print("> ");

String inpuhttp://t = new BufferedReader(new InputStreamReader(System.in, Charsets.UTF_8)).readLine();

http:// if (input == null || input.length() == 0) {

continue;

}

input = input.trim();

if (input.equalsIgnoreCase("quit")) {

System.exit(0);

}

String ccc= apolloConfigDemo.getConfig(input);

System.out.println(ccc);

}

}

}

运行结果如下

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。