服务调用流程|学习笔记

本文涉及的产品
传统型负载均衡 CLB,每月750个小时 15LCU
应用型负载均衡 ALB,每月750个小时 15LCU
EMR Serverless StarRocks,5000CU*H 48000GB*H
简介: 快速学习服务调用流程

开发者学堂课程【阿里巴巴分布式服务框架 Dubbo 快速入门服务调用流程】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址https://developer.aliyun.com/learning/course/624/detail/9481


服务调用流程


内容介绍:

一、代理对象如何进行方法调用

二、总结


一、代理对象如何进行方法调用

以 Debug 实际运行为准进行演示。

进入调用方法,看到 user service 确实是一个代理对象,这个代理对象是层层封装了各种 Invoker,Invoker 里是真正要执行的一些功能方法。

Stepinto 进来以后,拿到要执行的方法信息,包括参数的类型信息等等。

接着有一个叫 invoker.invoke,然而这个 Invoker 里本身就是层层封装的结果,放行,再带 stepinto,在 into之前,会看到它需要 Invoker 执行,会把方法以及参数封装成一个叫 RPC 执行,一个远程调用的对象。接着 stepped into 就行,它进来封装。

现在此处 Invoker:

Public Result invoke(Invocation invocation)throws RpcException{

Result result=null

首先得到的是最外层的 MockClusterInvoker,Invoker 时候又是 invoker.invoke,这里面又封装了 FailoverClusterInvoker。这些 clusterInvoker 其实就是 Invoker。当我们出现失败以后这是一个失败重试,重试到其他服务器。

继续执行,Invoker 里还会有。在 Invoker 执行的时候,集群执行的时候会发现这儿有一个方法叫 list:List<Invoker<T>>invokers=list(invocation

list 的作用是把想要执行的方法在注册中心找到,找到两个。一个是上一次的2.0版本,还有一个是1.0版本。然后接下来获取到配置的默认的负载均衡机制,获取到以后继续 doinvoke,继续进来,进入层层 Invoker 里,负载均衡拿到以后还有一个叫 select,能根据负载均衡策略(默认就是 random,按照权重进行负载,而 invoker,它随机选择一个 Invoker),选中执行2.0版本的方法,get user service 的 address 方法。

现在得到了 Invoker,有一个叫 invoker.invoke,继续执行。Invoker 里还有一些 Filter,真正要执行功能的时候封装了一些 Filter。这个 Filter 在最一开始代理对象里要用 Invoker 的时候,可以来封装 Filter。

比如要做缓存功能,有一个示例,示例里有一个结果缓存,如果想把结果缓存啊,可以配上 cache=“lru”,给代理对象加一个 Filter,如果还想做缓存,还想做 Mock,mock 就是有一个叫本地伪装,还想做这个功能,能有相关的 filter 介入,但是都没配这两个功能。所以一开始就来到了 invoker,invoker 选中了负载均衡以后,接下来就是又进入了 filter 的环节(各个统计信息),比如监控中心要统计一些信息,count 各种统计。

进入各种 Filter 的环节,Invoker 里明显看到有 Filter,同时 Filter 里还继续有封装。Invoker 里 dubboInvoker,还有其他的 filter,filter 里边又有其他的 filter,filter 里又有 Invoker,Invoker。相当于最终真正的目标方法把所有的 filter 都解除以后,就叫 dubboInvoke。

一步一步进入,来到一个 filter(protocolfilter),继续进入,在:return invoker.invoke(invocation)又要执行再来进入,还是 filter 来进入,进入以后呢,Result result=invoker.invoke(invacation),Invoker 又要执行,再来进入,是刚才那个 future filter,然后返回,再进入,来到 monitor 的 filter,相当于各种 filter 层层过滤。

在 return invoker.invoke(invocation )继续执行,接下来到抽象的 invoker 里。

doInvoker 继续执行,最终来到 dubboInvoker(打一个断点),这才是真正执行功能的。要执行哪个方法?

拿到方法的信息,将来它会拿到客户端,客户端在服务引用的时候暴露过一次,客户端相当于保存了要连上哪个服务。当前要连向

20882,找到客户端以后会发现有一个 currentClient.request,相当于客户端发起请求,发起请求以后获取请求的结果,然后返回.相当于就来到底层的调用,也就是已经来到了这个客户端了。客户端要进行调用,那就要进行底层的通信。发送请求, stepinto 进入,拿到客户端,发送请求进来,拿到通道发送请求,模拟出一个请求对象。

Req.setVersion(“2.0,0”)

Req.setTwoWay(true)

Req.setDate(request)

然后,给通道发送出去,这就是底层的请求发送方法。发送以后有一个返回,返回以后,get 得到最终请求的这个结果。这儿还有一个超时属性或方法执行超时,就会报错,超时了再来放行放。有第二次重试,换一个机器再试。

发现没有出错,那直接就出来了,出来拿到响应结果。在响应结果里,Response  result 里封装了远程调用的两个返回的结果对象,拿到这个结果对象以后把这个封装一下,再来返回。整个 dubbo 一执行完以后,把整个结果还有进行各种解码编解码,然后返回,返回完了以后整个相当于就调用完了。最后是控制台进行功能打印。以上就是全部的步骤。


二、总结

调用步骤,主要就是这张原理图。

image.pngimage.png

代理对象如果有要做其他功能,有 filter 介入。否则没有的话,用 Cluster,是来封装多个 Invoker 的,如果有多个 Invoker 的情况下,还能选一种负载均衡机制,而且调用错了,还会有重试。

负载均衡在调动期间还有其他的 filter 来介入,统计一些信息数据,当然最终真正执行功能的,由于是用 dubbo 协议来远程调用,所以说是 dubboInvoker 来进行调用。

而调用的底层是 client 发送请求,在client 的底层,就是用 Netty 的客户端连接目标端口的服务器来发送请求。服务器请求收到数据以后,就要解码来整个返回数据。

由代理对象交还。所以这是整个的调用完成。

相关实践学习
SLB负载均衡实践
本场景通过使用阿里云负载均衡 SLB 以及对负载均衡 SLB 后端服务器 ECS 的权重进行修改,快速解决服务器响应速度慢的问题
负载均衡入门与产品使用指南
负载均衡(Server Load Balancer)是对多台云服务器进行流量分发的负载均衡服务,可以通过流量分发扩展应用系统对外的服务能力,通过消除单点故障提升应用系统的可用性。 本课程主要介绍负载均衡的相关技术以及阿里云负载均衡产品的使用方法。
相关文章
|
6月前
|
存储 缓存 测试技术
微服务注册中心的原理和实现方式
【2月更文挑战第19天】注册中心可以说是实现服务化的关键,因为服务化之后,服务提供者和服务消费者不在同一个进程中运行,实现了解耦,这就需要一个纽带去连接服务提供者和服务消费者,而注册中心就正好承担了这一角色。
|
6月前
|
存储 消息中间件 缓存
微服务配置中心功能实现
【2月更文挑战第9天】配置中心的思路就是把服务的各种配置,如代码里配置的各种参数、服务降级的开关甚至依赖的资源等都在一个地方统一进行管理。
|
前端开发 Java 关系型数据库
【SpringBoot】微服务学习笔记七:微服务中异步调用数据提交数据库的问题
【SpringBoot】微服务学习笔记七:微服务中异步调用数据提交数据库的问题
619 0
【SpringBoot】微服务学习笔记七:微服务中异步调用数据提交数据库的问题
|
3月前
|
缓存 Java Maven
SpringCloud基于Eureka的服务治理架构搭建与测试:从服务提供者到消费者的完整流程
Spring Cloud微服务框架中的Eureka是一个用于服务发现和注册的基础组件,它基于RESTful风格,为微服务架构提供了关键的服务注册与发现功能。以下是对Eureka的详细解析和搭建举例。
|
网络协议 算法
一次完整的 RPC 流程
一次完整的 RPC 流程 因为 RPC 是远程调用,首先会涉及网络通信, 又因为 RPC 用于业务系统之间的数据交互,要保证数据传输的可靠性,所以它一般默认采用 TCP 来实现网络数据传输。 网络传输的数据必须是二进制数据,可是在 RPC 框架中,调用方请求的出入参数都是对象,对象不能直接在网络中传输,所以需要提前把对象转成可传输的二进制数据,转换算法还要可逆,这个过程就叫“序列化”和“反序列化”。
345 0
一次完整的 RPC 流程
|
负载均衡 监控 前端开发
(十一)、OpenFegin服务调用
(十一)、OpenFegin服务调用
|
小程序 Java 关系型数据库
开发订单微服务与注册调用|学习笔记(二)
快速学习开发订单微服务与注册调用
开发订单微服务与注册调用|学习笔记(二)
|
小程序 Java API
开发订单微服务与注册调用|学习笔记(一)
快速学习开发订单微服务与注册调用
开发订单微服务与注册调用|学习笔记(一)
|
Java 数据库 开发者
微服务调用-上|学习笔记
快速学习微服务调用-上
微服务调用-上|学习笔记
|
Java 开发者 微服务
微服务调用-下|学习笔记
快速学习微服务调用-下
微服务调用-下|学习笔记
下一篇
无影云桌面