dubbo服务引用创建Invoker代理对象

 更新时间:2023年08月16日 11:24:25   作者:包月星  
这篇文章主要为大家介绍了dubbo服务引用创建Invoker代理对象示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

创建Invoker代理

ReferenceConfig#createProxy方法的结尾处,将FailoverClusterInvoker创建DemoService接口的动态代理。

proxyFactory.getProxy(invoker);

proxyFactory也是一个带有Adaptive注解方法的SPI类。

默认实现JavassistProxyFactory

@SPI("javassist")
public interface ProxyFactory {
    /**
     * create proxy.
     *
     * @param invoker
     * @return proxy
     */
    @Adaptive({Constants.PROXY_KEY})
    <T> T getProxy(Invoker<T> invoker) throws RpcException;
    /**
     * create invoker.
     *
     * @param <T>
     * @param proxy
     * @param type
     * @param url
     * @return invoker
     */
    @Adaptive({Constants.PROXY_KEY})
    <T> Invoker<T> getInvoker(T proxy, Class<T> type, URL url) throws RpcException;
}

在JavassistProxyFactory#getProxy中

这个地方生成代理的方法非常类似Java的原生的动态代理java.lang.reflect.Proxy,大家感兴趣的可以自己去看一下,这个地方暂不继续写下去了。

InvokerInvocationHandler

我们主要看一下InvokerInvocationHandler。

这样在执行接口的方法时,将方法名与入参构造成一个RpcInvocation作为入参,传递到Invoker的invoke函数中去。

public class InvokerInvocationHandler implements InvocationHandler {
    private final Invoker<?> invoker;
    public InvokerInvocationHandler(Invoker<?> handler) {
        this.invoker = handler;
    }
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        String methodName = method.getName();
        Class<?>[] parameterTypes = method.getParameterTypes();
        if (method.getDeclaringClass() == Object.class) {
            return method.invoke(invoker, args);
        }
        if ("toString".equals(methodName) && parameterTypes.length == 0) {
            return invoker.toString();
        }
        if ("hashCode".equals(methodName) && parameterTypes.length == 0) {
            return invoker.hashCode();
        }
        if ("equals".equals(methodName) && parameterTypes.length == 1) {
            return invoker.equals(args[0]);
        }
        return invoker.invoke(new RpcInvocation(method, args)).recreate();
    }
}

总结

我们都说,使用RPC框架时,调用外部服务就像调用本地服务一样方便,那么如何实现服务接口的注入的呢?本文真是从这个角度出发,讲解了dubbo服务引用时,是怎么注入接口的,并讲解了dubbo是通过Invoker调用外部服务的,更多关于dubbo创建Invoker代理对象的资料请关注脚本之家其它相关文章!

相关文章

  • Docker部署ElasticSearch和ElasticSearch-Head的实现

    Docker部署ElasticSearch和ElasticSearch-Head的实现

    这篇文章主要介绍了Docker部署ElasticSearch和ElasticSearch-Head的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-12-12
  • Docker搭建Skywalking的实现示例

    Docker搭建Skywalking的实现示例

    本文主要介绍了Docker搭建Skywalking的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2025-02-02
  • ubuntu vps安装docker报错:Cannot connect to the Docker daemon at unix:///var/run/docker.sock.问题解决

    ubuntu vps安装docker报错:Cannot connect to t

    这篇文章主要介绍了解决ubuntu vps安装docker时报错:Cannot connect to the Docker daemon at unix:///var/run/docker.sock.问题的相关资料,文中介绍非常详细,需要的朋友可以参考借鉴,下面来一起看看吧。
    2017-04-04
  • Docker镜像+nginx 部署 vue 项目的方法

    Docker镜像+nginx 部署 vue 项目的方法

    这篇文章主要介绍了Docker镜像+nginx 部署 vue 项目的方法,帮助大家更好的使用docke镜像,感兴趣的朋友可以了解下
    2020-10-10
  • 使用Docker部署前后端分离项目的完整步骤

    使用Docker部署前后端分离项目的完整步骤

    刚刚接触基础的运维工作,采用的是docker部署的方式,下面这篇文章主要给大家介绍了关于使用Docker部署前后端分离项目的相关资料,文中通过图文介绍的非常详细,需要的朋友可以参考下
    2023-01-01
  • docker搭建redis哨兵集群并且整合springboot的实现

    docker搭建redis哨兵集群并且整合springboot的实现

    本文主要介绍了docker搭建redis哨兵集群并且整合springboot的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2022-07-07
  • IDEA整合Docker的实现步骤

    IDEA整合Docker的实现步骤

    本文主要介绍了IDEA整合Docker的实现步骤,主要设置了远程连接,插件以及配置信息等,具有一定的参考价值,感兴趣的可以了解一下
    2023-10-10
  • 使用Docker多阶段构建来减小镜像大小的方法

    使用Docker多阶段构建来减小镜像大小的方法

    这篇文章主要介绍了使用Docker多阶段构建来减小镜像大小的方法,适用于需要在 Dockerfile 中构建程式,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-12-12
  • 在Docker中安装Elasticsearch7.6.2的教程

    在Docker中安装Elasticsearch7.6.2的教程

    这篇文章主要介绍了在Docker中安装Elasticsearch7.6.2的教程,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2020-11-11
  • 使用Portainer部署Docker容器的项目实践

    使用Portainer部署Docker容器的项目实践

    这篇文章主要介绍了使用Portainer部署Docker容器的项目实践,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2021-04-04

最新评论