注意:本文档适用对象是Apollo系统的使用者,如果你是公司内Apollo系统的开发者/维护人员,建议先参考Apollo开发指南。
注:对于Apollo客户端,如果有需要的话,可以做少量代码修改来降级到Java 1.6,详细信息可以参考Issue 483
Apollo客户端依赖于AppId
,Apollo Meta Server
等环境信息来工作,所以请确保阅读下面的说明并且做正确的配置:
AppId是应用的身份信息,是从服务端获取配置的一个重要信息。
有以下几种方式设置,按照优先级从高到低分别为:
Apollo 0.7.0+支持通过System Property传入app.id信息,如
-Dapp.id=YOUR-APP-ID
Apollo 1.4.0+支持通过操作系统的System Environment APP_ID
来传入app.id信息,如
APP_ID=YOUR-APP-ID
Apollo 1.0.0+支持通过Spring Boot的application.properties文件配置,如
app.id=YOUR-APP-ID
该配置方式不适用于多个war包部署在同一个tomcat的使用场景
确保classpath:/META-INF/app.properties文件存在,并且其中内容形如:
app.id=YOUR-APP-ID
文件位置参考如下:
注:app.id是用来标识应用身份的唯一id,格式为string。
Apollo支持应用在不同的环境有不同的配置,所以需要在运行提供给Apollo客户端当前环境的Apollo Meta Server信息。默认情况下,meta server和config service是部署在同一个JVM进程,所以meta server的地址就是config service的地址。
为了实现meta server的高可用,推荐通过SLB(Software Load Balancer)做动态负载均衡。Meta server地址也可以填入IP,如http://1.1.1.1:8080,http://2.2.2.2:8080
,不过生产环境还是建议使用域名(走slb),因为机器扩容、缩容等都可能导致IP列表的变化。
1.0.0版本开始支持以下方式配置apollo meta server信息,按照优先级从高到低分别为:
apollo.meta
apollo.meta
来指定-Dapollo.meta=http://config-service-url
java -Dapollo.meta=http://config-service-url -jar xxx.jar
System.setProperty("apollo.meta", "http://config-service-url");
application.properties
或bootstrap.properties
中指定apollo.meta=http://config-service-url
> 该配置方式不适用于多个war包部署在同一个tomcat的使用场景APOLLO_META
APOLLO_META
来指定_
分隔server.properties
配置文件
server.properties
配置文件中指定apollo.meta=http://config-service-url
/opt/settings/server.properties
C:\opt\settings\server.properties
app.properties
配置文件
classpath:/META-INF/app.properties
指定apollo.meta=http://config-service-url
${env}_meta
dev
,那么用户可以配置-Ddev_meta=http://config-service-url
${ENV}_META
(1.2.0版本开始支持)
dev
,那么用户可以配置操作系统的System Environment DEV_META=http://config-service-url
通过apollo-env.properties
文件
apollo-env.properties
,放在程序的classpath下,或者放在spring boot应用的config目录下文件内容形如:
dev.meta=http://1.1.1.1:8080
fat.meta=http://apollo.fat.xxx.com
uat.meta=http://apollo.uat.xxx.com
pro.meta=http://apollo.xxx.com
如果通过以上各种手段都无法获取到Meta Server地址,Apollo最终会fallback到
http://apollo.meta
作为Meta Server地址
在1.0.0版本中,Apollo提供了MetaServerProvider SPI,用户可以注入自己的MetaServerProvider来自定义Meta Server地址定位逻辑。
由于我们使用典型的Java Service Loader模式,所以实现起来还是比较简单的。
有一点需要注意的是,apollo会在运行时按照顺序遍历所有的MetaServerProvider,直到某一个MetaServerProvider提供了一个非空的Meta Server地址,因此用户需要格外注意自定义MetaServerProvider的Order。规则是较小的Order具有较高的优先级,因此Order=0的MetaServerProvider会排在Order=1的MetaServerProvider的前面。
如果你的公司有很多应用需要接入Apollo,建议封装一个jar包,然后提供自定义的Apollo Meta Server定位逻辑,从而可以让接入Apollo的应用零配置使用。比如自己写一个xx-company-apollo-client
,该jar包依赖apollo-client
,在该jar包中通过spi方式定义自定义的MetaServerProvider实现,然后应用直接依赖xx-company-apollo-client
即可。
MetaServerProvider的实现可以参考LegacyMetaServerProvider和DefaultMetaServerProvider。
适用于apollo-client 0.11.0及以上版本
一般情况下都建议使用Apollo的Meta Server机制来实现Config Service的服务发现,从而可以实现Config Service的高可用。不过apollo-client也支持跳过Meta Server服务发现,主要用于以下场景:
针对以上场景,可以通过直接指定Config Service地址的方式来跳过Meta Server服务发现,按照优先级从高到低分别为:
apollo.config-service
(1.9.0+) 或者 apollo.configService
(1.9.0之前)
apollo.config-service
(1.9.0+) 或者 apollo.configService
(1.9.0之前)来指定-Dapollo.config-service=http://config-service-url:port
java -Dapollo.configService=http://config-service-url:port -jar xxx.jar
System.setProperty("apollo.config-service", "http://config-service-url:port");
APOLLO_CONFIG_SERVICE
(1.9.0+) 或者 APOLLO_CONFIGSERVICE
(1.9.0之前)
APOLLO_CONFIG_SERVICE
(1.9.0+) 或者 APOLLO_CONFIGSERVICE
(1.9.0之前)来指定_
分隔server.properties
配置文件
server.properties
配置文件中指定apollo.config-service=http://config-service-url:port
(1.9.0+) 或者 apollo.configService=http://config-service-url:port
(1.9.0之前)
/opt/settings/server.properties
C:\opt\settings\server.properties
Apollo客户端会把从服务端获取到的配置在本地文件系统缓存一份,用于在遇到服务不可用,或网络不通的时候,依然能从本地恢复配置,不影响应用正常运行。
本地缓存路径默认位于以下路径,所以请确保/opt/data
或C:\opt\data\
目录存在,且应用有读写权限。
本地配置文件会以下面的文件名格式放置于本地缓存路径下:
{appId}+{cluster}+{namespace}.properties
文件内容以properties格式存储,比如如果有两个key,一个是request.timeout,另一个是batch,那么文件内容就是如下格式:
request.timeout=2000
batch=2000
注:如果部署在Kubernetes环境中,您还可以启用configMap缓存来进一步提高可用性
1.0.0版本开始支持以下方式自定义缓存路径,按照优先级从高到低分别为:
apollo.cache-dir
(1.9.0+) 或者 apollo.cacheDir
(1.9.0之前)
apollo.cache-dir
(1.9.0+) 或者 apollo.cacheDir
(1.9.0之前)来指定-Dapollo.cache-dir=/opt/data/some-cache-dir
(1.9.0+) 或者 apollo.cacheDir=/opt/data/some-cache-dir
(1.9.0之前)
java -Dapollo.cache-dir=/opt/data/some-cache-dir -jar xxx.jar
(1.9.0+) 或者 java -Dapollo.cacheDir=/opt/data/some-cache-dir -jar xxx.jar
(1.9.0之前)System.setProperty("apollo.cache-dir", "/opt/data/some-cache-dir");
(1.9.0+) 或者 System.setProperty("apollo.cacheDir", "/opt/data/some-cache-dir");
(1.9.0之前)application.properties
或bootstrap.properties
中指定apollo.cache-dir=/opt/data/some-cache-dir
(1.9.0+) 或者 apollo.cacheDir=/opt/data/some-cache-dir
(1.9.0之前)APOLLO_CACHE_DIR
(1.9.0+) 或者 APOLLO_CACHEDIR
(1.9.0之前)
APOLLO_CACHE_DIR
(1.9.0+) 或者 APOLLO_CACHEDIR
(1.9.0之前)来指定_
分隔server.properties
配置文件
server.properties
配置文件中指定apollo.cache-dir=/opt/data/some-cache-dir
(1.9.0+) 或者 apollo.cacheDir=/opt/data/some-cache-dir
(1.9.0之前)/opt/settings/server.properties
C:\opt\settings\server.properties
注:本地缓存路径也可用于容灾目录,如果应用在所有config service都挂掉的情况下需要扩容,那么也可以先把配置从已有机器上的缓存路径复制到新机器上的相同缓存路径
Environment可以通过以下3种方式的任意一个配置:
通过Java System Property
env
来指定环境-Denv=YOUR-ENVIRONMENT
java -Denv=YOUR-ENVIRONMENT -jar xxx.jar
通过操作系统的System Environment
ENV
来指定通过配置文件
env=YOUR-ENVIRONMENT
/opt/settings/server.properties
C:\opt\settings\server.properties
文件内容形如:
env=DEV
目前,env
支持以下几个值(大小写不敏感):
更多环境定义,可以参考Env.java
Apollo支持配置按照集群划分,也就是说对于一个appId和一个环境,对不同的集群可以有不同的配置。
1.0.0版本开始支持以下方式集群,按照优先级从高到低分别为:
apollo.cluster
apollo.cluster
来指定-Dapollo.cluster=SomeCluster
java -Dapollo.cluster=SomeCluster -jar xxx.jar
System.setProperty("apollo.cluster", "SomeCluster");
application.properties
或bootstrap.properties
中指定apollo.cluster=SomeCluster
idc
来指定环境-Didc=xxx
java -Didc=xxx -jar xxx.jar
IDC
来指定server.properties
配置文件
server.properties
配置文件中指定idc=xxx
/opt/settings/server.properties
C:\opt\settings\server.properties
Cluster Precedence(集群顺序)
如果apollo.cluster
和idc
同时指定:
apollo.cluster
指定的集群加载配置idc
指定的集群加载配置default
)加载如果只指定了apollo.cluster
:
apollo.cluster
指定的集群加载配置default
)加载如果只指定了idc
:
idc
指定的集群加载配置default
)加载如果apollo.cluster
和idc
都没有指定:
default
)加载配置适用于1.6.0及以上版本
默认情况下,apollo client内存中的配置存放在Properties中(底下是Hashtable),不会刻意保持和页面上看到的顺序一致,对绝大部分的场景是没有影响的。不过有些场景会强依赖配置项的顺序(如spring cloud zuul的路由规则),针对这种情况,可以开启OrderedProperties特性来使得内存中的配置顺序和页面上看到的一致。
配置方式按照优先级从高到低分别为:
apollo.property.order.enable
apollo.property.order.enable
来指定-Dapollo.property.order.enable=true
java -Dapollo.property.order.enable=true -jar xxx.jar
System.setProperty("apollo.property.order.enable", "true");
application.properties
或bootstrap.properties
中指定apollo.property.order.enable=true
app.properties
配置文件
classpath:/META-INF/app.properties
指定apollo.property.order.enable=true
适用于1.6.0及以上版本
Apollo从1.6.0版本开始增加访问密钥机制,从而只有经过身份验证的客户端才能访问敏感配置。如果应用开启了访问密钥,客户端需要配置密钥,否则无法获取配置。
配置方式按照优先级从高到低分别为:
apollo.access-key.secret
(1.9.0+) 或者 apollo.accesskey.secret
(1.9.0之前)
apollo.access-key.secret
(1.9.0+) 或者 apollo.accesskey.secret
(1.9.0之前)来指定-Dapollo.access-key.secret=1cf998c4e2ad4704b45a98a509d15719
(1.9.0+) 或者 -Dapollo.accesskey.secret=1cf998c4e2ad4704b45a98a509d15719
(1.9.0之前)
java -Dapollo.access-key.secret=1cf998c4e2ad4704b45a98a509d15719 -jar xxx.jar
(1.9.0+) 或者 java -Dapollo.accesskey.secret=1cf998c4e2ad4704b45a98a509d15719 -jar xxx.jar
(1.9.0之前)System.setProperty("apollo.access-key.secret", "1cf998c4e2ad4704b45a98a509d15719");
(1.9.0+) 或者 System.setProperty("apollo.accesskey.secret", "1cf998c4e2ad4704b45a98a509d15719");
(1.9.0之前)application.properties
或bootstrap.properties
中指定apollo.access-key.secret=1cf998c4e2ad4704b45a98a509d15719
(1.9.0+) 或者 apollo.accesskey.secret=1cf998c4e2ad4704b45a98a509d15719
(1.9.0之前)APOLLO_ACCESS_KEY_SECRET
(1.9.0+) 或者 APOLLO_ACCESSKEY_SECRET
(1.9.0之前)来指定app.properties
配置文件
classpath:/META-INF/app.properties
指定apollo.access-key.secret=1cf998c4e2ad4704b45a98a509d15719
(1.9.0+) 或者 apollo.accesskey.secret=1cf998c4e2ad4704b45a98a509d15719
(1.9.0之前)适用于1.8.0及以上版本
1.8.0版本开始支持以下方式自定义server.properties路径,按照优先级从高到低分别为:
apollo.path.server.properties
apollo.path.server.properties
来指定-Dapollo.path.server.properties=/some-dir/some-file.properties
java -Dapollo.path.server.properties=/some-dir/some-file.properties -jar xxx.jar
System.setProperty("apollo.path.server.properties", "/some-dir/some-file.properties");
APOLLO_PATH_SERVER_PROPERTIES
APOLLO_PATH_SERVER_PROPERTIES
来指定_
分隔propertyNames
缓存,在大量配置场景下可以显著改善启动速度适用于1.9.0及以上版本
在使用@ConfigurationProperties
和存在大量配置项场景下,Spring容器的启动速度会变慢。通过开启该配置可以显著提升启动速度,当配置发生变化时缓存会自动清理,默认为false
。详见:issue 3800
配置方式按照优先级从高到低依次为:
apollo.property.names.cache.enable
apollo.property.names.cache.enable
来指定-Dapollo.property.names.cache.enable=true
java -Dapollo.property.names.cache.enable=true -jar xxx.jar
System.setProperty("apollo.property.names.cache.enable", "true");
APOLLO_PROPERTY_NAMES_CACHE_ENABLE=true
来指定_
分隔application.properties
或bootstrap.properties
中指定apollo.property.names.cache.enable=true
app.properties
配置文件
classpath:/META-INF/app.properties
指定apollo.property.names.cache.enable=true
ApolloLabel是应用的标签信息,是从服务端获取配置的一个重要信息,用于灰度规则的配置。
有以下几种方式设置,按照优先级从高到低分别为:
Apollo 2.0.0+支持通过System Property传入apollo.label信息,如
-Dapollo.label=YOUR-APOLLO-LABEL
Apollo 2.0.0+支持通过操作系统的System Environment APP_LABEL
来传入apollo.label信息,如
APOLLO_LABEL=YOUR-APOLLO-LABEL
Apollo 2.0.0+支持通过Spring Boot的application.properties文件配置,如
apollo.label=YOUR-APOLLO-LABEL
该配置方式不适用于多个war包部署在同一个tomcat的使用场景
确保classpath:/META-INF/app.properties文件存在,并且其中内容形如:
apollo.label=YOUR-APOLLO-LABEL
文件位置参考如下:
注:apollo.label是用来标识应用身份的标签,格式为string。
适用于2.1.0及以上版本
apollo.override-system-properties
标识Apollo的远程属性是否应该覆盖Java的系统属性。默认为 true。
配置方式按照优先级从高到低分别为:
apollo.override-system-properties
apollo.override-system-properties
来指定-Dapollo.override-system-properties=true
java -Dapollo.override-system-properties=true -jar xxx.jar
System.setProperty("apollo.override-system-properties", "true");
application.properties
或bootstrap.properties
中指定apollo.override-system-properties=true
app.properties
配置文件
classpath:/META-INF/app.properties
指定apollo.override-system-properties=true
适用于2.4.0及以上版本
在2.4.0版本开始,客户端在Kubernetes环境下的可用性得到了加强,开启configMap缓存后,客户端会将从服务端拉取到的配置信息在configMap中缓存一份,在服务不可用,或网络不通,且本地缓存文件丢失的情况下,依然能从configMap恢复配置。以下是相关配置
apollo.cache.kubernetes.enable
:是否开启configMap缓存机制,默认false
apollo.cache.kubernetes.namespace
:将使用的configMap所在的namespace(Kubernetes中的namespace),默认值为"default"
配置信息会以下面的对应关系放置于指定的configmap中:
namespace:使用指定的值,若未指定默认为"default"
configMapName: apollo-configcache-{appId}
key:{cluster}___{namespace}
value:内容为对应的配置信息的json格式字符串
appId是应用自己的appId,如100004458
cluster是应用使用的集群,一般在本地模式下没有做过配置的话,是default
namespace就是应用使用的配置namespace。 如果namespace中出现‘_’ , 将会在拼接key时被转义为‘__’由于此功能为拓展功能,所以对于client-java的依赖设为了optional。需用户自行导入匹配的版本
由于需要对configmap进行读写操作,所以客户端所在pod必须有相应读写权限,具体配置方法可参考下文
如何授权一个Pod的Service Account具有对ConfigMap的读写权限:
创建Service Account: 如果还没有Service Account,你需要创建一个。
apiVersion: v1
kind: ServiceAccount
metadata:
name: my-service-account
namespace: default
创建Role或ClusterRole: 定义一个Role或ClusterRole,授予对特定ConfigMap的读写权限。如果ConfigMap是跨多个Namespace使用的,应该使用ClusterRole。
apiVersion: rbac.authorization.k8s.io/v1
kind: Role
metadata:
namespace: default
name: configmap-role
rules:
- apiGroups: [""]
resources: ["configmaps"]
verbs: ["get", "list", "watch", "create", "update", "delete"]
绑定Service Account到Role或ClusterRole: 使用RoleBinding或ClusterRoleBinding将Service Account绑定到上面创建的Role或ClusterRole。
apiVersion: rbac.authorization.k8s.io/v1
kind: RoleBinding
metadata:
name: configmap-reader-binding
namespace: default
subjects:
- kind: ServiceAccount
name: my-service-account
namespace: default
roleRef:
kind: Role
name: configmap-role
apiGroup: rbac.authorization.k8s.io
在Pod配置中指定Service Account: 确保Pod的配置中使用了上面创建的Service Account。
apiVersion: v1
kind: Pod
metadata:
name: my-pod
namespace: default
spec:
serviceAccountName: my-service-account
containers:
- name: my-container
image: my-image
应用配置: 使用kubectl命令行工具应用这些配置。
kubectl apply -f service-account.yaml
kubectl apply -f role.yaml
kubectl apply -f role-binding.yaml
kubectl apply -f pod.yaml
这些步骤使Pod中的Service Account具有对指定ConfigMap的读写权限。
如果ConfigMap是跨Namespace的,使用ClusterRole和ClusterRoleBinding代替Role和RoleBinding,并确保在所有需要访问ConfigMap的Namespace中应用这些配置。
Apollo的客户端jar包已经上传到中央仓库,应用在实际使用时只需要按照如下方式引入即可。
<dependency>
<groupId>com.ctrip.framework.apollo</groupId>
<artifactId>apollo-client</artifactId>
<version>1.7.0</version>
</dependency>
Apollo支持API方式和Spring整合方式,该怎么选择用哪一种方式?
@Value("${someKeyFromApollo:someDefaultValue}")
spring.datasource.url: ${someKeyFromApollo:someDefaultValue}
spring.datasource.url=jdbc:mysql://localhost:3306/somedb?characterEncoding=utf8
Spring方式也可以结合API方式使用,如注入Apollo的Config对象,就可以照常通过API方式获取配置了:
@ApolloConfig
private Config config; //inject config for namespace application
更多有意思的实际使用场景和示例代码,请参考apollo-use-cases
API方式是最简单、高效使用Apollo配置的方式,不依赖Spring框架即可使用。
Config config = ConfigService.getAppConfig(); //config instance is singleton for each namespace and is never null
String someKey = "someKeyFromDefaultNamespace";
String someDefaultValue = "someDefaultValueForTheKey";
String value = config.getProperty(someKey, someDefaultValue);
通过上述的config.getProperty可以获取到someKey对应的实时最新的配置值。
另外,配置值从内存中获取,所以不需要应用自己做缓存。
监听配置变化事件只在应用真的关心配置变化,需要在配置变化时得到通知时使用,比如:数据库连接串变化后需要重建连接等。
如果只是希望每次都取到最新的配置的话,只需要按照上面的例子,调用config.getProperty即可。
Config config = ConfigService.getAppConfig(); //config instance is singleton for each namespace and is never null
config.addChangeListener(new ConfigChangeListener() {
@Override
public void onChange(ConfigChangeEvent changeEvent) {
System.out.println("Changes for namespace " + changeEvent.getNamespace());
for (String key : changeEvent.changedKeys()) {
ConfigChange change = changeEvent.getChange(key);
System.out.println(String.format("Found change - key: %s, oldValue: %s, newValue: %s, changeType: %s", change.getPropertyName(), change.getOldValue(), change.getNewValue(), change.getChangeType()));
}
}
});
String somePublicNamespace = "CAT";
Config config = ConfigService.getConfig(somePublicNamespace); //config instance is singleton for each namespace and is never null
String someKey = "someKeyFromPublicNamespace";
String someDefaultValue = "someDefaultValueForTheKey";
String value = config.getProperty(someKey, someDefaultValue);
apollo-client 1.3.0版本开始对yaml/yml做了更好的支持,使用起来和properties格式一致。
Config config = ConfigService.getConfig("application.yml");
String someKey = "someKeyFromYmlNamespace";
String someDefaultValue = "someDefaultValueForTheKey";
String value = config.getProperty(someKey, someDefaultValue);
获取时需要使用ConfigService.getConfigFile
接口并指定Format,如ConfigFileFormat.XML
。
String someNamespace = "test";
ConfigFile configFile = ConfigService.getConfigFile("test", ConfigFileFormat.XML);
String content = configFile.getContent();
指定对应的AppId和namespace来获取Config,再获取属性
String someAppId = "Animal";
String somePublicNamespace = "CAT";
Config config = ConfigService.getConfig(someAppId, somePublicNamespace);
String someKey = "someKeyFromPublicNamespace";
String someDefaultValue = "someDefaultValueForTheKey";
String value = config.getProperty(someKey, someDefaultValue);
Apollo也支持和Spring整合(Spring 3.1.1+),只需要做一些简单的配置就可以了。
Apollo目前既支持比较传统的基于XML
的配置,也支持目前比较流行的基于Java(推荐)
的配置。
如果是Spring Boot环境,建议参照3.2.1.3 Spring Boot集成方式(推荐)配置。
需要注意的是,如果之前有使用org.springframework.beans.factory.config.PropertyPlaceholderConfigurer
的,请替换成org.springframework.context.support.PropertySourcesPlaceholderConfigurer
。Spring 3.1以后就不建议使用PropertyPlaceholderConfigurer了,要改用PropertySourcesPlaceholderConfigurer。
如果之前有使用<context:property-placeholder>
,请注意xml中引入的spring-context.xsd
版本需要是3.1以上(一般只要没有指定版本会自动升级的),建议使用不带版本号的形式引入,如:http://www.springframework.org/schema/context/spring-context.xsd
注1:yaml/yml格式的namespace从1.3.0版本开始支持和Spring整合,注入时需要填写带后缀的完整名字,比如application.yml
注2:非properties、非yaml/yml格式(如xml,json等)的namespace暂不支持和Spring整合。
注:需要把apollo相关的xml namespace加到配置文件头上,不然会报xml语法错误。
1.注入默认namespace的配置到Spring中
<?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:apollo="http://www.ctrip.com/schema/apollo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.ctrip.com/schema/apollo http://www.ctrip.com/schema/apollo.xsd">
<!-- 这个是最简单的配置形式,一般应用用这种形式就可以了,用来指示Apollo注入application namespace的配置到Spring环境中 -->
<apollo:config/>
<bean class="com.ctrip.framework.apollo.spring.TestXmlBean">
<property name="timeout" value="${timeout:100}"/>
<property name="batch" value="${batch:200}"/>
</bean>
</beans>
2.注入多个namespace的配置到Spring中
<?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:apollo="http://www.ctrip.com/schema/apollo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.ctrip.com/schema/apollo http://www.ctrip.com/schema/apollo.xsd">
<!-- 这个是最简单的配置形式,一般应用用这种形式就可以了,用来指示Apollo注入application namespace的配置到Spring环境中 -->
<apollo:config/>
<!-- 这个是稍微复杂一些的配置形式,指示Apollo注入FX.apollo和application.yml namespace的配置到Spring环境中 -->
<apollo:config namespaces="FX.apollo,application.yml"/>
<bean class="com.ctrip.framework.apollo.spring.TestXmlBean">
<property name="timeout" value="${timeout:100}"/>
<property name="batch" value="${batch:200}"/>
</bean>
</beans>
3.注入多个namespace,并且指定顺序
Spring的配置是有顺序的,如果多个property source都有同一个key,那么最终是顺序在前的配置生效。
apollo:config如果不指定order,那么默认是最低优先级。
<?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:apollo="http://www.ctrip.com/schema/apollo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.ctrip.com/schema/apollo http://www.ctrip.com/schema/apollo.xsd">
<apollo:config order="2"/>
<!-- 这个是最复杂的配置形式,指示Apollo注入FX.apollo和application.yml namespace的配置到Spring环境中,并且顺序在application前面 -->
<apollo:config namespaces="FX.apollo,application.yml" order="1"/>
<bean class="com.ctrip.framework.apollo.spring.TestXmlBean">
<property name="timeout" value="${timeout:100}"/>
<property name="batch" value="${batch:200}"/>
</bean>
</beans>
相对于基于XML的配置,基于Java的配置是目前比较流行的方式。
注意@EnableApolloConfig
要和@Configuration
一起使用,不然不会生效。
1.注入默认namespace的配置到Spring中
//这个是最简单的配置形式,一般应用用这种形式就可以了,用来指示Apollo注入application namespace的配置到Spring环境中
@Configuration
@EnableApolloConfig
public class AppConfig {
@Bean
public TestJavaConfigBean javaConfigBean() {
return new TestJavaConfigBean();
}
}
2.注入多个namespace的配置到Spring中
@Configuration
@EnableApolloConfig
public class SomeAppConfig {
@Bean
public TestJavaConfigBean javaConfigBean() {
return new TestJavaConfigBean();
}
}
//这个是稍微复杂一些的配置形式,指示Apollo注入FX.apollo和application.yml namespace的配置到Spring环境中
@Configuration
@EnableApolloConfig({"FX.apollo", "application.yml"})
public class AnotherAppConfig {}
3.注入多个namespace,并且指定顺序
//这个是最复杂的配置形式,指示Apollo注入FX.apollo和application.yml namespace的配置到Spring环境中,并且顺序在application前面
@Configuration
@EnableApolloConfig(order = 2)
public class SomeAppConfig {
@Bean
public TestJavaConfigBean javaConfigBean() {
return new TestJavaConfigBean();
}
}
@Configuration
@EnableApolloConfig(value = {"FX.apollo", "application.yml"}, order = 1)
public class AnotherAppConfig {}
4.多appId的支持(新增于2.4.0版本)
// 新增支持了多appId和对应namespace的加载,注意使用多appId的情况下,key相同的情况,只会取优先加载appId的那一个key
@Configuration
@EnableApolloConfig(value = {"FX.apollo", "application.yml"},
multipleConfigs = {@MultipleConfig(appid = "ORDER_SERVICE", namespaces = {"ORDER.apollo"})}
)
public class SomeAppConfig {}
Spring Boot除了支持上述两种集成方式以外,还支持通过application.properties/bootstrap.properties来配置,该方式能使配置在更早的阶段注入,比如使用@ConditionalOnProperty
的场景或者是有一些spring-boot-starter在启动阶段就需要读取配置做一些事情(如dubbo-spring-boot-project),所以对于Spring Boot环境建议通过以下方式来接入Apollo(需要0.10.0及以上版本)。
使用方式很简单,只需要在application.properties/bootstrap.properties中按照如下样例配置即可。
注入默认application
namespace的配置示例
# will inject 'application' namespace in bootstrap phase
apollo.bootstrap.enabled = true
注入非默认application
namespace或多个namespace的配置示例
apollo.bootstrap.enabled = true
# will inject 'application', 'FX.apollo' and 'application.yml' namespaces in bootstrap phase
apollo.bootstrap.namespaces = application,FX.apollo,application.yml
将Apollo配置加载提到初始化日志系统之前(1.2.0+)
从1.2.0版本开始,如果希望把日志相关的配置(如logging.level.root=info
或logback-spring.xml
中的参数)也放在Apollo管理,那么可以额外配置apollo.bootstrap.eagerLoad.enabled=true
来使Apollo的加载顺序放到日志系统加载之前,更多信息可以参考PR 1614。参考配置示例如下:
# will inject 'application' namespace in bootstrap phase
apollo.bootstrap.enabled = true
# put apollo initialization before logging system initialization
apollo.bootstrap.eagerLoad.enabled=true
对于 Spring Boot 2.4 以上版本还支持通过 Config Data Loader 模式来加载配置
apollo-client-config-data 已经依赖了 apollo-client, 所以只需要添加这一个依赖即可, 无需再添加 apollo-client 的依赖
<dependencies>
<dependency>
<groupId>com.ctrip.framework.apollo</groupId>
<artifactId>apollo-client-config-data</artifactId>
<version>1.9.0</version>
</dependency>
</dependencies>
app.id
, env
, apollo.meta
(或者 apollo.config-service
), apollo.cluster
application.properties
或 application.yml
使用默认的 namespace application
# old way
# apollo.bootstrap.enabled=true
# 不配置 apollo.bootstrap.namespaces
# new way
spring.config.import=apollo://
或者
# old way
# apollo.bootstrap.enabled=true
# apollo.bootstrap.namespaces=application
# new way
spring.config.import=apollo://application
使用自定义 namespace
# old way
# apollo.bootstrap.enabled=true
# apollo.bootstrap.namespaces=your-namespace
# new way
spring.config.import=apollo://your-namespace
使用多个 namespaces
注: spring.config.import
是从后往前加载配置的, 而 apollo.bootstrap.namespaces
是从前往后加载的, 刚好相反。为了保证和原有逻辑一致, 请颠倒 namespaces 的顺序
# old way
# apollo.bootstrap.enabled=true
# apollo.bootstrap.namespaces=namespace1,namespace2,namespace3
# new way
spring.config.import=apollo://namespace3, apollo://namespace2, apollo://namespace1
对于 Spring Boot 2.4 以上版本还支持通过 Config Data Loader 模式来加载配置
Apollo 的 Config Data Loader 还提供了基于 webClient 的 http 客户端来替换原有的 http 客户端, 从而方便的对 http 客户端进行扩展
webClient 可以基于多种实现 (reactor netty httpclient, jetty reactive httpclient, apache httpclient5), 所需添加的依赖如下
<dependencies>
<dependency>
<groupId>com.ctrip.framework.apollo</groupId>
<artifactId>apollo-client-config-data</artifactId>
<version>1.9.0</version>
</dependency>
<!-- webclient -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webflux</artifactId>
</dependency>
<!-- reactor netty httpclient -->
<dependency>
<groupId>io.projectreactor.netty</groupId>
<artifactId>reactor-netty-http</artifactId>
</dependency>
</dependencies>
<dependencies>
<dependency>
<groupId>com.ctrip.framework.apollo</groupId>
<artifactId>apollo-client-config-data</artifactId>
<version>1.9.0</version>
</dependency>
<!-- webclient -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webflux</artifactId>
</dependency>
<!-- jetty reactive httpclient -->
<dependency>
<groupId>org.eclipse.jetty</groupId>
<artifactId>jetty-reactive-httpclient</artifactId>
</dependency>
</dependencies>
spring boot 没有指定 apache httpclient5 的版本, 所以这里需要手动指定一下版本
<dependencies>
<dependency>
<groupId>com.ctrip.framework.apollo</groupId>
<artifactId>apollo-client-config-data</artifactId>
<version>1.9.0</version>
</dependency>
<!-- webclient -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webflux</artifactId>
</dependency>
<!-- apache httpclient5 -->
<dependency>
<groupId>org.apache.httpcomponents.client5</groupId>
<artifactId>httpclient5</artifactId>
<version>5.1</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents.core5</groupId>
<artifactId>httpcore5-reactive</artifactId>
<version>5.1</version>
</dependency>
</dependencies>
app.id
, env
, apollo.meta
(或者 apollo.config-service
), apollo.cluster
application.properties
或 application.yml
这里以默认 namespace 为例, namespace 的配置详见 3.2.1.4.3
spring.config.import=apollo://application
apollo.client.extension.enabled=true
提供接口 com.ctrip.framework.apollo.config.data.extension.webclient.customizer.spi.ApolloClientWebClientCustomizerFactory
的 spi 实现
在配置了 apollo.client.extension.enabled=true
之后, Apollo 的 Config Data Loader 会尝试去加载该 spi 的实现类来定制 webClient
Spring应用通常会使用Placeholder来注入配置,使用的格式形如${someKey:someDefaultValue},如${timeout:100}。冒号前面的是key,冒号后面的是默认值。
建议在实际使用时尽量给出默认值,以免由于key没有定义导致运行时错误。
从v0.10.0开始的版本支持placeholder在运行时自动更新,具体参见PR #972。
如果需要关闭placeholder在运行时自动更新功能,可以通过以下两种方式关闭:
通过设置System Property apollo.autoUpdateInjectedSpringProperties
,如启动时传入-Dapollo.autoUpdateInjectedSpringProperties=false
通过设置META-INF/app.properties中的apollo.autoUpdateInjectedSpringProperties
属性,如
app.id=SampleApp
apollo.autoUpdateInjectedSpringProperties=false
假设我有一个TestXmlBean,它有两个配置项需要注入:
public class TestXmlBean {
private int timeout;
private int batch;
public void setTimeout(int timeout) {
this.timeout = timeout;
}
public void setBatch(int batch) {
this.batch = batch;
}
public int getTimeout() {
return timeout;
}
public int getBatch() {
return batch;
}
}
那么,我在XML中会使用如下方式来定义(假设应用默认的application namespace中有timeout和batch的配置项):
<?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:apollo="http://www.ctrip.com/schema/apollo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.ctrip.com/schema/apollo http://www.ctrip.com/schema/apollo.xsd">
<apollo:config/>
<bean class="com.ctrip.framework.apollo.spring.TestXmlBean">
<property name="timeout" value="${timeout:100}"/>
<property name="batch" value="${batch:200}"/>
</bean>
</beans>
假设我有一个TestJavaConfigBean,通过Java Config的方式还可以使用@Value的方式注入:
public class TestJavaConfigBean {
@Value("${timeout:100}")
private int timeout;
private int batch;
@Value("${batch:200}")
public void setBatch(int batch) {
this.batch = batch;
}
public int getTimeout() {
return timeout;
}
public int getBatch() {
return batch;
}
}
在Configuration类中按照下面的方式使用(假设应用默认的application namespace中有timeout
和batch
的配置项):
@Configuration
@EnableApolloConfig
public class AppConfig {
@Bean
public TestJavaConfigBean javaConfigBean() {
return new TestJavaConfigBean();
}
}
Spring Boot提供了@ConfigurationProperties把配置注入到bean对象中。
Apollo也支持这种方式,下面的例子会把redis.cache.expireSeconds
和redis.cache.commandTimeout
分别注入到SampleRedisConfig的expireSeconds
和commandTimeout
字段中。
@ConfigurationProperties(prefix = "redis.cache")
public class SampleRedisConfig {
private int expireSeconds;
private int commandTimeout;
public void setExpireSeconds(int expireSeconds) {
this.expireSeconds = expireSeconds;
}
public void setCommandTimeout(int commandTimeout) {
this.commandTimeout = commandTimeout;
}
}
在Configuration类中按照下面的方式使用(假设应用默认的application namespace中有redis.cache.expireSeconds
和redis.cache.commandTimeout
的配置项):
@Configuration
@EnableApolloConfig
public class AppConfig {
@Bean
public SampleRedisConfig sampleRedisConfig() {
return new SampleRedisConfig();
}
}
需要注意的是,@ConfigurationProperties
如果需要在Apollo配置变化时自动更新注入的值,需要配合使用EnvironmentChangeEvent或RefreshScope。相关代码实现,可以参考apollo-use-cases项目中的ZuulPropertiesRefresher.java和apollo-demo项目中的SampleRedisConfig.java以及SpringBootApolloRefreshConfig.java
Apollo同时还增加了几个新的Annotation来简化在Spring环境中的使用。
使用样例如下:
public class TestApolloAnnotationBean {
@ApolloConfig
private Config config; //inject config for namespace application
@ApolloConfig("application")
private Config anotherConfig; //inject config for namespace application
@ApolloConfig("FX.apollo")
private Config yetAnotherConfig; //inject config for namespace FX.apollo
@ApolloConfig("application.yml")
private Config ymlConfig; //inject config for namespace application.yml
/**
* ApolloJsonValue annotated on fields example, the default value is specified as empty list - []
* <br />
* jsonBeanProperty=[{"someString":"hello","someInt":100},{"someString":"world!","someInt":200}]
*/
@ApolloJsonValue("${jsonBeanProperty:[]}")
private List<JsonBean> anotherJsonBeans;
@Value("${batch:100}")
private int batch;
//config change listener for namespace application
@ApolloConfigChangeListener
private void someOnChange(ConfigChangeEvent changeEvent) {
//update injected value of batch if it is changed in Apollo
if (changeEvent.isChanged("batch")) {
batch = config.getIntProperty("batch", 100);
}
}
//config change listener for namespace application
@ApolloConfigChangeListener("application")
private void anotherOnChange(ConfigChangeEvent changeEvent) {
//do something
}
//config change listener for namespaces application, FX.apollo and application.yml
@ApolloConfigChangeListener({"application", "FX.apollo", "application.yml"})
private void yetAnotherOnChange(ConfigChangeEvent changeEvent) {
//do something
}
//example of getting config from Apollo directly
//this will always return the latest value of timeout
public int getTimeout() {
return config.getIntProperty("timeout", 200);
}
//example of getting config from injected value
//the program needs to update the injected value when batch is changed in Apollo using @ApolloConfigChangeListener shown above
public int getBatch() {
return this.batch;
}
private static class JsonBean{
private String someString;
private int someInt;
}
}
在Configuration类中按照下面的方式使用:
@Configuration
@EnableApolloConfig
public class AppConfig {
@Bean
public TestApolloAnnotationBean testApolloAnnotationBean() {
return new TestApolloAnnotationBean();
}
}
很多情况下,应用可能已经有不少配置了,比如Spring Boot的应用,就会有bootstrap.properties/yml, application.properties/yml等配置。
在应用接入Apollo之后,这些配置是可以非常方便的迁移到Apollo的,具体步骤如下:
server.port
必须确保本地文件已经删除该配置项如:
spring.application.name = reservation-service
server.port = 8080
logging.level = ERROR
eureka.client.service-url.defaultZone = http://127.0.0.1:8761/eureka/
eureka.client.healthcheck.enabled = true
eureka.client.register-with-eureka = true
eureka.client.fetch-registry = true
eureka.client.eureka-service-url-poll-interval-seconds = 60
eureka.instance.prefer-ip-address = true
项目中有一个样例客户端的项目:apollo-demo
,具体信息可以参考Apollo开发指南中的2.3 Java样例客户端启动部分。
更多使用案例Demo可以参考Apollo使用场景和示例代码。
上图简要描述了Apollo客户端的实现原理:
apollo.refreshInterval
来覆盖,单位为分钟。Apollo客户端还支持本地开发模式,这个主要用于当开发环境无法连接Apollo服务器的时候,比如在邮轮、飞机上做相关功能开发。
在本地开发模式下,Apollo只会从本地文件读取配置信息,不会从Apollo服务器读取配置。
可以通过下面的步骤开启Apollo本地开发模式。
修改/opt/settings/server.properties(Mac/Linux)或C:\opt\settings\server.properties(Windows)文件,设置env为Local:
env=Local
更多配置环境的方式请参考1.2.4.1 Environment
在本地开发模式下,Apollo客户端会从本地读取文件,所以我们需要事先准备好配置文件。
本地配置目录位于:
appId就是应用的appId,如100004458。
请确保该目录存在,且应用程序对该目录有读权限。
【小技巧】 推荐的方式是先在普通模式下使用Apollo,这样Apollo会自动创建该目录并在目录下生成配置文件。
本地配置文件需要按照一定的文件名格式放置于本地配置目录下,文件名格式如下:
{appId}+{cluster}+{namespace}.properties
文件内容以properties格式存储,比如如果有两个key,一个是request.timeout,另一个是batch,那么文件内容就是如下格式:
request.timeout=2000
batch=2000
在本地开发模式下,Apollo不会实时监测文件内容是否有变化,所以如果修改了配置,需要重启应用生效。
1.1.0版本开始增加了apollo-mockserver
,从而可以很好地支持单元测试时需要mock配置的场景,使用方法如下:
<dependency>
<groupId>com.ctrip.framework.apollo</groupId>
<artifactId>apollo-mockserver</artifactId>
<version>1.7.0</version>
</dependency>
文件名格式约定为mockdata-{namespace}.properties
更多使用demo可以参考ApolloMockServerApiTest.java和ApolloMockServerSpringIntegrationTest.java。
@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes = TestConfiguration.class)
public class SpringIntegrationTest {
// 启动apollo的mockserver
@ClassRule
public static EmbeddedApollo embeddedApollo = new EmbeddedApollo();
@Test
@DirtiesContext // 这个注解很有必要,因为配置注入会弄脏应用上下文
public void testPropertyInject(){
assertEquals("value1", testBean.key1);
assertEquals("value2", testBean.key2);
}
@Test
@DirtiesContext
public void testListenerTriggeredByAdd() throws InterruptedException, ExecutionException, TimeoutException {
String otherNamespace = "othernamespace";
embeddedApollo.addOrModifyPropery(otherNamespace,"someKey","someValue");
ConfigChangeEvent changeEvent = testBean.futureData.get(5000, TimeUnit.MILLISECONDS);
assertEquals(otherNamespace, changeEvent.getNamespace());
assertEquals("someValue", changeEvent.getChange("someKey").getNewValue());
}
@EnableApolloConfig("application")
@Configuration
static class TestConfiguration{
@Bean
public TestBean testBean(){
return new TestBean();
}
}
static class TestBean{
@Value("${key1:default}")
String key1;
@Value("${key2:default}")
String key2;
SettableFuture<ConfigChangeEvent> futureData = SettableFuture.create();
@ApolloConfigChangeListener("othernamespace")
private void onChange(ConfigChangeEvent changeEvent) {
futureData.set(changeEvent);
}
}
}
from version 2.1.0
为了满足用户使用apollo-client时,对ConfigService负载均衡算法的不同需求,
我们在2.1.0版本中提供了spi。
interface是com.ctrip.framework.apollo.spi.ConfigServiceLoadBalancerClient
。
输入是meta server返回的多个ConfigService,输出是1个ConfigService。
默认服务提供是com.ctrip.framework.apollo.spi.RandomConfigServiceLoadBalancerClient
,使用random策略,也就是随机从多个ConfigService中选择1个ConfigService。