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的实现屏蔽了开发测试环境中非这个环境网段启动的应用，并且比对请求的标签和本地的标签，来控制路由给哪一个服务器。
@Override
public AbstractServerPredicate getPredicate() {
OfflineEnvMetadataAwarePredicate offlineEnvMetadataAwarePredicate = new OfflineEnvMetadataAwarePredicate();
offlineEnvMetadataAwarePredicate.setEnv(env);
return offlineEnvMetadataAwarePredicate;
}
那么我们注意到请求头上的标签要在初始时就拿到，所以需要一个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);
}
}
}
至此就基本实现了最初的想法。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
这篇文章主要给大家介绍了关于java中“==“和equals()区别的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-01-01
这篇文章主要介绍了Springmvc conver实现原理及用法解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-10-10
文章介绍了如何在新版IDEA中调整工具栏菜单的显示方式,通过取消勾选设置中的某个选项,可以使菜单展开更加方便2025-01-01
这篇文章主要介绍了slf4j中的桥接器是如何运作的，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-12-12
其实idea也提供了docker的管理功能,比如查看容器列表,启动容器,停止容器等,本文来看下如何管理本地的docker daemon和远程的dockers daemon,感兴趣的朋友跟随小编一起看看吧2024-05-05
详解在IDEA中使用MyBatis Generator逆向工程生成代码
这篇文章主要介绍了详解在IDEA中使用MyBatis Generator逆向工程生成代码，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-06-06
这篇文章主要介绍了Springboot 使用@Async整合线程池的操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-06-06
这篇文章主要介绍了Java RMI机制讲解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下2021-07-07
这篇文章主要介绍了MyEclipse配置JDK的全过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-04-04
在程序的开发中我们经常会遇到日期类型的操作，Java对日期类型的操作提供了很好的支持。本文将通过示例来聊聊Java中日期类的使用，需要的可以参考一下2022-09-09
最新评论