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.
Ответы
Ответ 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();
}
}