简单读读源码

Posted Codorld

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了简单读读源码相关的知识,希望对你有一定的参考价值。

  1. 消费者端dubbo的yml配置

    dubbo:
      consumer:
        timeout: 300000
      protocol:
        name: dubbo
        port: -1
      cloud:
        subscribed-services: order-server
    #    subscribed-services: hello-server,account-server,storage-server,order-server
    
  2. 按住ctrl + 鼠标左击subscribed-services如下图:

    按住鼠标左击

  3. 这里是对应的setter方法,上面找到定义地方

    	/**
    	 * All services of Dubbo.
    	 */
    	public static final String ALL_DUBBO_SERVICES = "*";
    
    	/**
    	 * The subscribed services, the default value is "*". The multiple value will use
    	 * comma(",") as the separator.
    	 *
    	 * @see #ALL_DUBBO_SERVICES
    	 */
    	private String subscribedServices = ALL_DUBBO_SERVICES;
    

    读一读就知道答案了。默认为*,多个值时候用,隔开。


    接下来,走走最表面的流程,就是看看怎么处理我们输入的数据的,至于是怎么找到提供者的,先不管。

  4. 光标点到类DubboCloudProperties上面,这里ctrl+单击是点不进去的,但是你点一下有提醒

    No usages found in Project Files 
    Press Ctrl+Alt+F7 again to search in \'Project and Libraries
    
  5. 跟着提醒,Ctrl+Alt+F7,如果提醒关闭了,就双击F7,出来下图。

    ctrl+alt+f7

  6. 直接回车,就是高亮的这一行。回去复制ubscribedServices,不要开头的s,不管大写还是小写,Ctrl+F搜出来看看。

  7. 通过点击向上向下的箭头,或者F3(下一个)/Shift+F3(上一个)来读一读源码。这里我们看到他在237行时候进行了初始化。

    初始化

  8. 老样子,ctrl+单击initSubscribedServices()方法。

    初始化方法

    读一下,如果ALL_DUBBO_SERVICES等于我们输入的提供者,就是输出巴拉巴拉。

  9. 那么ALL_DUBBO_SERVICES是啥,ctrl点,发现又跳回第一个文件了:

    @ConfigurationProperties(prefix = CONFIG_PROPERTY_PREFIX)
    public class DubboCloudProperties {
    
    	/**
    	 * All services of Dubbo.
    	 */
    	public static final String ALL_DUBBO_SERVICES = "*";
        
        // 这里是默认为*,如果set方法没有执行,那么get时候获得的就是*
        private String subscribedServices = ALL_DUBBO_SERVICES;
        
        /* ... */
        
    }
    
  10. 现在测试一下输出那个东西,启动一个提供者,然后消费者订阅的提供者写成*或者注释掉。启动消费者。

    查看日志:

    2021-05-27 16:28:24.950  WARN 6564 --- [client.listener] a.c.d.m.r.DubboServiceMetadataRepository : Current application will subscribe all services(size:20) in registry, a lot of memory and CPU cycles may be used, thus it\'s strongly recommend you using the externalized property \'dubbo.cloud.subscribed-services\' to specify the services
    

    与步骤8中一致。

  11. 接着读else,如果我们填入内容了,就subscribedServices()后加入到那个集合中

    newSubscribedServices.addAll(dubboCloudProperties.subscribedServices());
    

    ctrl点subscribedServices(),然后发现又转到第一个文件了:

    转回来了

    再继续读一下:使用commaDelimitedListToStringArray将我们输入的东西转化了字符串数组,处理返回。

  12. 我们来看看commaDelimitedListToStringArray怎么处理的,找到导入它的地方:

    import static org.springframework.util.StringUtils.commaDelimitedListToStringArray;

    然后ctrl点:

    	/**
    	 * Convert a comma delimited list (e.g., a row from a CSV file) into an
    	 * array of strings.
    	 * @param str the input {@code String} (potentially {@code null} or empty)
    	 * @return an array of strings, or the empty array in case of empty input
    	 */
    	public static String[] commaDelimitedListToStringArray(@Nullable String str) {
    		return delimitedListToStringArray(str, ",");
    	}
    

    这里与标题3.中The multiple value will use comma(",") as the separator.对应。

  13. 结论:

    • 不写或者*会订阅所有的。

    • 写多就使用,隔开。

以上是关于简单读读源码的主要内容,如果未能解决你的问题,请参考以下文章

Druid核心源码解析--DruidDataSource

Druid核心源码解析--DruidDataSource

吹爆!阿里新产Spring源码高级笔记,原来看懂源码如此简单

Druid核心源码解析--DruidDataSource

真强啊!建议每一位Java程序员都读读Dubbo心跳设计的源码...

优秀程序设计的原则(可以多读读)