zuul集成apollo动态刷新配置

客官°小女子只卖身不卖艺 2023-06-15 10:00 10阅读 0赞

zuul集成apollo实现路由配置的动态刷新

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.beans.factory.annotation.Autowired;
    import org.springframework.cloud.context.environment.EnvironmentChangeEvent;
    import org.springframework.cloud.netflix.zuul.RoutesRefreshedEvent;
    import org.springframework.cloud.netflix.zuul.filters.RouteLocator;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.ApplicationContextAware;
    import org.springframework.stereotype.Component;
    
    @Component
    public class ZuulPropertiesRefresher implements ApplicationContextAware {
    
      private static final Logger logger = LoggerFactory.getLogger(ZuulPropertiesRefresher.class);
    
      private ApplicationContext applicationContext;
    
      @Autowired
      private RouteLocator routeLocator;
    
      @ApolloConfigChangeListener(interestedKeyPrefixes = "zuul.")
      public void onChange(ConfigChangeEvent changeEvent) {
        refreshZuulProperties(changeEvent);
      }
    
      private void refreshZuulProperties(ConfigChangeEvent changeEvent) {
        logger.info("Refreshing zuul properties!");
    
        /**
         * rebind configuration beans, e.g. ZuulProperties
         * @see org.springframework.cloud.context.properties.ConfigurationPropertiesRebinder#onApplicationEvent
         */
        this.applicationContext.publishEvent(new EnvironmentChangeEvent(changeEvent.changedKeys()));
    
        /**
         * refresh routes
         * @see org.springframework.cloud.netflix.zuul.ZuulServerAutoConfiguration.ZuulRefreshListener#onApplicationEvent
         */
        this.applicationContext.publishEvent(new RoutesRefreshedEvent(routeLocator));
    
        logger.info("Zuul properties refreshed!");
      }
    
      @Override
      public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
      }
    }