-
适用场景:通过将一个或多个服务的提供者划分到同一个分组,约束流量只在指定分组中流转,从而实现流量隔离的目的,用于解决灰度发布、蓝绿发布问题。 -
基本原理:通过给服务提供方的单个或多个实例指定标签,消费方在调用服务的时候,通过匹配标签筛选出符合条件的服务列表,然后再根据负载策略进行远程服务调用。 -
基本使用:在使用标签路由的时候,需要对服务提供方和消费方做相应配置才可生效。
消费方可以通过设置隐式参数指定标签给自己使用,以及将标签传递给下游服务,因为下游服务也有可能再次调用其他服务,所以需要通过隐式参数的形式来传递标签,具体代码:
RpcContext.getContext().setAttachment(CommonConstants.TAG_KEY,"标签");
还有种方式可以通过<dubbo:reference tag=“标签” >来指定标签,如果流量隔离仅限于消费方和提供方两个服务范围,则可以使用这种方式,否则还是用隐式参数的方式。
服务提供方的标签有两种配置方式:静态和动态
静态打标:
服务级别打标,<dubbo:service tag=“标签”>
应用级别打标,启动参数中增加-Ddubbo.provider.tag=标签
动态打标:通过dubbo-admin服务治理平台添加标签路由。
- 动态路由实现原理
动态路由的获取:
我们可以通过dubbo-admin给应用添加标签路由,添加的时候会将路由信息写入到zookeeper节点:/dubbo/config/dubbo/应用名.tag-router中。消费方在创建远程引用对象的时候会去获取远程服务列表Invoker,获取到后会将Invoker列表传递给每个激活的路由Router,标签路由使用的类是TagRouter。TagRouter在收到服务列表后,会从动态配置DynamicConfiguration中获取路由信息,当前使用的配置中心是zookeeper,所以使用的配置实例对象是ZookeeperDynamicConfiguration,它会通过与dubbo-admin约定的相同节点中读取配置信息,同时还会将TagRouter作为这个节点的监听器,以便动态刷新路由配置,拿到配置后就是解析并赋值给变量tagRouterRule。路由配置获取逻辑参见TagRouter的notify方法,节选部分代码:
synchronized (this) {
if (!providerApplication.equals(application)) {
if (!StringUtils.isEmpty(application)) {
ruleRepository.removeListener(application + RULE_SUFFIX, this);
}
String key = providerApplication + RULE_SUFFIX;
ruleRepository.addListener(key, this);
application = providerApplication;
String rawRule = ruleRepository.getRule(key, DynamicConfiguration.DEFAULT_GROUP);
if (StringUtils.isNotEmpty(rawRule)) {
this.process(new ConfigChangedEvent(key, DynamicConfiguration.DEFAULT_GROUP, rawRule));
}
}
}
动态路由的使用:
消费方在调用远程服务的时候,会从RegistryDirectory中获取服务列表Invoker(见doList方法),在这过程中会使用RouteChain进行路由筛选。如果TagRouter没有获取到动态路由配置tagRouterRule,则会按照静态路由过滤规则(见filterUsingStaticTag方法)来筛选服务列表,否则按动态规则来筛选。
|