study/Spring-Cloud-Alibaba
1
0
Fork 0
mirror of https://gitee.com/mirrors/Spring-Cloud-Alibaba.git synced 2021-06-26 13:25:11 +08:00
Code Issues Releases Wiki Activity

sentinel zuul refactor 1.x

Browse Source
This commit is contained in:
fangjian0423 2019-03-04 16:48:57 +08:00
parent d0cbd9f994
commit c470f56492
2 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-alibaba-sentinel-zuul/src/main/java/org/springframework/cloud/alibaba/sentinel/zuul/SentinelZuulAutoConfiguration.java
View File

@ -22,7 +22,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.support.DefaultListableBeanFactory; import org.springframework.beans.factory.support.DefaultListableBeanFactory;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.cloud.alibaba.sentinel.zuul.listener.FallBackProviderListener; import org.springframework.cloud.alibaba.sentinel.zuul.handler.FallBackProviderHandler;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment; import org.springframework.core.env.Environment;
@ -106,9 +106,9 @@ public class SentinelZuulAutoConfiguration {
} }
@Bean @Bean
public FallBackProviderListener fallBackProviderListener( public FallBackProviderHandler fallBackProviderListener(
DefaultListableBeanFactory beanFactory) { DefaultListableBeanFactory beanFactory) {
return new FallBackProviderListener(beanFactory); return new FallBackProviderHandler(beanFactory);
} }
} }

12
spring-cloud-alibaba-sentinel-zuul/src/main/java/org/springframework/cloud/alibaba/sentinel/zuul/listener/FallBackProviderListener.java → spring-cloud-alibaba-sentinel-zuul/src/main/java/org/springframework/cloud/alibaba/sentinel/zuul/handler/FallBackProviderHandler.java
View File

@ -1,4 +1,4 @@
package org.springframework.cloud.alibaba.sentinel.zuul.listener; package org.springframework.cloud.alibaba.sentinel.zuul.handler;
import java.util.Map; import java.util.Map;
@ -15,14 +15,14 @@ import com.alibaba.csp.sentinel.adapter.zuul.fallback.ZuulBlockFallbackProvider;
/** /**
* @author tiger * @author tiger
*/ */
public class FallBackProviderListener implements SmartInitializingSingleton { public class FallBackProviderHandler implements SmartInitializingSingleton {
private static final Logger logger = LoggerFactory private static final Logger logger = LoggerFactory
.getLogger(FallBackProviderListener.class); .getLogger(FallBackProviderHandler.class);
private final DefaultListableBeanFactory beanFactory; private final DefaultListableBeanFactory beanFactory;
public FallBackProviderListener(DefaultListableBeanFactory beanFactory) { public FallBackProviderHandler(DefaultListableBeanFactory beanFactory) {
this.beanFactory = beanFactory; this.beanFactory = beanFactory;
} }
@ -32,13 +32,13 @@ public class FallBackProviderListener implements SmartInitializingSingleton {
.getBeansOfType(ZuulBlockFallbackProvider.class); .getBeansOfType(ZuulBlockFallbackProvider.class);
if (MapUtils.isNotEmpty(providerMap)) { if (MapUtils.isNotEmpty(providerMap)) {
for (String k : providerMap.keySet()) { for (String k : providerMap.keySet()) {
logger.info("[Sentinel] Register provider name:{}, instance: {}", k, logger.info("[Sentinel Zuul] Register provider name:{}, instance: {}", k,
providerMap.get(k)); providerMap.get(k));
ZuulBlockFallbackManager.registerProvider(providerMap.get(k)); ZuulBlockFallbackManager.registerProvider(providerMap.get(k));
} }
} }
else { else {
logger.info("[Sentinel] Register default fallback provider. "); logger.info("[Sentinel Zuul] Register default fallback provider. ");
ZuulBlockFallbackManager.registerProvider(new DefaultBlockFallbackProvider()); ZuulBlockFallbackManager.registerProvider(new DefaultBlockFallbackProvider());
} }
} }