Dubbo 源码解析 —— Cluster

前言

今天是小长假的倒数第二天,本来国庆是要加班四天的,后来因为要有事要回家才得以幸免,但是后天上班之后都要搬砖搬到手脱皮是必须的了.但是再忙每周一篇源码解析的承诺都依然记得,dubbo系列写完了还有很多系列,后面我会画个技能图谱给大家,以目前的知识储备,一周一篇的进度,一两年之内是肯定更新不完的,这点大家放心.今天刚回到广州,看了一下是星期六,怕明天太忙,所以就开始理一下思绪

其实相比博客而言,很多人更喜欢看书,为什么呢,因为看书比较系统,而很多博客经常写着写着就断更了,导致这看了一点,那看了一点,最后学得不系统,这个就是学习的大忌.我也希望能改变这个现状,后面有时间整理出一份我自己的 技能图谱和一份 目录.比如 dubbo源码解析这个系列的,按照学习曲线,制定出一个循序渐进学习的目录.

另外鉴于也有一些朋友问到我 怎么看源码为什么看源码这两个老生常谈的问题.

首先 怎么看源码这个问题,在今后的源码分析系列的内容中,我也力求能更多的把自己当时的思考思路向大家展示出来,当然这个思路毕竟只是我个人的思路,也欢迎大家批评指正.

其次 为什么看源码这个问题,其实可以从王者荣耀为什么火来分析.为什么王者农药容易上瘾,很大一个原因就是四个字, 及时反馈.你可以在短时间内通过自己的努力获取到胜利的快感,然而看源码恰恰相反.之所以会有这个疑惑是因为你有两个问题一直得不到答案,1.源码看了到底有没有用 2.需要看到什么程度才能涨工资.你甚至希望有人给出一个标准,然后你才放心的头悬梁,锥刺股去学,在这两个问题没有得到肯定的回答之前,你害怕失败.

鉴于这这些问题,源码分析系列文章中(包括之前的),我都有穿插面试题,让你看到自己正在为自己的未来做着准备.

直入主题

我们再来回顾一下官网的对于集群容错的架构设计图

从标题看就知道本篇主要讲的就是 Cluster了,之前我反复强调三个关键词 Directory, Router, LoadBalance,但是换个角度而言,其实也可以是四个关键词,还有一个就是 Cluster

首先我们先看看官网的介绍,这个 Cluster到底是干嘛的

Cluster 将 Directory 中的多个 Invoker 伪装成一个 Invoker,对上层透明,伪装过程包含了容错逻辑,调用失败后,重试另一个

简单来说,就是 应对出错情况采取的策略,当然这么说还是有些不准确的.那我们再来看看这个接口及其继承体系图

看继承体系图中,我们也可以看到了他有9个实现类,换个角度来说,就是有9中应对策略,下面的逐一简介和分析其内部实现(以下逻辑都在Cluster接口的join方法)

MergeableCluster

这个主要用在 分组聚合中,我们来看一下官网的介绍

按组合并返回结果 ,比如菜单服务,接口一样,但有多种实现,用group区分,现在消费方需从每种group中调用一次返回结果,合并结果返回,这样就可以实现聚合菜单项。

该类的源码是这么多实现类中最多的.代码全部贴出来篇幅就太大了,我用一个流程图来告诉大家这个类是干什么的

大家可以根据我这个流程图对照源码理一下思路,这三个判断也是很容易看出来的,比如

  • URL中merger属性是否有值
String merger = getUrl().getMethodParameter( invocation.getMethodName(), Constants.MERGER_KEY );
if (ConfigUtils.isEmpty(merger) ) { // 如果方法不需要Merge,退化为只调一个Group
    for(final Invoker<T> invoker : invokers ) {
        if (invoker.isAvailable()) {
            return invoker.invoke(invocation);
        }
    }
    return invokers.iterator().next().invoke(invocation);
}

是否指定合并方法 merger.startsWith("."),为什么是否指定方法是这么判断的呢?因为指定合并方法在xml配置中就是要以"."开头,例如

<dubbo:reference interface="com.xxx.MenuService" group="*">
    <dubbo:method name="getMenuItems" merger=".addAll" />
</dubbo:service>

是否默认merge策略

if (ConfigUtils.isDefault(merger)) {
    resultMerger = MergerFactory.getMerger(returnType);
} else {
    resultMerger = ExtensionLoader.getExtensionLoader(Merger.class).getExtension(merger);
}

其实这个`ConfigUtils.isDefault从我们使用上都可以推断出他的实现

public static boolean isDefault(String value) {
    return "true".equalsIgnoreCase(value) 
            || "default".equalsIgnoreCase(value);
}

AvailableCluster

从单词 Available意思就知道,这个是调用 可用的.代码实现逻辑也比较简单

源码的这个写法是比较优雅的,遍历所有的 Invokers判断 invoker.isAvalible,只要一个有为true直接调用返回,否则就抛出异常.

ForkingCluster

引用官网的介绍

并行调用多个服务器,只要一个成功即返回。通常用于实时性要求较高的读操作,但需要浪费更多服务资源。可通过 forks="2" 来设置最大并行数。

我们来看看源码的实现

这里就涉及到了 线程池,但是由于本篇篇幅会很大,所以线程池的会专门有个专题来讲,可以继续简书关注肥朝

至于这个 execute方法是干嘛的,这个时候可以用上码农日常工具推荐里面介绍的 Dash

FailfastCluster

引用官网的介绍

快速失败,只发起一次调用,失败立即报错。通常用于非幂等性的写操作,比如新增记录。

看看源码实现

这个的实现应该是实现类里面最简单的,就是调用invoke,调用失败就抛出异常,但是这个却是面试问得最多的,请留意后面的面试题

MockClusterWrapper

这个主要用在 本地伪装上,让我们来看官网描述

本地伪装通常用于服务降级,比如某验权服务,当服务提供方全部挂掉后,客户端不抛出异常,而是通过 Mock 数据返回授权失败

同样我也用一个流程图来描述他的逻辑

FailoverCluster

这个是本篇的重点,也是dubbo里面容错方案的缺省值.让我们来看官网介绍

失败自动切换,当出现失败,重试其它服务器。通常用于读操作,但重试会带来更长延迟。可通过 retries="2" 来设置重试次数(不含第一次)

也就是说,默认的情况下,如果第一次调用失败,会重试两次,也就是一共是调用三次.所以len = 3的(经过调试确实是3).

这个时候面试题就来了,注意我上面提到的 FailfastCluster,面试会问,dubbo中"读接口"和"写接口"有什么区别?答案也是很明显的,因为默认 FailoverCluster会重试,如果是"写"类型的接口,如果在网络抖动情况下写入多个值,所以"写"类型的接口要换成 FailfastCluster

FailbackCluster

老规矩看官网

失败自动恢复,后台记录失败请求,定时重发。通常用于消息通知操作。

这个定时重发的逻辑如下,由于还是涉及到 线程池,这个必须要有些知识铺垫,后面会讲解,简书关注肥朝即可,不过我们可以先看一下api文档

FailsafeCluster

继续看官网介绍,我反复强调官网介绍,其实也是在回答前面的"怎么看源码"这个问题

失败安全,出现异常时,直接忽略。通常用于写入审计日志等操作。

这个的逻辑就很简单了,官网的这句话就已经介绍完了

BroadcastCluster

老规矩,还是官网介绍

广播调用所有提供者,逐个调用,任意一台报错则报错。通常用于通知所有提供者更新缓存或日志等本地资源信息。

这个的逻辑也是很简单,遍历所有 Invokers, 逐个调用每个调用,有异常就catch,以免影响到剩下的调用,那这个和 AvailableCluster有什么区别?当然有啊,你仔细看就知道, BroadcastCluster是要遍历调用完全部的 invoker,而 AvailableCluster是只要有一个调用就return了.

写在末尾

本文到此就要结束了,看了一下时间,已经是星期天了.下周源码分析我们再见,鉴于本人才疏学浅,不对的地方还望斧正,也欢迎关注我的简书,名称为 肥朝

原文发布于微信公众号 - 芋道源码(YunaiV)

原文发表时间:2017-11-17

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏FreeBuf

一个脑洞“颇大”的恶搞链接

事件起因 这其实是一件很偶然的事情,前几天在某大佬群里看大佬装逼。突然一个平日不怎么冒泡的群友发了一条链接。本着“这群里都是好人 ”的想法我就天真的点了进去.....

3719
来自专栏Wordpress专用主机|主题模板|必备插件

WORDPRESS视频教程:使用ELEMENTOR制作企业展示网站

第一次录wordpress视频教程,可能讲的很烂。希望各位朋友见谅,轻喷~博主会不断进步的。

5991
来自专栏大数据挖掘DT机器学习

爬取淘宝/天猫评论数据的过程

要做数据分析首先得有数据才行。对于我等平民来说,最廉价的获取数据的方法,应该是用爬虫在网络上爬取数据了。本文记录一下笔者爬取天猫某商品的全过程,淘宝上面的店铺...

4377
来自专栏贾老师の博客

分布式系统的接口幂等性设计

2883
来自专栏数据小魔方

扒一扒rvest的前世今生!

rvest包可能是R语言中数据抓取使用频率最高的包了,它的知名度和曝光度在知乎的数据分析相关帖子和回答中都很高。 甚至很多爬虫教程和数据分析课程在讲解R语言网络...

3857
来自专栏java一日一条

改善Java文档的理由、建议和技巧

我非常确定,作为开发人员我们都喜爱技术文档。我们喜欢阅读文档、写文档,更不用说维护文档了,我简直爱死它了!

1001
来自专栏小程序之家

如何在小程序中实现拍照功能

在小程序使用的过程中,难免会用到相机组件,本文将教大家配置入门小程序camera组件的使用,并自己制作一个小程序相机的demo出来。

2.4K4
来自专栏web前端教室

我在工作中的常用代码管理

说是管理其实就是把常用的一些JS方法,自己保存下来,这样的以后的工作中可以比较方便的使用。 哪些方法可以、或是说值得保存呢?(偏见啊)我自己的主观看法就是一些功...

1955
来自专栏me的随笔

Visual Studio 代码风格约束

注意,这里的错误是IDE1006:Naming rule violation,编译时依然能通过(没找到在哪里设置不允许通过编译):

2062
来自专栏java一日一条

改善Java文档的理由、建议和技巧

我非常确定,作为开发人员我们都喜爱技术文档。我们喜欢阅读文档、写文档,更不用说维护文档了,我简直爱死它了!

521

扫码关注云+社区

领取腾讯云代金券