SpringFramework应用接入Apollo配置中心过程解析_F11 - 专业站长和开发者的学习网站

分享到

SpringFramework应用接入Apollo配置中心过程解析

java 来源：互联网搜集作者：秩名发布时间：2020-03-25 20:19:05 人浏览

摘要

环境： SpringFramework：4.3.5.RELEASE apollo-client：1.5.1 1.在项目的 resources/META-INF/ 目录下添加 app.properties 文件： #Apollo配置id app.id = phpdragon-demo apollo.bootstrap.enabled = true apollo.eagerLoad.enabled = true apollo.cacheDi

环境：

SpringFramework：4.3.5.RELEASE

apollo-client：1.5.1

1.在项目的 resources/META-INF/ 目录下添加 app.properties 文件：

#Apollo配置id
app.id = phpdragon-demo
apollo.bootstrap.enabled = true
apollo.eagerLoad.enabled = true
apollo.cacheDir = /data/app_data/apollo_cache/

2. 新建 ApolloConfigurer 类，负责处理合并本地properties配置：

				?

									import com.alibaba.dubbo.common.utils.ConfigUtils;

									import com.ctrip.framework.apollo.Config;

									import com.ctrip.framework.apollo.ConfigService;

									import org.springframework.beans.BeansException;

									import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;

									import org.springframework.beans.factory.config.PropertyPlaceholderConfigurer;

									import java.util.Properties;

									import java.util.Set;

									/**

									 * 处理apollo配置

									 */

									public class ApolloConfigurer extends PropertyPlaceholderConfigurer {

									  static final String[] NAMESPACES = {"PUBLIC", "REDIS", "ZOOKEEPER", "application"};

									  @Override

									  protected void processProperties(ConfigurableListableBeanFactory beanFactoryToProcess, Properties props) throws BeansException {

									    try {

									      this.reloadProperties(props);

									    } catch (Exception e) {

									      e.printStackTrace();

									      logger.info("获取apollo配置失败");

									    }

									    //设置到dubbo的上下里

									    ConfigUtils.addProperties(props);

									    super.processProperties(beanFactoryToProcess, props);

									  }

									  private void reloadProperties(Properties props) {

									    for (String namespace : NAMESPACES) {

									      Config config = ConfigService.getConfig(namespace);

									      Set<String> fieldNames = config.getPropertyNames();

									      for (String attributeName : fieldNames) {

									        props.put(attributeName, config.getProperty(attributeName, ""));

									        //设置到系统变量里

									        System.setProperty(attributeName, config.getProperty(attributeName, ""));

									      }

									    }

									  }

									  @Override

									  protected String resolvePlaceholder(String placeholder, Properties props) {

									    this.reloadProperties(props);

									    return props.getProperty(placeholder);

									  }

									}

import com.alibaba.dubbo.common.utils.ConfigUtils;
import com.ctrip.framework.apollo.Config;
import com.ctrip.framework.apollo.ConfigService;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.ConfigurableListableBeanFactory;
import org.springframework.beans.factory.config.PropertyPlaceholderConfigurer;

import java.util.Properties;
import java.util.Set;

/**
 * 处理apollo配置
 */
public class ApolloConfigurer extends PropertyPlaceholderConfigurer {

static final String[] NAMESPACES = {"PUBLIC", "REDIS", "ZOOKEEPER", "application"};
  
  @Override
  protected void processProperties(ConfigurableListableBeanFactory beanFactoryToProcess, Properties props) throws BeansException {
    try {
      this.reloadProperties(props);
    } catch (Exception e) {
      e.printStackTrace();
      logger.info("获取apollo配置失败");
    }

//设置到dubbo的上下里
    ConfigUtils.addProperties(props);

super.processProperties(beanFactoryToProcess, props);
  }

private void reloadProperties(Properties props) {
    for (String namespace : NAMESPACES) {
      Config config = ConfigService.getConfig(namespace);
      Set<String> fieldNames = config.getPropertyNames();
      for (String attributeName : fieldNames) {
        props.put(attributeName, config.getProperty(attributeName, ""));
        //设置到系统变量里
        System.setProperty(attributeName, config.getProperty(attributeName, ""));
      }
    }
  }
  @Override
  protected String resolvePlaceholder(String placeholder, Properties props) {
    this.reloadProperties(props);
    return props.getProperty(placeholder);
  }
}

3.在 Spring 的配置xml文件中声明配置：

				?

									<bean class="com.phpdragon.config.ApolloConfigurer">

									  <property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_OVERRIDE"/>

									  <property name="ignoreResourceNotFound" value="true"/>

									  <property name="trimValues" value="true"/>

									  <property name="locations">

									    <list>

									      <value>classpath*:*.properties</value>

									      <value>classpath*:properties/*.properties</value>

									    </list>

									  </property>

									  <property name="fileEncoding" value="UTF-8"/>

									</bean>

4.编写配置类接收远程配置变量：

			?

								import org.springframework.beans.factory.annotation.Autowired;

								import org.springframework.beans.factory.annotation.Value;

								import org.springframework.context.annotation.Bean;

								import org.springframework.context.annotation.Configuration;

								import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;

								import org.springframework.data.redis.core.StringRedisTemplate;

								import org.springframework.data.redis.serializer.StringRedisSerializer;

								import redis.clients.jedis.JedisPoolConfig;

								import lombok.Data;

								/**

								 *

								 */

								@Data

								@Configuration

								//@EnableApolloConfig不能使用该注解，否则会导致无效，该注解由 ApolloConfigurer 接管类似功能

								public class RedisConfig {

								  @Value("${sys.redis.host}")

								  private String hostName;

								  @Value("${sys.redis.port}")

								  private int port;

								  @Value("${redis.password}")

								  private String password;

								  @Value("${redis.timeout}")

								  private int timeout;

								  @Value("${redis.pool.maxTotal}")

								  private int maxTotal;

								  @Value("${redis.pool.minIdle}")

								  private int minIdle;

								  @Value("${redis.pool.maxIdle}")

								  private int maxIdle;

								  @Value("${redis.pool.maxWaitMillis}")

								  private long maxWaitMillis;

								  @Value("${redis.pool.testOnBorrow}")

								  private boolean testOnBorrow;

								  @Value("${redis.pool.testOnReturn}")

								  private boolean testOnReturn;

								}

您可能感兴趣的文章 :

集成apollo动态日志取缔logback-spring.xml配置

原文链接 : https://www.cnblogs.com/phpdragon/p/12562429.html

Tag :

SpringBoot自定义错误处理逻辑介绍

1. 自定义错误页面将自定义错误页面放在 templates 的 error 文件夹下，SpringBoot 精确匹配错误信息，使用 4xx.html 或者 5xx.html 页面可以打印错误
Java实现手写一个线程池的代码

线程池技术想必大家都不陌生把，相信在平时的工作中没有少用，而且这也是面试频率非常高的一个知识点，那么大家知道它的实现原理和
Java实现断点续传功能的代码

题目实现：网络资源的断点续传功能。二、解题思路获取要下载的资源网址显示网络资源的大小上次读取到的字节位置以及未读取的字节
你可知HashMap为什么是线程不安全的

HashMap 的线程不安全 HashMap 的线程不安全主要体现在下面两个方面在 jdk 1.7 中，当并发执行扩容操作时会造成环形链和数据丢失的情况在
ArrayList的动态扩容机制的介绍

对于 ArrayList 的动态扩容机制想必大家都听说过，之前的文章中也谈到过，不过由于时间久远，早已忘却。所以利用这篇文章做做笔记，加
JVM基础之字节码的增强技术介绍

字节码增强技术在上文中，着重介绍了字节码的结构，这为我们了解字节码增强技术的实现打下了基础。字节码增强技术就是一类对现有字
Java中的字节码增强技术

1.字节码增强技术字节码增强技术就是一类对现有字节码进行修改或者动态生成全新字节码文件的技术。参考地址 2.常见技术技术分类类
Redis BloomFilter布隆过滤器原理与实现

Bloom Filter 概念布隆过滤器（英语：Bloom Filter）是1970年由一个叫布隆的小伙子提出的。它实际上是一个很长的二进制向量和一系列随机映射
Java C++算法题解leetcode801使序列递增的最小交换次

题目要求思路：状态机DP 实现一：状态机 Java 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 class Solution { public int minSwap(int[] nums1, int[] nums2) { int n
Mybatis结果集映射与生命周期介绍

一、ResultMap结果集映射 1、设计思想对简单的语句做到零配置，对于复杂一点的语句，只需要描述语句之间的关系就行了 2、resultMap的应用场