作者:zlt2000 原文:https://www.cnblogs.com/zlt2000/p/11459390.html?utm_source=tuicool&utm_medium=referral
一、背景
在我们开发微服务架构系统时,虽然说每个微服务都是孤立的可以单独开发,但实际上并非如此,要调试和测试你的服务不仅需要您的微服务启动和运行,还需要它的上下文服务、依赖的基础服务等都要运行;但如果你的系统服务数和依赖比较多呢,那就是一个比较棘手的问题!有没有办法能提高开发效率呢?
如上图所示,我们能不能用 服务器把所有的服务都部署起来,然后开发 只在本地运行自己所负责开发的服务,因为需要依赖其他服务所以本地启动的服务也需要注册到公共的注册中心里;
例子中业务服务B有3台实例注册到注册中心里
分别是:服务上的、开发A与开发B自己本机启动的
但是这样做又会出现新的问题: 服务会冲突乱窜,意思就是开发A在debug自己的业务服务B服务的时候可能请求会跳转到其他人的实例上(服务器、开发B)
二、解决思路
解决这个服务乱窜问题有一个比较优雅的方式就是自定义负载均衡规则,主要实现以下目标:
三、具体实现
要实现上面的目标有两个比较关键的问题需要解决
3.1. 区分不同用户的服务实例
直接使用注册中心的元数据(metadata)来区分就可以了
主流的注册中心都带有元数据管理
以Nacos为例,只需要在配置文件下添加
spring: cloud: nacos: discovery: server-addr: localhost:8848 metadata: version: zlt
metadata下的version就是我添加的元数据key为version,value为zlt
启动服务后元数据就会注册上去,如下图
经过元数据区分后,目前是下面这个情况
3.2. 自定义负载均衡规则
首先在Spring Cloud微服务框架里实例的负载均衡是由Ribbon负责。
CustomIsolationRule详细类信息可查看:CustomIsolationRule.java
public class CustomIsolationRule extends RoundRobinRule {
/**
* 优先根据版本号取实例
*/
@Override
public Server choose(ILoadBalancer lb, Object key) {
if (lb == null) {
return null;
}
String version = LbIsolationContextHolder.getVersion();
List<Server> targetList = null;
List<Server> upList = lb.getReachableServers();
if (StrUtil.isNotEmpty(version)) {
//取指定版本号的实例
targetList = upList.stream().filter(
server -> version.equals(
((NacosServer) server).getMetadata().get(CommonConstant.METADATA_VERSION)
)
).collect(Collectors.toList());
}
if (CollUtil.isEmpty(targetList)) {
//只取无版本号的实例
targetList = upList.stream().filter(
server -> {
String metadataVersion = ((NacosServer) server).getMetadata().get(CommonConstant.METADATA_VERSION);
return StrUtil.isEmpty(metadataVersion);
}
).collect(Collectors.toList());
}
if (CollUtil.isNotEmpty(targetList)) {
return getServer(targetList);
}
return super.choose(lb, key);
}
/**
* 随机取一个实例
*/
private Server getServer(List<Server> upList) {
int nextInt = RandomUtil.randomInt(upList.size());
return upList.get(nextInt);
}
}
集成轮询规则RoundRobinRule来实现,主要的逻辑为
并通过配置开关控制是否开启自定义负载规则
@Configuration
@ConditionalOnProperty(value = "zlt.ribbon.isolation.enabled", havingValue = "true")
@RibbonClients(defaultConfiguration = {RuleConfigure.class})
public class LbIsolationConfig {
}
四、总结
上面提到的 区分服务实例和 自定义负载规则为整个解决思路的核心点,基本实现了服务实例的隔离,剩下要做的就是 上游的version怎样传递呢?,下面我提供两个思路
参考
https://github.com/Nepxion/Discovery
最后给大家分享一些学习资料,里面包括:(BATJ面试资料、高可用、高并发、高性能及分布式、Jvm性能调优、Spring源码,MyBatis,Netty,Redis,Kafka,Mysql,Zookeeper,Tomcat,Docker,Dubbo,Nginx等多个知识点的架构资料)和Java进阶学习路线图。
免费领取方式:加微信号 weixin99ting 备注验证消息 (资料)即可获取。
最后,祝大家早日学有所成!
来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/31545684/viewspace-2656049/ ,如需转载,请注明出处,否则将追究法律责任。