Подтвердить что ты не робот

Spring Клиент Cloud Config без Spring Загрузка

У нас есть существующее веб-приложение spring, развернутое как WAR файл на Amazon Elastic Beanstalk. В настоящее время мы загружаем файлы свойств в виде http-ресурсов, чтобы предоставить нам один источник конфигурации конфигуратора заполнителя. Im, исследуя замену этого на новый сервер конфигурации облаков spring, чтобы дать нам преимущества управления версиями git и т.д.

Однако документация (http://cloud.spring.io/spring-cloud-config/spring-cloud-config.html), похоже, описывает приложение spring Boot client. Возможно ли настроить spring Cloud Config Client в существующем веб-приложении? Нужно ли вручную настраивать исходный контекст приложения Bootstrap и т.д. - есть ли примеры этого? Наша текущая конфигурация spring основана на XML.

4b9b3361

Ответ 1

Все, что "просто работает" с Spring Boot, на самом деле не более чем какая-то конфигурация. Это всего лишь приложение Spring в конце дня. Поэтому я считаю, что вы, вероятно, можете настроить все вручную, что Boot делает для вас автоматически, но я не знаю, кто на самом деле пытается этот конкретный угол. Создание контекста приложения bootstrap, безусловно, является предпочтительным подходом, но в зависимости от вашего варианта использования вы можете заставить его работать с одним контекстом, если вы убедитесь, что локаторы источника свойств выполнены достаточно рано.

Не Spring (или не Spring Boot) приложения могут получать доступ к текстовым или двоичным файлам на сервере конфигурации. Например. в Spring вы можете использовать @PropertySource с расположением ресурсов, которое было URL-адресом, например http://configserver/{app}/{profile}/{label}/application.properties или http://configserver/{app}-{profile}.properties. Все это описано в руководстве пользователя.

Ответ 2

У меня есть аналогичное требование; У меня есть веб-приложение, которое использует конфигурацию Spring XML для определения некоторого beans, значение свойств хранится в файлах .property. Требование состоит в том, что конфигурация должна быть загружена с жесткого диска во время разработки и с сервера Spring Cloud Config в рабочей среде.

Моя идея состоит в том, чтобы иметь два определения для PropertyPlaceholderConfigurer; первый будет использоваться для загрузки конфигурации с жесткого диска:

        <bean id="resources" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer" doc:name="Bean">
        <property name="locations">
            <list>
                <value>dcm.properties</value>
                <value>post_process.properties</value>
            </list>
        </property>
    </bean>

Второй загрузит .properties из Spring Config Server:

    <bean id="resources" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer" doc:name="Bean">
        <property name="locations">
            <list>
                <value>http://localhost:8888/trunk/dcm-qa.properties</value>
            </list>
        </property>
    </bean>

Ответ 3

Проводка в качестве ответа, потому что у меня недостаточно очков, чтобы прокомментировать Dave Syer отличный ответ. Мы внедрили его предлагаемое решение в производство, и оно работает, как ожидалось. Наши новые приложения записываются с использованием Boot, в то время как наши устаревшие приложения используют Spring, но не загружаются. Мы смогли использовать Spring Cloud Config для создания службы свойств, которая обслуживает свойства для обоих. Изменения были минимальными. Я переместил устаревшие файлы свойств из файла войны в репозиторий службы свойств git и изменил определение свойства из ссылки на путь к URL-адресу, поскольку Дэйв описывает и вставляет нашу переменную системной среды так же, как мы это делали для classpath. Это было легко и эффективно.

<util:properties id="envProperties" location="https://properties.me.com/property-service/services-#{envName}.properties" />
<context:property-placeholder properties-ref="envProperties" ignore-resource-not-found="true" ignore-unresolvable="true" order="0" />
<util:properties id="defaultProperties" location="https://properties.me.com/property-service/services-default.properties" />
<context:property-placeholder properties-ref="defaultProperties" ignore-resource-not-found="true" ignore-unresolvable="true" order="10" />

Ответ 4

Я нашел решение для использования spring -cloud-zookeeper без Spring Boot, основываясь на приведенной здесь идее https://wenku.baidu.com/view/493cf9eba300a6c30d229f49.html

Он должен быть легко обновлен в соответствии с вашими потребностями и с использованием сервера облачных вычислений Spring (класс CloudEnvironement должен быть обновлен для загрузки файла с сервера вместо Zookeeper)

Сначала создайте класс CloudEnvironement, который создаст PropertySource (из Zookeeper):

CloudEnvironement.java

  public class CloudEnvironment extends StandardServletEnvironment { 

  @Override 
  protected void customizePropertySources(MutablePropertySources propertySources) { 
    super.customizePropertySources(propertySources); 
    try { 
      propertySources.addLast(initConfigServicePropertySourceLocator(this)); 
    } 
    catch (Exception ex) { 
      logger.warn("failed to initialize cloud config environment", ex); 
    } 
  } 

  private PropertySource<?> initConfigServicePropertySourceLocator(Environment environment) { 
    ZookeeperConfigProperties configProp = new ZookeeperConfigProperties(); 
    ZookeeperProperties props = new ZookeeperProperties(); 
    props.setConnectString("myzookeeper:2181"); 
    CuratorFramework fwk = curatorFramework(exponentialBackoffRetry(props), props); 
    ZookeeperPropertySourceLocator propertySourceLocator = new ZookeeperPropertySourceLocator(fwk, configProp); 
    PropertySource<?> source= propertySourceLocator.locate(environment); 
    return source ; 
  } 

  private CuratorFramework curatorFramework(RetryPolicy retryPolicy, ZookeeperProperties properties) { 
    CuratorFrameworkFactory.Builder builder = CuratorFrameworkFactory.builder(); 
    builder.connectString(properties.getConnectString()); 
    CuratorFramework curator = builder.retryPolicy(retryPolicy).build(); 
    curator.start(); 
    try { 
      curator.blockUntilConnected(properties.getBlockUntilConnectedWait(), properties.getBlockUntilConnectedUnit()); 
    } 
    catch (InterruptedException e) { 
      throw new RuntimeException(e); 
    } 
    return curator; 
  } 

  private RetryPolicy exponentialBackoffRetry(ZookeeperProperties properties) { 
    return new ExponentialBackoffRetry(properties.getBaseSleepTimeMs(), 
        properties.getMaxRetries(), 
        properties.getMaxSleepMs()); 
  } 

}

Затем создайте собственный класс XmlWebApplicationContext: он позволит загрузить PropertySource из Zookeeper, когда начнется ваше веб-приложение и заменит макет начальной загрузки Spring Boot:

MyConfigurableWebApplicationContext.java

public class MyConfigurableWebApplicationContext extends XmlWebApplicationContext { 

  @Override 
  protected ConfigurableEnvironment createEnvironment() { 
    return new CloudEnvironment(); 
  } 
}

Наконец, в вашем файле web.xml добавьте следующий контекстный параметр для использования вашего класса MyConfigurableWebApplicationContext и бутстринг вашего CloudEnvironement.

<context-param>           
      <param-name>contextClass</param-name> 
      <param-value>com.kiabi.config.MyConfigurableWebApplicationContext</param-value> 
    </context-param> 

Если вы используете стандартный конфигуратор файла свойств, он все равно должен быть загружен, чтобы вы могли иметь свойства как в локальном файле, так и в Zookeeper.

Для этого вам нужно иметь spring -cloud-starter-zookeeper-config и куратор-фреймворк в вашем пути к классам с их зависимостью, если вы используете maven, вы можете добавить следующее к своему pom.xml

<dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-zookeeper-dependencies</artifactId>
                <version>1.1.1.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <dependencies>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zookeeper-config</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
        </dependency>
    </dependencies>

Ответ 5

Подтверждено: https://wenku.baidu.com/view/493cf9eba300a6c30d229f49.html

Root WebApplicationContext и Servlet WebApplicationContext использует среду и инициализирует PropertySources на основе профиля spring. Для загрузочных приложений без spring нам нужно настроить их, чтобы получить свойства из Config Server и обновить beans всякий раз, когда есть изменение свойства. Ниже приведены изменения, которые были сделаны для настройки конфигурации в SpringMVC. Вам также понадобится системное свойство для spring.profile.active

  • Создайте CustomBeanFactoryPostProcessor и установите lazyInit для всех определений bean в true для инициализации всех bean лениво i.e. beans инициализируются только по запросу.

    @Component
    public class AddRefreshScopeProcessor implements BeanFactoryPostProcessor, ApplicationContextAware {
    
    private static ApplicationContext applicationContext;
    
    @SuppressWarnings("unchecked")
    @Override
    public void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {
    
        String[] beanNames = applicationContext.getBeanDefinitionNames();
        for(int i=0; i<beanNames.length; i++){
            BeanDefinition beanDef = beanFactory.getBeanDefinition(beanNames[i]);
            beanDef.setLazyInit(true);
            beanDef.setScope("refresh");
        }
    }
    
    @Override
    public void setApplicationContext(ApplicationContext context)
            throws BeansException {
        applicationContext = context;
    }
    
    /**
     * Get a Spring bean by type.
     * 
     * @param beanClass
     * @return
     */
    public static <T> T getBean(Class<T> beanClass) {
        return applicationContext.getBean(beanClass);
    }
    
    /**
     * Get a Spring bean by name.
     * 
     * @param beanName
     * @return
     */
    public static Object getBean(String beanName) {
        return applicationContext.getBean(beanName);
      }
    }
    
  • Создайте собственный класс, расширяющий StandardServletEnvironment и переопределяя метод initPropertySources для загрузки дополнительных PropertySources. (из конфигурационного сервера)

     public class CloudEnvironment extends StandardServletEnvironment {
    
      @Override
        public void initPropertySources(ServletContext servletContext, ServletConfig servletConfig) {
     super.initPropertySources(servletContext,servletConfig);
     customizePropertySources(this.getPropertySources());
       }
    
    @Override
      protected void customizePropertySources(MutablePropertySources propertySources) {
        super.customizePropertySources(propertySources);
        try {
          PropertySource<?> source = initConfigServicePropertySourceLocator(this);
          propertySources.addLast(source);
    
        } catch (
    
        Exception ex) {
          ex.printStackTrace();
        }
      }
    
      private PropertySource<?> initConfigServicePropertySourceLocator(Environment environment) {
    
        ConfigClientProperties configClientProperties = new ConfigClientProperties(environment);
        configClientProperties.setUri("http://localhost:8888");
        configClientProperties.setProfile("dev");
        configClientProperties.setLabel("master");
        configClientProperties.setName("YourApplicationName");
    
        System.out.println("##################### will load the client configuration");
        System.out.println(configClientProperties);
    
        ConfigServicePropertySourceLocator configServicePropertySourceLocator =
            new ConfigServicePropertySourceLocator(configClientProperties);
    
        return configServicePropertySourceLocator.locate(environment);
        }
    
      }
    
  • Создайте собственный ApplicatonContextInitializer и переопределите метод initialize для установки настраиваемого Enviroment вместо StandardServletEnvironment.

    public class ConfigAppContextInitializer implements ApplicationContextInitializer<ConfigurableApplicationContext> {
    
    @Override
    public void initialize(ConfigurableApplicationContext applicationContext) {
        applicationContext.setEnvironment(new CloudEnvironment());
      }
    }
    
  • Измените web.xml, чтобы использовать этот настраиваемый инициализатор контекста как для контекста приложения, так и для контекста сервлета.

    <servlet>
        <servlet-name>dispatcher</servlet-name>
            <servlet-class>
                org.springframework.web.servlet.DispatcherServlet
            </servlet-class>
        <init-param>
            <param-name>contextInitializerClasses</param-name>
            <param-value>com.my.context.ConfigAppContextInitializer</param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>
    
    
    <servlet-mapping>
        <servlet-name>dispatcher</servlet-name>
        <url-pattern>/</url-pattern>
    </servlet-mapping>
    
    <listener>
     <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>
    
    <context-param>
        <param-name>contextInitializerClasses</param-name>
        <param-value>com.my.context.ConfigAppContextInitializer</param-value>
    </context-param>
    
    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>/WEB-INF/dispatcher-servlet.xml</param-value>
    </context-param>
    

  • Для обновления beans созданной конечной точки обновления вам также потребуется обновить контекст приложения.

    @Controller
    public class RefreshController {
    
    @Autowired
    private RefreshAppplicationContext refreshAppplicationContext;
    
    @Autowired
    private RefreshScope refreshScope;
    
    @RequestMapping(path = "/refreshall", method = RequestMethod.GET)
    public String refresh() {
        refreshScope.refreshAll();
        refreshAppplicationContext.refreshctx();
        return "Refreshed";
    }
    

    }

RefreshAppplicationContext.java

@Component
public class RefreshAppplicationContext implements ApplicationContextAware {

    private ApplicationContext applicationContext;
    public void setApplicationContext(ApplicationContext applicationContext) {
        this.applicationContext = applicationContext;
    }


    public void refreshctx(){
        ((XmlWebApplicationContext)(applicationContext)).refresh();
    }
}