我的书签
添加书签
移除书签3.1 处理配置
Dubbo 提供了丰富的配置，用于调整和优化框架行为，性能等。Dubbo 在引用或导出服务时，首先会对这些配置进行检查和处理，以保证配置的正确性。配置解析逻辑封装在 ReferenceConfig 的 init 方法中，下面进行分析。
private void init() {// 避免重复初始化if (initialized) {return;}initialized = true;// 检测接口名合法性if (interfaceName == null || interfaceName.length() == 0) {throw new IllegalStateException("interface not allow null!");}// 检测 consumer 变量是否为空，为空则创建checkDefault();appendProperties(this);if (getGeneric() == null && getConsumer() != null) {// 设置 genericsetGeneric(getConsumer().getGeneric());}// 检测是否为泛化接口if (ProtocolUtils.isGeneric(getGeneric())) {interfaceClass = GenericService.class;} else {try {// 加载类interfaceClass = Class.forName(interfaceName, true, Thread.currentThread().getContextClassLoader());} catch (ClassNotFoundException e) {throw new IllegalStateException(e.getMessage(), e);}checkInterfaceAndMethods(interfaceClass, methods);}// -------------------------------✨ 分割线1 ✨------------------------------// 从系统变量中获取与接口名对应的属性值String resolve = System.getProperty(interfaceName);String resolveFile = null;if (resolve == null || resolve.length() == 0) {// 从系统属性中获取解析文件路径resolveFile = System.getProperty("dubbo.resolve.file");if (resolveFile == null || resolveFile.length() == 0) {// 从指定位置加载配置文件File userResolveFile = new File(new File(System.getProperty("user.home")), "dubbo-resolve.properties");if (userResolveFile.exists()) {// 获取文件绝对路径resolveFile = userResolveFile.getAbsolutePath();}}if (resolveFile != null && resolveFile.length() > 0) {Properties properties = new Properties();FileInputStream fis = null;try {fis = new FileInputStream(new File(resolveFile));// 从文件中加载配置properties.load(fis);} catch (IOException e) {throw new IllegalStateException("Unload ..., cause:...");} finally {try {if (null != fis) fis.close();} catch (IOException e) {logger.warn(e.getMessage(), e);}}// 获取与接口名对应的配置resolve = properties.getProperty(interfaceName);}}if (resolve != null && resolve.length() > 0) {// 将 resolve 赋值给 urlurl = resolve;}// -------------------------------✨ 分割线2 ✨------------------------------if (consumer != null) {if (application == null) {// 从 consumer 中获取 Application 实例，下同application = consumer.getApplication();}if (module == null) {module = consumer.getModule();}if (registries == null) {registries = consumer.getRegistries();}if (monitor == null) {monitor = consumer.getMonitor();}}if (module != null) {if (registries == null) {registries = module.getRegistries();}if (monitor == null) {monitor = module.getMonitor();}}if (application != null) {if (registries == null) {registries = application.getRegistries();}if (monitor == null) {monitor = application.getMonitor();}}// 检测 Application 合法性checkApplication();// 检测本地存根配置合法性checkStubAndMock(interfaceClass);// -------------------------------✨ 分割线3 ✨------------------------------Map<String, String> map = new HashMap<String, String>();Map<Object, Object> attributes = new HashMap<Object, Object>();// 添加 side、协议版本信息、时间戳和进程号等信息到 map 中map.put(Constants.SIDE_KEY, Constants.CONSUMER_SIDE);map.put(Constants.DUBBO_VERSION_KEY, Version.getProtocolVersion());map.put(Constants.TIMESTAMP_KEY, String.valueOf(System.currentTimeMillis()));if (ConfigUtils.getPid() > 0) {map.put(Constants.PID_KEY, String.valueOf(ConfigUtils.getPid()));}// 非泛化服务if (!isGeneric()) {// 获取版本String revision = Version.getVersion(interfaceClass, version);if (revision != null && revision.length() > 0) {map.put("revision", revision);}// 获取接口方法列表，并添加到 map 中String[] methods = Wrapper.getWrapper(interfaceClass).getMethodNames();if (methods.length == 0) {map.put("methods", Constants.ANY_VALUE);} else {map.put("methods", StringUtils.join(new HashSet<String>(Arrays.asList(methods)), ","));}}map.put(Constants.INTERFACE_KEY, interfaceName);// 将 ApplicationConfig、ConsumerConfig、ReferenceConfig 等对象的字段信息添加到 map 中appendParameters(map, application);appendParameters(map, module);appendParameters(map, consumer, Constants.DEFAULT_KEY);appendParameters(map, this);// -------------------------------✨ 分割线4 ✨------------------------------String prefix = StringUtils.getServiceKey(map);if (methods != null && !methods.isEmpty()) {// 遍历 MethodConfig 列表for (MethodConfig method : methods) {appendParameters(map, method, method.getName());String retryKey = method.getName() + ".retry";// 检测 map 是否包含 methodName.retryif (map.containsKey(retryKey)) {String retryValue = map.remove(retryKey);if ("false".equals(retryValue)) {// 添加重试次数配置 methodName.retriesmap.put(method.getName() + ".retries", "0");}}// 添加 MethodConfig 中的“属性”字段到 attributes// 比如 onreturn、onthrow、oninvoke 等appendAttributes(attributes, method, prefix + "." + method.getName());checkAndConvertImplicitConfig(method, map, attributes);}}// -------------------------------✨ 分割线5 ✨------------------------------// 获取服务消费者 ip 地址String hostToRegistry = ConfigUtils.getSystemProperty(Constants.DUBBO_IP_TO_REGISTRY);if (hostToRegistry == null || hostToRegistry.length() == 0) {hostToRegistry = NetUtils.getLocalHost();} else if (isInvalidLocalHost(hostToRegistry)) {throw new IllegalArgumentException("Specified invalid registry ip from property..." );}map.put(Constants.REGISTER_IP_KEY, hostToRegistry);// 存储 attributes 到系统上下文中StaticContext.getSystemContext().putAll(attributes);// 创建代理类ref = createProxy(map);// 根据服务名，ReferenceConfig，代理类构建 ConsumerModel，// 并将 ConsumerModel 存入到 ApplicationModel 中ConsumerModel consumerModel = new ConsumerModel(getUniqueServiceName(), this, ref, interfaceClass.getMethods());ApplicationModel.initConsumerModel(getUniqueServiceName(), consumerModel);}
上面的代码很长，做的事情比较多。这里根据代码逻辑，对代码进行了分块，下面我们一起来看一下。
首先是方法开始到分割线1之间的代码。这段代码主要用于检测 ConsumerConfig 实例是否存在，如不存在则创建一个新的实例，然后通过系统变量或 dubbo.properties 配置文件填充 ConsumerConfig 的字段。接着是检测泛化配置，并根据配置设置 interfaceClass 的值。接着来看分割线1到分割线2之间的逻辑。这段逻辑用于从系统属性或配置文件中加载与接口名相对应的配置，并将解析结果赋值给 url 字段。url 字段的作用一般是用于点对点调用。继续向下看，分割线2和分割线3之间的代码用于检测几个核心配置类是否为空，为空则尝试从其他配置类中获取。分割线3与分割线4之间的代码主要用于收集各种配置，并将配置存储到 map 中。分割线4和分割线5之间的代码用于处理 MethodConfig 实例。该实例包含了事件通知配置，比如 onreturn、onthrow、oninvoke 等。分割线5到方法结尾的代码主要用于解析服务消费者 ip，以及调用 createProxy 创建代理对象。关于该方法的详细分析，将会在接下来的章节中展开。
