Spring Cloud体系实现标签路由
如果你正在使用spring cloud体系,在实际使用过程中正遇到以下问题,可以阅读本文章的内容作为后续你解决这些问题的参考,文章内容不保证无错,请务必仔细思考之后再进行实践。
问题:
1,本地连上开发或测试环境的集群连调,正常测试请求可能会请求到本地,被自己的debug阻塞。
2,测试环境维护时,多项目并发提测,维护多个相同的集群进行测试是否必要,是否有更好的方案。
一般,我们在使用spring cloud全家桶的时候,会选择zuul作为网关,ribbon作为负载均衡器,feign作为远程服务调用模版。使用过spring cloud的同学对这些组件的作用必然非常熟悉。这里就拿这些组件组合成的微服务集群来实现标签路由的功能。
实现的效果如图所示,在头上带上标签的请求会在经过网关和各个应用时进行标签判断流量应该打到哪一个去,而每一个应用自己本身的标签是通过eureka上的matedate实现的。
如下图可以构想动态修改标签控制应用所能承接的请求,这里暂时不描述mq部分的功能:
答案:
实现一个zoneavoidancerule的继承类,重写getpredicate方法:
@override public abstractserverpredicate getpredicate() { offlineenvmetadataawarepredicate offlineenvmetadataawarepredicate = new offlineenvmetadataawarepredicate(); offlineenvmetadataawarepredicate.setenv(env); return offlineenvmetadataawarepredicate; }
predicate的实现屏蔽了开发测试环境中非这个环境网段启动的应用,并且比对请求的标签和本地的标签,来控制路由给哪一个服务器。
/** * 线下环境路由策略具体逻辑 */ public class offlineenvmetadataawarepredicate extends abstractserverpredicate { private string env; public void setenv(string env) { this.env = env; } @override public boolean apply(predicatekey predicatekey) { if(predicatekey == null || !(predicatekey.getserver() instanceof discoveryenabledserver)){ return true; } discoveryenabledserver server = (discoveryenabledserver) predicatekey.getserver(); string serverzone = server.getinstanceinfo().getmetadata().get("zone"); string requestzone = requestzonelabelcontext.getrequestzone(); // dev || sit 环境 本地不允许直接连调 if(env.equals("sit") || env.equals("dev")){ if(stringutils.isblank(requestzone) && !server.gethost().startswith("10.0")){ return false; } } if(stringutils.isnotblank(serverzone)) { return serverzone.equals(requestzone); }else if(stringutils.isnotblank(requestzone)){ return requestzone.equals(serverzone); } return true; } }
那么我们注意到请求头上的标签要在初始时就拿到,所以需要一个servletrequestlistener,将拿到的zone放入requestzonelabelcontext。我们知道在一个请求中如果是一个io线程执行到底,我们只需要利用threadlocal来存储线程变量,可是如果一个请求中会产生不定的子线程完成,数据在线程间的传递就成为问题,这里使用了inheritablethreadlocal来决解,在requestzonelabelcontext中可以看到。
public class requestzonelabelcontextlistener implements servletrequestlistener { private static final string zone_label_name = "zone"; @override public void requestdestroyed(servletrequestevent sre) { requestzonelabelcontext.remove(); } @override public void requestinitialized(servletrequestevent requestevent) { httpservletrequest request = (httpservletrequest)requestevent.getservletrequest(); string lbzone = request.getheader(zone_label_name); if(stringutils.isnotblank(lbzone)){ requestzonelabelcontext.setzone(lbzone); } } }
/** * 从request header上传递label到feign请求 */ public class requestzonelabelcontext { private static inheritablethreadlocal<string> zonelabelthreadlocal = new inheritablethreadlocal<>(); public static void setzone(string zone){ zonelabelthreadlocal.set(zone); } public static string getrequestzone(){ return zonelabelthreadlocal.get(); } public static void remove(){ zonelabelthreadlocal.remove(); } }
那么在应用之间调用的feign中我们是需要继续把这个zone通过header传递下去的,所以又扩展了requestinterceptor:
public class feignzoneheaderinterceptor implements requestinterceptor { @override public void apply(requesttemplate template) { string requestzone = requestzonelabelcontext.getrequestzone(); if(stringutils.isnotblank(requestzone)){ template.header("zone", requestzone); } } }
至此就基本实现了最初的想法。
这个实现方式仅供参考,如有跟好的方式,多多指教哈~
上一篇: 真正会写文章的人,往往会从抄袭开始!
下一篇: 7天学完Java基础之3/7
推荐阅读
-
Spring Cloud zuul自定义统一异常处理实现方法
-
Spring Cloud体系实现标签路由的方法示例
-
[Spring cloud 一步步实现广告系统] 16. 增量索引实现以及投送数据到MQ(kafka)
-
spring cloud config 配置中心快速实现过程解析
-
Spring Cloud Gateway 服务网关快速实现解析
-
详解spring cloud使用Hystrix实现单个方法的fallback
-
spring cloud实现Eureka注册中心的HA的方法
-
详解Spring Cloud Consul 实现服务注册和发现
-
Spring Cloud Config实现分布式配置中心
-
Spring Cloud使用Feign实现Form表单提交的示例