一， Zuul动态路由实现

动态路由需要达到可持久化配置，动态刷新的效果。不仅要能满足从spring的配置文件properties加载路由信息，还需要从Redis加载我们的配置。另外一点是，路由信息在容器启动时就已经加载进入了内存，我们希望配置完成后，实施发布，动态刷新内存中的路由信息，达到不停机维护路由信息的效果。

为了避免Eureka的侵入性设计，这里没有使用spring-cloud的服务的注册与发现的Eureka，而直接使用了Zuul。

需要配置如下属性使Zuul不依赖Eureka：

Icon

#关闭zuul的eureka注册
eureka.client.enabled=false

这里采取的方式修改路由定位器，借鉴DiscoveryClientRouteLocator去改造SimpleRouteLocator使其具备刷新能力。

DiscoveryClientRouteLocator比SimpleRouteLocator多了两个功能，第一是从DiscoveryClient（如Eureka）发现路由信息，我们不想使用eureka这种侵入式的网关模块，所以忽略它，第二是实现了RefreshableRouteLocator接口，能够实现动态刷新。

路由定位器的实现：

路由定位器的实现
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
@Override
public  void  refresh() {
     doRefresh();
}
 
@Override
protected  Map<String, ZuulRoute> locateRoutes() {
     LinkedHashMap<String, ZuulRoute> routesMap =  new  LinkedHashMap<String, ZuulRoute>();
     //从application.properties中加载路由信息
     routesMap.putAll( super .locateRoutes());
     //从redis中加载路由信息
     routesMap.putAll(locateRoutesFromRedis());
     //优化一下配置
     LinkedHashMap<String, ZuulRoute> values =  new  LinkedHashMap<>();
     for  (Map.Entry<String, ZuulRoute> entry : routesMap.entrySet()) {
         String path = entry.getKey();
         // Prepend with slash if not already present.
         if  (!path.startsWith( "/" )) {
             path =  "/"  + path;
         }
         if  (StringUtils.hasText( this .properties.getPrefix())) {
             path =  this .properties.getPrefix() + path;
             if  (!path.startsWith( "/" )) {
                 path =  "/"  + path;
             }
         }
         values.put(path, entry.getValue());
     }
     return  values;
} 
locateRoutesFromRedis方法，则是从Redis中获取路由信息。

然后通过调用路由定位器的doRefresh方法，刷新路由。

刷新路由
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
@Service
public  class  RefreshRouteService {
 
     @Autowired
     ApplicationEventPublisher publisher;
 
     @Autowired
     RouteLocator routeLocator;
 
     public  void  refreshRoute() {
         RoutesRefreshedEvent routesRefreshedEvent =  new  RoutesRefreshedEvent(routeLocator);
         publisher.publishEvent(routesRefreshedEvent);
     }
 
}

二， Zuul动态Filter实现

Zuul提供了一个框架，可以对过滤器进行动态的加载，编译，运行。过滤器之间没有直接的相互通信。他们是通过一个RequestContext的静态类来进行数据传递的。RequestContext类中有ThreadLocal变量来记录每个Request所需要传递的数据。

过滤器是由Groovy写成。这些过滤器文件被放在Zuul Server上的特定目录下面。Zuul会定期轮询这些目录。修改过的过滤器会动态的加载到Zuul Server中以便于request使用。

需要在启动方法中追加如下代码，动态载入Groovy脚本：

动态载入Groovy
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
// 启动时加载groovy filter
@Component
public  static  class  GroovyLoadLineRunner  implements  CommandLineRunner {
     private  Logger logger = LoggerFactory.getLogger(getClass());
 
     @Value ( "${ecej.groovy.path}" )
     private  String groovyPath;
 
     @Override
     public  void  run(String... args)  throws  Exception {
         MonitoringHelper.initMocks();
         FilterLoader.getInstance().setCompiler( new  GroovyCompiler());
         try  {
             FilterFileManager.setFilenameFilter( new  GroovyFileFilter());
             logger.info(groovyPath);
             FilterFileManager.init( 1 , groovyPath +  "pre" , groovyPath +  "post" );
         }  catch  (Exception e) {
             throw  new  RuntimeException(e);
         }
     }
} 
FilterFileManager会根据设定的pollingIntervalSeconds，去扫描指定目录的文件到内存中。

在指定目录放入如下的脚本，即可以实现动态Filter的功能。

Groovy脚本
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
package  com.ecej.zuul.filter.pre
 
import  org.slf4j.Logger
import  org.slf4j.LoggerFactory;
 
import  javax.servlet.http.HttpServletRequest;
 
import  com.netflix.zuul.ZuulFilter;
import  com.netflix.zuul.context.RequestContext;
 
class  PreRequest  extends  ZuulFilter {
     private  Logger logger = LoggerFactory.getLogger(getClass());
     @Override
     String filterType() {
         return  "pre"
     }
 
     @Override
     int  filterOrder() {
         return  1000
     }
 
     @Override
     boolean  shouldFilter() {
         return  true
     }
 
     @Override
     Object run() {
         try  {
             RequestContext ctx = RequestContext.getCurrentContext();
             HttpServletRequest request = ctx.getRequest();
             logger.info(String.format( "#####Groovy Pre Filter#####send %s request to %s" , request.getMethod(), request.getRequestURL().toString()));
         }  catch  (Exception e) {
             logger.error( "" ,e);
         }
 
         return  null
     }
}

之后只要修改这个文件，Filter的就会动态跟着改变。


# 微服务
Logo
向您推荐>>Eolink开发者社区

权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区

更多推荐

ELK实现containerd的容器日志采集展示【基于logging的全栈监测】

企业级ELK Stack构建介绍

avatar 云原生

深入理解 Mocha 测试框架：从零实现一个 Mocha

前言什么是自动化测试自动化测试在很多团队中都是Devops环节中很难执行起来的一个环节，主要原因在于测试代码的编写工作很难抽象，99%的场景都需要和业务强绑定，而且写测试代码的编写工作量往往比编写实际业务代码的工作量更多。在一些很多业务场景中投入产出比很低，适合写自动化测试的应该是那些中长期业务以及一些诸如组件一样的基础库。自动化测试是个比较大的概念，其中分类也比较多，比如单元测试，端对端测试，集

avatar 云原生

(20200916 Solved)docker-compose up创建容器自动退出

问题描述如题，创建容器后自动退出了。并且docker start container无效解决方案原因是缺失了控制终端的配置，需要在docker-compose.yml中增加tty:true ，有时候这样也不行，需要再增加一个command:/bin/bash，命令不一定是这个，需要是一个不会退出的命令，然后用-d后台启动容器。Referencesdocker-compose启动容器后自动退出...

avatar 云原生