小编给大家分享一下SpringBoot整合Apollo配置中心怎么用,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!
1.Apollo 是什么?Apollo(阿波罗)是携程框架部门研发的分布式配置中心。服务端基于Spring Boot和Spring Cloud开发。
2.为什么要使用Apollo?
安全性:配置跟随源代码保存在代码库中,容易造成配置泄漏
时效性:普通方式配置,修改配置,需要重启服务才能生效
局限性:无法支持动态调整:例如日志开关、功能开关
注:本文主要介绍SpringBoot 整合 Apollo 实现动态配置
1.1 添加Maven依赖
<dependency> <groupId>com.ctrip.framework.apollo</groupId> <artifactId>apollo-client</artifactId> <version>1.3.0</version> </dependency>
1.2 配置文件
# apollo集成 # apollo 配置应用的 appid app.id=springboot-apollo-demo1 # apollo meta-server地址,一般同config-server地址 apollo.meta=http://192.168.0.153:8080 #启用apollo配置开关 apollo.bootstrap.enabled=true apollo.bootstrap.eagerLoad.enabled=true # apollo 使用配置的命名空间,多个以逗号分隔 apollo.bootstrap.namespaces = application
配置说明:
app.id:在配置中心配置的应用身份信息。
apollo.bootstrap.enabled:在应用启动阶段是否向Spring容器注入被托管的properties文件配置信息。
apollo.bootstrap.eagerLoad.enabled:将Apollo配置加载提到初始化日志系统之前。
apollo.bootstrap.namespaces:配置的命名空间,多个逗号分隔,一个namespace相当于一个配置文件。
**apollo.meta:**当前环境服务配置地址,生产环境建议至少双节点,可以填写多个逗号分隔,使用一个单独的域,如 http://config.xxx.com(由nginx等软件负载平衡器支持),而不是多个IP地址,因为服务器可能会扩展或缩小。
图示说明:
1.3 添加启动类
@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class, DataSourceTransactionManagerAutoConfiguration.class}) public class SpringbootApolloApplication { public static void main(String[] args) { SpringApplication.run(SpringbootApolloApplication.class, args); } }
1.4 添加配置开关类
基于@Value注解配置
@Component public class ValueStyleProperty { @Value("${apollo.value.demoKey1}") private String demoKey1; @Value("${apollo.value.demoKey2}") private String demoKey2; //省略 get/set 方法 }
1.5 添加测试controller
/** * value注解方式,获取属性 * * @author mengqiang */ @RestController @RequestMapping("/value-style") public class ValuePropertyController { @Autowired private ValueStyleProperty keyProperty; @Value("${server.port}") private String port; @Value("${apollo.bootstrap.namespaces:'application'}") private String namespaces; @GetMapping("/get") public Map<String, Object> getProperty() { Map<String, Object> map = new LinkedHashMap<>(); map.put("port", port); map.put("namespaces", namespaces); map.put("demoKey1", keyProperty.getDemoKey1()); map.put("demoKey2", keyProperty.getDemoKey2()); return map; } }
2.1 创建项目
2.2 填写配置信息
配置说明:
部门:选择应用所在的部门。(可自定义部门)
应用AppId:用来标识应用身份的唯一id,格式为string,需与application.properties中配置的app.id一致。
应用名称:应用名,仅用于界面展示。
应用负责人:选择的人默认会成为该项目的管理员,具备项目权限管理、集群创建、Namespace创建等权限。
项目配置主页截图
2.3 添加配置
2.3.1 表格形式单个添加
注:不能批量操作
2.3.2 文本形式批量添加
注:可实现批量操作
2.4 发布配置
注:配置只有发布后才会生效
点击发布按钮
2.5 多环境同步配置
注意事项:
通过同步配置功能,可以使多个环境、集群间的配置保持一致需要注意的是,同步完之后需要发布后才会对应用生效
点击同步配置
选择需要同步的配置,以及目标环境
点击同步
目标环境查看
3.1 初始启动读取测试
3.2 自动更新属性测试
发布后控制台变化
测试输出值变化
4.1@ConfigurationProperties注解整合Apollo不生效问题
示例配置类
/** * 公共开关,key值 属性配置 * * @author mengqiang */ @Component @ConfigurationProperties(prefix = "apollo.first.config") public class ConfigFirstProperty { /** * 测试数字 */ private Integer oneNumber; /** * 测试字符串 */ private String oneStr; /** * 启用标记 */ private Boolean oneEnableFlag; /** * 税率 默认 0.03 */ private BigDecimal oneTaxRate = new BigDecimal("0.03"); //省略 get/set 方法 }
解决方案
添加监听配置
import com.ctrip.framework.apollo.model.ConfigChange; import com.ctrip.framework.apollo.model.ConfigChangeEvent; import com.ctrip.framework.apollo.spring.annotation.ApolloConfigChangeListener; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.BeansException; import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContextAware; import org.springframework.stereotype.Component; import org.springframework.cloud.context.environment.EnvironmentChangeEvent; /** * Apollo 配置监听 */ @Configuration public class ApolloConfigListener implements ApplicationContextAware { /** * 日志 */ private static final Logger LOGGER = LoggerFactory.getLogger(ApolloConfigListener.class); private ApplicationContext applicationContext; /** * 配置监听 * ApolloConfigChangeListener > value 属性默认 命名空间 "application" * * 示例: @ApolloConfigChangeListener(value = {"application", "test_space"}) */ @ApolloConfigChangeListener private void onChange(ConfigChangeEvent changeEvent) { LOGGER.info("【Apollo-config-change】start"); for (String key : changeEvent.changedKeys()) { ConfigChange change = changeEvent.getChange(key); LOGGER.info("key={} , propertyName={} , oldValue={} , newValue={} ", key, change.getPropertyName(), change.getOldValue(), change.getNewValue()); } // 更新相应的bean的属性值,主要是存在@ConfigurationProperties注解的bean this.applicationContext.publishEvent(new EnvironmentChangeEvent(changeEvent.changedKeys())); LOGGER.info("【Apollo-config-change】end"); } @Override public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { this.applicationContext = applicationContext; } }
4.2日志级别未更新问题
示例配置
logging.level.com.example=info
解决方案-日志监听器
import com.ctrip.framework.apollo.model.ConfigChange; import com.ctrip.framework.apollo.model.ConfigChangeEvent; import com.ctrip.framework.apollo.spring.annotation.ApolloConfigChangeListener; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.boot.logging.LogLevel; import org.springframework.boot.logging.LoggingSystem; import org.springframework.context.annotation.Configuration; import javax.annotation.Resource; /** * Apollo 日志-配置监听 */ @Configuration public class LoggerConfigListener { private static final Logger LOGGER = LoggerFactory.getLogger(LoggerConfigListener.class); private static final String LOGGER_TAG = "logging.level."; @Resource private LoggingSystem loggingSystem; /** * 监听 日志配置的变化 */ @ApolloConfigChangeListener(interestedKeyPrefixes = LOGGER_TAG) private void onChangeLogger(ConfigChangeEvent changeEvent) { LOGGER.info("【Apollo-logger-config-change】>> start"); refreshLoggingLevel(changeEvent); LOGGER.info("【Apollo-logger-config-change】>> end"); } /** * 刷新日志级别 */ private void refreshLoggingLevel(ConfigChangeEvent changeEvent) { if (null == loggingSystem) { return; } for (String key : changeEvent.changedKeys()) { ConfigChange change = changeEvent.getChange(key); if (!StringUtils.containsIgnoreCase(key, LOGGER_TAG)) { continue; } LOGGER.info("【Apollo-logger-config-change】>> key={} , propertyName={} , oldValue={} , newValue={} ", key, change.getPropertyName(), change.getOldValue(), change.getNewValue()); String newLevel = change.getNewValue(); LogLevel level = LogLevel.valueOf(newLevel.toUpperCase()); loggingSystem.setLogLevel(key.replace(LOGGER_TAG, ""), level); LOGGER.info("【Apollo-logger-config-change】>> {} -> {}", key, newLevel); } } }
4.3日志+配置类自动刷新整合监听
注:由于 4.1与4.2监听有重合,所以最好放在一起处理
import com.ctrip.framework.apollo.model.ConfigChange; import com.ctrip.framework.apollo.model.ConfigChangeEvent; import com.ctrip.framework.apollo.spring.annotation.ApolloConfigChangeListener; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.BeansException; import org.springframework.boot.logging.LogLevel; import org.springframework.boot.logging.LoggingSystem; import org.springframework.cloud.context.environment.EnvironmentChangeEvent; import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContextAware; import org.springframework.context.annotation.Configuration; import javax.annotation.Resource; /** * Apollo 配置监听 */ @Configuration public class ApolloConfigListener implements ApplicationContextAware { /** * 日志 */ private static final Logger LOGGER = LoggerFactory.getLogger(ApolloConfigListener.class); /** * 日志配置常量 */ private static final String LOGGER_TAG = "logging.level."; @Resource private LoggingSystem loggingSystem; private ApplicationContext applicationContext; @Override public void setApplicationContext(ApplicationContext applicationContext) throws BeansException { this.applicationContext = applicationContext; } /** * 配置监听 * ApolloConfigChangeListener > value 属性默认 命名空间 "application" */ @ApolloConfigChangeListener private void onChangeConfig(ConfigChangeEvent changeEvent) { LOGGER.info("【Apollo-config-change】>> start"); for (String key : changeEvent.changedKeys()) { ConfigChange change = changeEvent.getChange(key); LOGGER.info("【Apollo-config-change】>> key={} , propertyName={} , oldValue={} , newValue={} ", key, change.getPropertyName(), change.getOldValue(), change.getNewValue()); //是否为日志配置 if (StringUtils.containsIgnoreCase(key, LOGGER_TAG)) { //日志配置刷新 changeLoggingLevel(key, change); continue; } // 更新相应的bean的属性值,主要是存在@ConfigurationProperties注解的bean this.applicationContext.publishEvent(new EnvironmentChangeEvent(changeEvent.changedKeys())); } LOGGER.info("【Apollo-config-change】>> end"); } /** * 刷新日志级别 */ private void changeLoggingLevel(String key, ConfigChange change) { if (null == loggingSystem) { return; } String newLevel = change.getNewValue(); LogLevel level = LogLevel.valueOf(newLevel.toUpperCase()); loggingSystem.setLogLevel(key.replace(LOGGER_TAG, ""), level); LOGGER.info("【Apollo-logger-config-change】>> {} -> {}", key, newLevel); } }
4.4 其它问题
4.4.1配置文件与配置中心同时存在配置,启用的是那一份
apollo 配置开关开启情况下,配置中心配置会覆盖本地配置
注:配置开关 apollo.bootstrap.enabled=true
4.4.2 配置中心挂掉会影响已发布的项目吗?
项目启动后配置会存在缓存中,配置中心挂掉,已发布的项目不影响
4.4.3 是否支持更新端口配置
支持更新端口配置,但是必需要重启生效,同时也需要考虑服务器的端口占用问题。
以上是“SpringBoot整合Apollo配置中心怎么用”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注亿速云行业资讯频道!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。