Dubbo是如何进行远程服务调用的？（源码流程跟踪）

首先会分析Dubbo是如何进行远程服务调用的，如果不了解dubbo的服务暴露和服务调用，请去看前两篇dubbo的文章，然后后面我还会说一下dubbo的SPI机制

当我们在使用@reference 注解的时候，来调用我们的提供者的Service对象的时候，Dubbo中的服务调用是怎么实现的

Dubbo的远程服务调用

（1）首选Dubbo是通过Poxy对象来生成一个代理对象的

  1. 具体实现是在ReferenceConfig对象中调用的private T createProxy(Map<String, String> map)方法的，这个方法中有三种生成Invoker对象的方式，第一种是通过本地JVM，第二种是通过URL对象是不是为空判断进行判断，然后如果为空就从注册中心获取这个Invoker对象，否则就是从ReferenceConfig中的URL中拿到
  2. 上面那个方法中还会通过获取到的Invoker这里的【生成Invoker的过程后面补充】的对象去通过ProxyFactory生成Poxy对象，代码为：return proxyFactory.getProxy(this.invoker);，这里proxyFactory其实就是
	//ProxyFactory接口的javassist扩展类JavassistProxyFactory的getProxy方法实现public <T> T getProxy(Invoker<T> invoker, Class<?>[] interfaces) {return Proxy.getProxy(interfaces).newInstance(new InvokerInvocationHandler(invoker));}
  1. 然后通过第2步的getPoxy()方法去动态代理生成代理Poxy对象
    public static Proxy getProxy(Class<?>... ics) {return getProxy(ClassHelper.getClassLoader(Proxy.class), ics);}/*** Get proxy.** @param cl  class loader.* @param ics interface class array. 可以实现多个接口* @return Proxy instance.*/public static Proxy getProxy(ClassLoader cl, Class<?>... ics) {if (ics.length > 65535)throw new IllegalArgumentException("interface limit exceeded");StringBuilder sb = new StringBuilder();for (int i = 0; i < ics.length; i++) {String itf = ics[i].getName();if (!ics[i].isInterface())throw new RuntimeException(itf + " is not a interface.");Class<?> tmp = null;try {tmp = Class.forName(itf, false, cl);} catch (ClassNotFoundException e) {}if (tmp != ics[i])throw new IllegalArgumentException(ics[i] + " is not visible from class loader");sb.append(itf).append(';');}// use interface class name list as key.// 用接口类名做key,多个接口以分号分开。String key = sb.toString();// get cache by class loader.// 缓存Map<String, Object> cache;synchronized (ProxyCacheMap) {cache = ProxyCacheMap.get(cl);if (cache == null) {cache = new HashMap<String, Object>();ProxyCacheMap.put(cl, cache);}}Proxy proxy = null;synchronized (cache) {do {Object value = cache.get(key);if (value instanceof Reference<?>) {//如果有存在引用对象，返回缓存对象。proxy = (Proxy) ((Reference<?>) value).get();if (proxy != null)return proxy;}//对象正在生成，线程挂起，等待if (value == PendingGenerationMarker) {try {cache.wait();} catch (InterruptedException e) {}} else {//放入正在生成标识cache.put(key, PendingGenerationMarker);break;}}while (true);}//类名称后自动加序列号 0,1,2,3...long id = PROXY_CLASS_COUNTER.getAndIncrement();String pkg = null;//ClassGenerator dubbo用javassist实现的工具类ClassGenerator ccp = null, ccm = null;try {ccp = ClassGenerator.newInstance(cl);Set<String> worked = new HashSet<String>();List<Method> methods = new ArrayList<Method>();for (int i = 0; i < ics.length; i++) {//检查包名称及不同包的修饰符if (!Modifier.isPublic(ics[i].getModifiers())) {String npkg = ics[i].getPackage().getName();if (pkg == null) {pkg = npkg;} else {if (!pkg.equals(npkg))throw new IllegalArgumentException("non-public interfaces from different packages");}}//代理类添加要实现的接口Class对象ccp.addInterface(ics[i]);for (Method method : ics[i].getMethods()) {//获取方法描述符，不同接口，同样的方法，只能被实现一次。String desc = ReflectUtils.getDesc(method);if (worked.contains(desc))continue;worked.add(desc);int ix = methods.size();//方法返回类型Class<?> rt = method.getReturnType();//方法参数类型列表Class<?>[] pts = method.getParameterTypes();//生成接口的实现代码，每个方法都一样StringBuilder code = new StringBuilder("Object[] args = new Object[").append(pts.length).append("];");for (int j = 0; j < pts.length; j++)code.append(" args[").append(j).append("] = ($w)$").append(j + 1).append(";");code.append(" Object ret = handler.invoke(this, methods[" + ix + "], args);");if (!Void.TYPE.equals(rt))code.append(" return ").append(asArgument(rt, "ret")).append(";");methods.add(method);ccp.addMethod(method.getName(), method.getModifiers(), rt, pts, method.getExceptionTypes(), code.toString());}}if (pkg == null)pkg = PACKAGE_NAME;// create ProxyInstance class.// 具体代理类名称，这里是类全名String pcn = pkg + ".proxy" + id;ccp.setClassName(pcn);ccp.addField("public static java.lang.reflect.Method[] methods;");ccp.addField("private " + InvocationHandler.class.getName() + " handler;");//创建构造函数ccp.addConstructor(Modifier.PUBLIC, new Class<?>[]{InvocationHandler.class}, new Class<?>[0], "handler=$1;");ccp.addDefaultConstructor();Class<?> clazz = ccp.toClass();//通过反射，把method数组放入，静态变量methods中，clazz.getField("methods").set(null, methods.toArray(new Method[0]));// create Proxy class.String fcn = Proxy.class.getName() + id;ccm = ClassGenerator.newInstance(cl);ccm.setClassName(fcn);ccm.addDefaultConstructor();//设置父类为抽象类，Proxy类子类，ccm.setSuperClass(Proxy.class);//生成实现它的抽象方法newInstance代码//new 的实例对象，是上面生成的代理类 pcnccm.addMethod("public Object newInstance(" + InvocationHandler.class.getName() + " h){ return new " + pcn + "($1); }");Class<?> pc = ccm.toClass();proxy = (Proxy) pc.newInstance();} catch (RuntimeException e) {throw e;} catch (Exception e) {throw new RuntimeException(e.getMessage(), e);} finally {// release ClassGeneratorif (ccp != null)ccp.release();if (ccm != null)ccm.release();synchronized (cache) {if (proxy == null)cache.remove(key);else//放入缓存，key:实现的接口名，value 代理对象，这个用弱引用，//当jvm gc时，会打断对实例对象的引用，对象接下来就等待被回收。cache.put(key, new WeakReference<Proxy>(proxy));cache.notifyAll();}}return proxy;}

（2）这里是进行补充上面的那个【Invoker的怎么生成的步骤】，看一下Invoker中都包含了什么信息这么重要，这里需要强调一下这个Invoker生成的过程和Dubbo服务的暴露和导出生成的Invoker不太一样

  1. invoker对象是通过 InvokerInvocationHandler构造方法传入，而InvokerInvocationHandler对象是由JavassistProxyFactory类getProxy(Invoker invoker, Class<?>[] interfaces)方法创建。
    这还要回到调用proxyFactory.getProxy(invoker);方法的地方，即ReferenceConfig类的createProxy(Map<String, String> map)方法中
  2. 所以这个Invoker其实是通过ReferenceConfig 中的createProxy（Map<String, String> map）方法来生成的Invoker对象，这个就是下面中使用到的对象refprotocol ，private static final Protocol refprotocol = (Protocol)ExtensionLoader.getExtensionLoader(Protocol.class).getAdaptiveExtension();
 if (urls.size() == 1) {//只有一个直连地址或一个注册中心配置地址//这里的urls.get(0)协议，可能是直连地址(默认dubbo协议）,也可能是regiter注册地址（zookeeper协议）//我们这里走的是注册中心，所以invoker = refprotocol.refer(interfaceClass, urls.get(0));//本例通过配置一个注册中心的形式(***看这里***)} else {//多个直连地址或者多个注册中心地址,甚至是两者的组合。List<Invoker<?>> invokers = new ArrayList<Invoker<?>>();URL registryURL = null;for (URL url : urls) {//创建invoker放入invokersinvokers.add(refprotocol.refer(interfaceClass, url));if (Constants.REGISTRY_PROTOCOL.equals(url.getProtocol())) {registryURL = url; // 多个注册中心，用最后一个registry url}}if (registryURL != null) { //有注册中心协议的URL，//对多个url,其中存在有注册中心的，写死用AvailableCluster集群策略//这其中包括直连和注册中心混合或者都是注册中心两种情况URL u = registryURL.addParameter(Constants.CLUSTER_KEY, AvailableCluster.NAME);invoker = cluster.join(new StaticDirectory(u, invokers));} else { // 多个直连的urlinvoker = cluster.join(new StaticDirectory(invokers));}}
  1. 上面的代码可以看出生成Invoker的有三种方式，
    • 第一种是refprotocol.refer(this.interfaceClass, (URL)，这里的接口用的是SPI机制的dubbo对应下面的那个@SPI注解=com.alibaba.dubbo.rpc.protocol.dubbo.DubboProtocol这一句，所以这一种主要是使用的是Dubbo直连的协议都会走这一层
    • 第二种是 cluster.join(new StaticDirectory(u, invokers));，这个是加了路由的负载均衡相关的，这一部分主要都是路由层的东西
    • 第三种是 this.invoker = cluster.join(new StaticDirectory(invokers));也是路由层的东西， 路由层：封装多个提供者的路由及负载均衡，并桥接注册中心，以 Invoker 为中心，扩展接口为 Cluster, Directory, Router, LoadBalance
@SPI("dubbo")
public interface Protocol {int getDefaultPort();@Adaptive<T> Exporter<T> export(Invoker<T> var1) throws RpcException;@Adaptive<T> Invoker<T> refer(Class<T> var1, URL var2) throws RpcException;void destroy();
}

因为Dubbo中在实现远程调用的时候其实是通过Poxy对象生成的Invoker对象，那么就先看一下Invoker的怎么生成的，里面都包含了什么信息？

  • 这里的invoker对象，通过InvokerInvocationHandler构造方法传入，而InvokerInvocationHandler对象是由JavassistProxyFactory类
    getProxy(Invoker invoker, Class<?>[] interfaces)方法创建

Dubbo中的SPI机制的使用和分析

在这里插入图片描述

参考文章：https://cloud.tencent.com/developer/article/1109459

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/555521.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

JAVA解析存储过程获取的对象_java 解析数据的存储过程的

JAVA解析存储过程获取的对象_java 解析数据的存储过程的

先定义枚举&#xff1a;public enum ProcParamType {IN,OUT}调用存储过程的描述public class ProcCallableDescriptor {private List procParams new ArrayList();public List getProcParams() {return procParams;}public void addProPram(ProcParam param) {procParams.add(…
阅读更多...
Redis五种数据类型及应用场景

Redis五种数据类型及应用场景

Redis五种数据类型及应用场景 MySqlMemcached架构的问题 实际MySQL是适合进行海量数据存储的&#xff0c;通过Memcached将热点数据加载到cache&#xff0c;加速访问&#xff0c;很多公司都曾经使用过这样的架构&#xff0c;但随着业务数据量的不断增加&#xff0c;和访问量的…
阅读更多...
轮询、长轮询与Web Socket的前端实现

轮询、长轮询与Web Socket的前端实现

Web Socket 应用场景:实现即时通讯:如股票交易行情分析、聊天室、在线游戏等&#xff0c;替代轮询和长轮询 轮询 轮询是在特定的的时间间隔&#xff08;如每1秒&#xff09;&#xff0c;由浏览器对服务器发出HTTP request&#xff0c;然后由服务器返回最新的数据给客户端的浏…
阅读更多...
java apt怎么用_java – APT和AOP在同一个项目中,使用Maven

java apt怎么用_java – APT和AOP在同一个项目中,使用Maven

我显然是唯一能够回答我自己问题的人.我已经使用Maven Antrun Plugin通过ant编译AspectJ.这是我的pom片段&#xff1a;maven-antrun-plugin1.4org.aspectjaspectjtools${aspectj.version}ajc-compileprocess-classesvalue"${project.basedir}/src/main/aspect" />…
阅读更多...
WebSocket介绍和Socket的区别

WebSocket介绍和Socket的区别

WebSocket介绍与原理 WebSocket protocol 是HTML5一种新的协议。它实现了浏览器与服务器全双工通信(full-duplex)。一开始的握手需要借助HTTP)请求完成。 ——百度百科 目的&#xff1a;即时通讯&#xff0c;替代轮询 应用场景&#xff1a;网站上的即时通讯是很常见的&#xf…
阅读更多...
python代码html显示数据_通过AJAX success方法以html格式显示数据

python代码html显示数据_通过AJAX success方法以html格式显示数据

我正在编写下面的代码&#xff0c;用json格式从数据库返回的html表中显示数据success : function(data){alert("declaring variable");var output"alert("creating output");output"" "" "REPORTSUITE_ID" "&q…
阅读更多...
WebSocket协议入门介绍

WebSocket协议入门介绍

文章目录WebSocket协议是什么WebSocket是应用层协议WebSocket与Http的区别为什么要使用WebSocket如何使用WebSocket客户端API在客户端使用WebSocket在服务端使用WebSocket反向代理对WebSocket的支持WebSocket协议是什么 WebSocket是应用层协议 WebSocket是基于TCP的应用层协议…
阅读更多...
远程ykvm 插件移值java_Centos7 命令行下kvm安装windows，linux

远程ykvm 插件移值java_Centos7 命令行下kvm安装windows，linux

查看是否支持egrep "svm|vmx" /proc/cpuinfo |uniq安装软件yum install libvirt -yyum -y install qemu-kvmsystemctl enable libvirtd && systemctl start libvirtd# 启动libvitd服务查看 ip add #查看是否有 virbr0网卡 yum install virt-installcentos7 例…
阅读更多...
Websocket——原理及基本属性和方法

Websocket——原理及基本属性和方法

Websocket——原理及基本属性和方法 初次接触 WebSocket 的人&#xff0c;都会问同样的问题&#xff1a;我们已经有了 HTTP 协议&#xff0c;为什么还需要另一个协议&#xff1f;它能带来什么好处&#xff1f; 答案很简单&#xff0c;因为 HTTP 协议有一个缺陷&#xff1a;通…
阅读更多...
php7.0扩展yac,php扩展之yac安装

php7.0扩展yac,php扩展之yac安装

git克隆$ git clone https://github.com/laruence/yac.git解压安装注意这里的php-config可能不一样查看php-config位置$whereis php编译安装$ cd yac$ phpize$ ./configure --with-php-config/usr/bin/php-config$ make$ make install修改php.ini,载入扩展,重启php-fpmextensio…
阅读更多...
springboot+websocket实现服务端、客户端

springboot+websocket实现服务端、客户端

一、引言 小编最近一直在使用springboot框架开发项目&#xff0c;毕竟现在很多公司都在采用此框架&#xff0c;之后小编也会陆续写关于springboot开发常用功能的文章。 什么场景下会要使用到websocket的呢&#xff1f; websocket主要功能就是实现网络通讯&#xff0c;比如说…
阅读更多...
输出有样式的php,PHP导出带样式的Excel

输出有样式的php,PHP导出带样式的Excel

工作中做导出的时候&#xff0c;需要导出自定义的表格或嫌弃导出的Excel格式太难看了。需要设置颜色、字号大小、加粗、合并单元格等等。Paste_Image.pngPHP代码&#xff1a;php/**导出文件return string*/public function export(){$file_name "成绩单-".date(&quo…
阅读更多...
java 实现websocket的两种方式

java 实现websocket的两种方式

简单说明 1.两种方式&#xff0c;一种使用tomcat的websocket实现&#xff0c;一种使用spring的websocket 2.tomcat的方式需要tomcat 7.x&#xff0c;JEE7的支持。 3.spring与websocket整合需要spring 4.x&#xff0c;并且使用了socketjs&#xff0c;对不支持websocket的浏览…
阅读更多...
php 地址传递,PHP引用符传递存储地址

php 地址传递,PHP引用符传递存储地址

关于php的引用(就是在变量或者函数、对象等前面加上&符号)的作用&#xff0c;我们先看下面这个程序。代码如下:$a 100; //声明变量a$b &$a; //声明变量b,引用自变量aecho "$a ";echo "$b ";$a; //变量a自增1echo "$a ";echo "$b …
阅读更多...
idea创建多模块Springboot项目、导入多模块、删除多模块

idea创建多模块Springboot项目、导入多模块、删除多模块

前言 在eclipse中有Workspace&#xff08;工作空间&#xff09;和 Project&#xff08;工程&#xff09;的概念在 IDEA中只有 Project&#xff08;工程&#xff09;和 Module&#xff08;模块&#xff09;的概念。这个地方刚开始用的时候会很容易理不清它们之间的关系。在eclip…
阅读更多...
php 高效缓存类,简单高效的文件缓存php类

php 高效缓存类,简单高效的文件缓存php类

简单高效的文件缓存php类class FileCache{public $keyPrefix ;public $cachePath ;public $cacheFileSuffix .bin;public $directoryLevel 1;public $gcProbability 10;public $fileMode;public $dirMode 0775;function __construct(){$this->cachePath HT::$cacheRo…
阅读更多...
Java四种访问权限

Java四种访问权限

java基础(七) java四种访问权限 引言 Java中的访问权限理解起来不难&#xff0c;但完全掌握却不容易&#xff0c;特别是4种访问权限并不是任何时候都可以使用。下面整理一下&#xff0c;在什么情况下&#xff0c;有哪些访问权限可以允许选择。 一、访问权限简介 访问权限控…
阅读更多...
php表单提取,php – 使用RegEx提取表单字段

php表单提取,php – 使用RegEx提取表单字段

使用正则表达式解析HTML可能不是最好的方法.您可以查看DOMDocument::loadHTML,这将允许您使用DOM方法处理HTML文档(例如,如果您知道这些,则使用XPath查询).您可能还想看一下Zend_Dom和Zend_Dom_Query,顺便说一句,如果您可以在应用程序中使用Zend Framework的某些部分,这是非常好…
阅读更多...
phpexcel.php实际应用,PHP操作excel的一个例子(原创)-PHP教程,PHP应用

phpexcel.php实际应用,PHP操作excel的一个例子(原创)-PHP教程,PHP应用

这是对于那些只喜欢简单处理一下excel朋友来说的//定义一个excel文件$workbook "c:/my documents/test.xls";$sheet "sheet1";//生成一个com对象$ex$ex new com("excel.sheet") or die ("连不上&#xff01;&#xff01;&#xff01;&qu…
阅读更多...
集成 websocket 的四种方案

集成 websocket 的四种方案

集成 websocket 的四种方案 1. 原生注解 pom.xml <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-websocket</artifactId> </dependency>WebSocketConfig package cn.coder4j.study.exampl…
阅读更多...
最新文章

Copyright @ 2022~2023