Dubbo服务引用

一、服务引用的时机

1、ReferenceBean#afterPropertiesSet 方法时引用服务

2、ReferenceBean 对应的服务被注入到其他类中时引用

二、服务引用流程图:

服务引用流程:

  1. 参数检查,把ReferenceBean⾥的参数值设置为高优先级

  1. 调用init方法,生成ref

  1. 创建一个map对象,放入消费者一些参数

  1. 如果是本地引用,构建本地协议URL进行服务引入

如果是一个注册中心,直接调用Protocol#refer,得到一个Invoker对象

如果是多注册中心,遍历每个注册中心,分别调用Protocol#refer,封装所有Invokers,经过路由负载均衡,得到一个Invoker对象

  1. PROXY_FACTORY.getProxy(invoker) 传入invoker,得到一个代理对象

三、生成的代理对象

生成的代理对象:

public class proxy0 implements ClassGenerator.DC,EchoService,DemoService {
    public static Method[] methods;
    private InvocationHandler handler;

    public String sayHello(String string) {
        Object[] objectArray = new Object[]{string};
        Object object = this.handler.invoke(this, methods[0], objectArray);
        return (String)object;
    }

    public String sayHello(String string, String string2) {
        Object[] objectArray = new Object[]{string, string2};
        Object object = this.handler.invoke(this, methods[1], objectArray);
        return (String)object;
    }

    public Object $echo(Object object) {
        Object[] objectArray = new Object[]{object};
        Object object2 = this.handler.invoke(this, methods[2], objectArray);
        return object2;
    }

    public proxy0() {
    }

refer方法的执行链:

总结:通过检查参数,创建map放入消费者的一些参数配置,把map转换成url,然后根据自适应调用REF_PROTOCOL.refer生成具体的invoker,在封装invoker得到代理类,发起调用时通过nettyClient进行连接。