【想进大厂还不会阅读源码】ShenYu源码-支持motan协议

简介: ShenYu源码阅读📚。原来的插件只支持 motan2 协议,并且是硬编码的,本次修改使MotanRpcExt 得到增强。我们可以通过以上的线索来思考我们本次的阅读线索,贡献者是做了什么实现了增强motan插件、这个motan的插件的功能是什么。

相信大家碰到源码时经常无从下手🙃,不知道从哪开始阅读,面对大量代码晕头转向,索性就读不下去了,又浪费了一次提升自己的机会😭。


我认为有一种方法,可以解决大家的困扰!那就是通过阅读某一次开源的【PR】、【ISSUE】,从这个入口出发去阅读源码!!


至此,我们发现自己开始从大量堆砌的源码中脱离开来😀。豁然开朗,柳暗花明又一村。

ShenYu是一个异步的,高性能的,跨语言的,响应式的 API 网关。有关ShenYu的介绍可以戳这

一、前瞻

OK,开始我们今天的PR阅读,PR提交如下图。

在这里插入图片描述

翻译过来,意思就是:原来的插件只支持motan2协议,并且是硬编码的。本次修改使MotanRpcExt 得到增强以支持motan协议。同时支持根据客户端注册的RPC协议自动匹配。

简单来说就是增强motan插件

我们可以通过以上的线索来思考我们本次的阅读线索:

  1. 贡献者是做了什么实现了增强motan插件
  2. 这个motan的插件的功能是什么

二、探索

对于线索2,我们可以看下ShenYu项目的模块。

在这里插入图片描述

ShenYu既然是一个网关,它必须要调用到微服务节点,而上图中有各个微服务开源中间件的集成:grpc、dubbo等。可以知道motan插件的功能,就是提供给ShenYu网关一个支持调用motan微服务节点的功能。

那我们继续线索1的探索。

整体看下本次的所有提交,可以分为两部分,负责监听微服务节点消息的监听端、调用微服务节点的调用端

在这里插入图片描述

那我们先看看调用端修改了什么?

// 旧代码
try {
   
    responseFuture = (ResponseFuture) commonClient.asyncCall(metaData.getMethodName(), params, Object.class);
} catch (Throwable e) {
   
    LOG.error("Exception caught in MotanProxyService#genericInvoker.", e);
    return null;
}

// 新代码
try {
   
    Request request = MotanClientUtil.buildRequest(reference.getServiceInterface(), metaData.getMethodName(), metaData.getParameterTypes(), params, null);
    responseFuture = (ResponseFuture)commonClient.asyncCall(request, Object.class);
} catch (Throwable e) {
   
    LOG.error("Exception caught in MotanProxyService#genericInvoker.", e);
    return null;
}

很明显,新代码新增了几个入参reference.getServiceInterface()metaData.getParameterTypes(),推测是为了支持motan协议的作用,这一部分我们发现收获的东西不多,那先看看监听端。

监听端做了以下修改。和调用端同样,新增了入参

在这里插入图片描述
我们很好奇,支持一个新的协议这么简单吗,只是新增了几个入参?

其实可以思考下,本次PR提交贡献的新motan协议和旧的motan2协议,两者本质上都是motan协议。而前者相比旧协议motan2,需要在旧协议的基础上新增以上的入参以支持其功能。

这也解答了上文我们思考的线索1:

贡献者是做了什么实现了增强motan插件

好了,今天的分享就到这了。大家能否感受到通过PR这种方式来阅读源码的乐趣呢

创作不易,不妨点赞、收藏、关注支持一下,各位的支持就是我创作的最大动力❤️

相关文章
|
7月前
|
XML 监控 Dubbo
从初学者到专家:Dubbo中Application的终极指南【十一】
从初学者到专家:Dubbo中Application的终极指南【十一】
118 0
|
7月前
|
Dubbo Cloud Native 网络协议
【Dubbo3技术专题】「服务架构体系」第一章之Dubbo3新特性要点之RPC协议分析介绍
【Dubbo3技术专题】「服务架构体系」第一章之Dubbo3新特性要点之RPC协议分析介绍
97 1
|
7月前
|
XML Dubbo Java
【Dubbo3技术专题】回顾Dubbo2.x的技术原理和功能实现及源码分析(温故而知新)(二)
【Dubbo3技术专题】回顾Dubbo2.x的技术原理和功能实现及源码分析(温故而知新)
88 2
|
7月前
|
XML 监控 Dubbo
【Dubbo3技术专题】回顾Dubbo2.x的技术原理和功能实现及源码分析(温故而知新)(一)
【Dubbo3技术专题】回顾Dubbo2.x的技术原理和功能实现及源码分析(温故而知新)
113 1
|
7月前
|
API Nacos
【想进大厂还不会阅读源码】ShenYu源码-接入注册中心发现服务
ShenYu源码阅读。相信大家碰到源码时经常无从下手🙃,不知道从哪开始阅读😭。我们先思考下我们的阅读线索,贡献者是怎么添加发现服务的。这些发现服务是怎么和项目集成的,让ShenYu网关能从注册中心获取节点信息?
117 1
【想进大厂还不会阅读源码】ShenYu源码-接入注册中心发现服务
|
7月前
|
API Nacos
【想进大厂还不会阅读源码】ShenYu源码-重构同步数据服务
ShenYu源码阅读📚。我们看下PR的标题和Concersation的头一句,大概意思就是重构注册中心数据同步到ShenYu网关的方式。大家看看重构了有没好处呢?不仅获得了知识,还获得了一次开源贡献,何乐而不为呢
|
Dubbo Java 应用服务中间件
Netty入门到超神系列-手撸简单版RPC框架(仿Dubbo)
原理还是比较简单 : 代理 + 线程池 + Netty 下面做一些解释: 首先需要定义一个统一的API接口,例:UserApi , 服务端(provider)需要实现这个接口,提供相应的方法UserApiImpl#save,客户端通过远程来调用该接口。 然后需要约定一个协议,服务器如何才能识别到客户端要调用哪个接口?:我这里用 “接口权限定名#方法名#参数” ,的方式来,因为是一个简单版本的RPC。服务端解析该内容就能匹配对应的接口的实现类,然后调用该方法。并把方法的返回值通过Netty写回给客户端 使用的编解码器都是比价简单的String的编解码器
177 0
|
XML Java 数据格式
最近很火的SOFARPC是什么?带你快速入门SOFARPC
最近很火的SOFARPC是什么?带你快速入门SOFARPC
最近很火的SOFARPC是什么?带你快速入门SOFARPC
|
7月前
|
存储 Dubbo Java
从源码全面解析 dubbo 服务订阅的来龙去脉
从源码全面解析 dubbo 服务订阅的来龙去脉
|
存储 JavaScript Linux
开源 Golang 微服务入门二:RPC 框架 Kitex| 青训营笔记
Kitex 字节跳动内部的 Golang 微服务 RPC 框架,具有高性能、强可扩展的特点,在字节内部已广泛使用。如果对微服务性能有要求,又希望定制扩展融入自己的治理体系,Kitex 会是一个不错的选
305 0
开源 Golang 微服务入门二:RPC 框架 Kitex| 青训营笔记