dubbo源码实践-protocol层-invoker理解

Posted 2023-02-16 alf_cee

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了dubbo源码实践-protocol层-invoker理解相关的知识，希望对你有一定的参考价值。

1概述

Invoker官方解释：

Invoker 是实体域，它是 Dubbo 的核心模型，其它模型都向它靠扰，或转换成它，它代表一个可执行体，可向它发起 invoke 调用，它有可能是一个本地的实
现，也可能是一个远程的实现，也可能一个集群实现。

1.1 Invoker接口

通过源码可知Invoker接口不是SPI。可以调用invoke方法执行调用。

Invocation是参数，如：调用那个方法名称、参数的类型、参数的值是什么等信息。

1.2 Invoker的实现类

从下图展示了各个Invoker实现类的作用。

2 例子代码

2.1 调用本地的实现

想象一下应用场景：dubbo服务提供者会先把提供的功能封装到service中，然后配置到dubbo中(注解或xml文件)，dubbo就可以调用到这些service了。

问题：各个service的名称和方法都不同、参数也不一致，能用一种通用的方式掉用各个service吗？

解决方法：dubbo使用Invoker本地的实现来解决这个问题。

dubbo提供了两种实现方式JdkProxyFactory和JavassistProxyFactory。

2.1.1 JdkProxyFactory实现方式

InvokerTest类代码

package org.example.dubbo.invoker;
import org.apache.dubbo.common.URL;
import org.apache.dubbo.common.URLBuilder;
import org.apache.dubbo.rpc.*;
import org.apache.dubbo.rpc.proxy.jdk.JdkProxyFactory;
import org.example.test.protocol.AlfService;
import org.example.test.protocol.IAlfService;
/** 本地Invoker使用, 2022/12/29. */
public class InvokerTest 
    public static void main(String[] args) 
        //业务服务类
        AlfService alfService = new AlfService();
        //构造一个空的url
        URLBuilder urlBuilder = new URLBuilder();
        URL url = urlBuilder.build();
        //构造Invocation对象
        RpcInvocation rpcInvocation = new RpcInvocation();
        rpcInvocation.setMethodName("sayHolle");//指定调用的方法名
        Class<?>[] parameterTypes = new Class[1];//指定调用的方法的参数类型
        parameterTypes[0] = String.class;
        rpcInvocation.setParameterTypes(parameterTypes);
        Object[] args1 = new Object[1];//指定调用的方法的参数
        args1[0] = "alf";
        rpcInvocation.setArguments(args1);
        //创建ProxyFactory
        ProxyFactory proxyFactory = new JdkProxyFactory();
        //传入service实例，接口和URL获取Invoker实例
        Invoker<IAlfService> invoker = proxyFactory.getInvoker(alfService, IAlfService.class, url);
        //调用invoker实例
        Result result = invoker.invoke(rpcInvocation);
        //获取service方法返回值
        Object value = result.getValue();
        System.out.println(value);

AlfService类

package org.example.test.protocol;

/** 业务类 */
public class AlfService implements IAlfService
    @Override
    public String sayHolle(String hi) 
        System.out.println("AlfService call");
        return "hi " + hi;

运行结果，调用了service。

实现原理分析

不管什么service，通过proxyFactory.getInvoker获取到响应的Invoker实例，然后使用统一的invoke(Invocation invocation)方法来调用service。

JdkProxyFactory中的实现方式是通过java的反射实现的上述功能。

2.1.2 JavassistProxyFactory实现方式

只要把上面的代码替换成ProxyFactory proxyFactory = new JavassistProxyFactory(); 即可。

运行结果是一样的。

可以知道方式是通过javassist动态产生的一个Wrapper类的实现，然后编译、加载到JVM中。

产生的Wrapper实现的invokeMethod方法如下：

dubbo的默认实现是JavassistProxyFactory。因为性能更好。

2.2 远程调用

必须得有服务端才运行。这里就不演示了。参考DubboInvoker类实现。

下一篇会有例子。

2.3 集群的调用

集群的Invoker的继承关系如下图。

通过ClusterInvoker类的注释可以看到：

This is the final Invoker type referenced by the RPC proxy on Consumer side.
客户端使用该ClusterInvoker，并且是最外层的Invoker。

A ClusterInvoker holds a group of normal invokers, stored in a Directory, mapping to one Registry.
一个ClusterInvoker通过Directory持有一组普通的Invoker，Directory同时会对应一个注册(参考RegistryDirectory类)。

The ClusterInvoker implementation usually provides LB or HA policies, like FailoverClusterInvoker.
ClusterInvoker提供LB或者HA的功能，如FailoverClusterInvoker类。

In multi-registry subscription scenario, the final ClusterInvoker will referr to several sub ClusterInvokers, with each sub ClusterInvoker representing one Registry. Take ZoneAwareClusterInvoker as an example, it is specially customized for multi-registry use cases: first, pick up one ClusterInvoker, then do LB inside the chose Cluster。
在多注册中心订阅的场景下，一个最外层ClusterInvoker内部可以包含多个子ClusterInvoker，每个子ClusterInvoker代表的一个注册中心。可以参考ZoneAwareClusterInvoker类。