简介

本篇将围绕Dubbo消费端的主流程进行讲解，其中会涉及到过滤器、容错、复杂均衡进行重点分析。

首先，我们需要认识几个重要的接口 Filter、Cluster、LoadBalance，分别对应过滤器、容错、复杂均衡。下面会这几个接口进行初步介绍。

过滤器（Filter）

//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//

package com.alibaba.dubbo.rpc;

import com.alibaba.dubbo.common.extension.SPI;

@SPI
public interface Filter {
    Result invoke(Invoker<?> var1, Invocation var2) throws RpcException;
}

一看就是Dubbo SPI的设计思想，实现类如下：

而他的配置文件如下：

负载均衡接口（LoadBalance）

//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//

package com.alibaba.dubbo.rpc.cluster;

import com.alibaba.dubbo.common.URL;
import com.alibaba.dubbo.common.extension.Adaptive;
import com.alibaba.dubbo.common.extension.SPI;
import com.alibaba.dubbo.rpc.Invocation;
import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.RpcException;
import java.util.List;

@SPI("random")
public interface LoadBalance {
    @Adaptive({"loadbalance"})
    <T> Invoker<T> select(List<Invoker<T>> var1, URL var2, Invocation var3) throws RpcException;
}

默认策略是随机策略，而他的实现类和对应的key为：

容错接口（Cluster）

//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//

package com.alibaba.dubbo.rpc.cluster;

import com.alibaba.dubbo.common.extension.Adaptive;
import com.alibaba.dubbo.common.extension.SPI;
import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.RpcException;

@SPI("failover")
public interface Cluster {
    @Adaptive
    <T> Invoker<T> join(Directory<T> var1) throws RpcException;
}

对应的实现类，以及key-value结构如下：

源码分析

客户端测试代码：

   @Test
    public void clientRpc() throws IOException
    {
        Protocol protocol = protocolLoader.getAdaptiveExtension();
        //代理
        ProxyFactory proxy = proxyLoader.getAdaptiveExtension();
        //消费服务
        Invoker<DemoService> referInvoker = protocol.refer(DemoService.class, registryUrl);
        DemoService service = proxy.getProxy(referInvoker);

        for (int i = 0;i < 5;i++){
            String result = service.sayHello(registryUrl.getProtocol()+"调用");
            System.out.println(result);
        }
        // 保证服务一直开着
//        System.in.read();

    }

1. 获取Invoker过程

我们知道，无论是 ProxyFactory 还是 Protocol，他两都是一个静态代理类，那么获取Invoker对象实际调用到的就是静态代理类的refer方法：

进入到RegistryProtocol类的getInvoker方法。其实，就是根据注册中心的registryURL和 Interface信息到注册中心中进行注册与订阅操作。我们使用的是zookeeper，那也就是zookeeper的发布与定于操作，不是本文的重点，在分析zookeeper的时候会重点分析。