dubbo 源码分析汇总

3.1 Dubbo 内核解剖

dubbo 源码分析 1 之 架构原理探索
dubbo 源码分析 2 之 内核 SPI 实现
dubbo 源码分析 3 之 动态编译
dubbo 源码分析 4 之 与 Spring 集成
dubbo 源码分析 5 之 SPI 分析

3.2 Dubbo 服务发布原理解剖

dubbo 源码分析 6 之 服务暴露概述
dubbo 源码分析 7 之 服务本地暴露
dubbo 源码分析 8 之 服务远程暴露 (上)
dubbo 源码分析 9 之 服务远程暴露 (中)
dubbo 源码分析 10 之 服务远程暴露 (下)

3.3 Dubbo 服务引用原理解剖

dubbo 源码分析 11 之 服务引用
dubbo 源码分析 12 之 Listener & Filter

3.4 Dubbo 集群容错的设计解剖

dubbo 源码分析 13 之 集群容错 Invoke
dubbo 源码分析 14 – 集群容错之 Directory
dubbo 源码分析 15 – 集群容错之 Route
dubbo 源码分析 16 – 集群容错之 LoadBalance
dubbo 源码分析 17 – 集群容错总结

3.5 Dubbo 服务治理设计解剖

dubbo 源码分析 18 – 服务监控
dubbo 源码分析 19 – 服务治理

3.6 Dubbo 网络通信架构解剖

dubbo 源码分析 20 – 远程调用概述
dubbo 源码分析 21 – 远程通信 netty
dubbo 源码分析 22 – consumer 发送与接收原理
dubbo 源码分析 23 – provider 接收与发送原理
dubbo 源码分析 24 – 调用核心 Invoke

3.7 Dubbo 网络通信编解码解剖

dubbo 源码分析 25 – 序列化与反序列化
dubbo 源码分析 26 – 网络编解码 参考文章：

  1. public class ConsumerApi {
  3.     public static void main(String[] args) {
  4.         ReferenceConfig<UserService> reference = new ReferenceConfig<>();
  5.         reference.setApplication(new ApplicationConfig("api-consumer"));
  6.         reference.setRegistry(new RegistryConfig("zookeeper://127.0.0.1:2181"));
  7.         reference.setInterface(UserService.class);
  8.         UserService orderService = reference.get();
  10.         String username = orderService.getUsername();
  11.         System.out.println("result: " + username);
  12.     }
  13. }
  14. public class ReferenceConfig<T> extends AbstractReferenceConfig {
  15.     public synchronized T get() {
  16.             if (destroyed) {
  17.                 throw new IllegalStateException("Already destroyed!");
  18.             }
  19.             if (ref == null) {
  20.                 init();
  21.             }
  22.             return ref;
  23.         }
  24. }

image.png

  1. public class ReferenceConfig<T> extends AbstractReferenceConfig {
  2.       ... 
  3.      private T createProxy(Map<String, String> map) {
  4.         URL tmpUrl = new URL("temp", "localhost", 0, map);
  5.         final boolean isJvmRefer;
  6.         if (isInjvm() == null) {
  7.             if (url != null && url.length() > 0) { // if a url is specified, don't do local reference
  8.                 isJvmRefer = false;
  9.             } else if (InjvmProtocol.getInjvmProtocol().isInjvmRefer(tmpUrl)) {
  10.                 // by default, reference local service if there is
  11.                 isJvmRefer = true;
  12.             } else {
  13.                 isJvmRefer = false;
  14.             }
  15.         } else {
  16.             isJvmRefer = isInjvm().booleanValue();
  17.         }
  19.         if (isJvmRefer) {
  20.             URL url = new URL(Constants.LOCAL_PROTOCOL, NetUtils.LOCALHOST, 0, interfaceClass.getName()).addParameters(map);
  21.             invoker = refprotocol.refer(interfaceClass, url);
  22.             if (logger.isInfoEnabled()) {
  23.                 logger.info("Using injvm service " + interfaceClass.getName());
  24.             }
  25.         } else {
  26.             if (url != null && url.length() > 0) { // user specified URL, could be peer-to-peer address, or register center's address.
  27.                 String[] us = Constants.SEMICOLON_SPLIT_PATTERN.split(url);
  28.                 if (us != null && us.length > 0) {
  29.                     for (String u : us) {
  30.                         URL url = URL.valueOf(u);
  31.                         if (url.getPath() == null || url.getPath().length() == 0) {
  32.                             url = url.setPath(interfaceName);
  33.                         }
  34.                         if (Constants.REGISTRY_PROTOCOL.equals(url.getProtocol())) {
  35.                             urls.add(url.addParameterAndEncoded(Constants.REFER_KEY, StringUtils.toQueryString(map)));
  36.                         } else {
  37.                             urls.add(ClusterUtils.mergeUrl(url, map));
  38.                         }
  39.                     }
  40.                 }
  41.             } else { // assemble URL from register center's configuration
  42.                 List<URL> us = loadRegistries(false);
  43.                 if (us != null && !us.isEmpty()) {
  44.                     for (URL u : us) {
  45.                         URL monitorUrl = loadMonitor(u);
  46.                         if (monitorUrl != null) {
  47.                             map.put(Constants.MONITOR_KEY, URL.encode(monitorUrl.toFullString()));
  48.                         }
  49.                         urls.add(u.addParameterAndEncoded(Constants.REFER_KEY, StringUtils.toQueryString(map)));
  50.                     }
  51.                 }
  52.                 if (urls.isEmpty()) {
  53.                     throw new IllegalStateException("No such any registry to reference " + interfaceName + " on the consumer " + NetUtils.getLocalHost() + " use dubbo version " + Version.getVersion() + ", please config <dubbo:registry address=\"...\" /> to your spring config.");
  54.                 }
  55.             }
  57.             if (urls.size() == 1) {
  58.                 invoker = refprotocol.refer(interfaceClass, urls.get(0));
  59.             } else {
  60.                 List<Invoker<?>> invokers = new ArrayList<Invoker<?>>();
  61.                 URL registryURL = null;
  62.                 for (URL url : urls) {
  63.                     invokers.add(refprotocol.refer(interfaceClass, url));
  64.                     if (Constants.REGISTRY_PROTOCOL.equals(url.getProtocol())) {
  65.                         registryURL = url; // use last registry url
  66.                     }
  67.                 }
  68.                 if (registryURL != null) { // registry url is available
  69.                     // use AvailableCluster only when register's cluster is available
  70.                     URL u = registryURL.addParameter(Constants.CLUSTER_KEY, AvailableCluster.NAME);
  71.                     invoker = cluster.join(new StaticDirectory(u, invokers));
  72.                 } else { // not a registry url
  73.                     invoker = cluster.join(new StaticDirectory(invokers));
  74.                 }
  75.             }
  76.         }
  78.         Boolean c = check;
  79.         if (c == null && consumer != null) {
  80.             c = consumer.isCheck();
  81.         }
  82.         if (c == null) {
  83.             c = true; // default true
  84.         }
  85.         if (c && !invoker.isAvailable()) {
  86.             throw new IllegalStateException("Failed to check the status of the service " + interfaceName + ". No provider available for the service " + (group == null ? "" : group + "/") + interfaceName + (version == null ? "" : ":" + version) + " from the url " + invoker.getUrl() + " to the consumer " + NetUtils.getLocalHost() + " use dubbo version " + Version.getVersion());
  87.         }
  88.         if (logger.isInfoEnabled()) {
  89.             logger.info("Refer dubbo service " + interfaceClass.getName() + " from url " + invoker.getUrl());
  90.         }
  91.         // create service proxy
  92.         return (T) proxyFactory.getProxy(invoker);
  93.     }
  94. }