阿里巴巴

dubbo-Reference注解改进

2018-05-21  本文已影响482人  兴浩

1.dubbo服务过多引用的问题

1.1 dubbo服务以xml配置消费者

由于引用多个dubbo服务时,在未使用前无法得知需要使用哪个接口,如果以xml配置的形式来调用,应该如下代码

代码示例1

<dubbo:reference interface="com.xxx.xxx.xxxService" timeout="300000"/>

1.2 dubbo服务膨胀的问题

由于需求不断变更,引用的dubbo服务不断增多,这时候配置将会如下

代码示例2

<dubbo:reference interface="com.xxx.xxx.xxxService1" timeout="300000"/>
<dubbo:reference interface="com.xxx.xxx.xxxService2" timeout="300000"/>
<dubbo:reference interface="com.xxx.xxx.xxxService3" timeout="300000"/>
<dubbo:reference interface="com.xxx.xxx.xxxService4" timeout="300000"/>
<dubbo:reference interface="com.xxx.xxx.xxxService5" timeout="300000"/>
......

实际项目中引用的服务会更多,维护该xml的数量将非常庞大,不利于团队之间的合作开发

1.3 使用Reference注解的形式

使用注解后,就可以在实际情况下引用即可,非常方便

代码示例3

@Reference
private UserService userService;

2.Reference注解的问题

  1. 当需要配置某个模块的version和group时,希望能够统一修改,与配置中心绑定
  2. 使用注解时,当在父类使用该注解时不生效,因为Reference注解并未对父类方法和字段进行解析

代码示例4

@Reference(version = "1.0",group = "app")
private UserService userService;

@Reference(version = "userModule.version",group = "userModule.group")
private UserService userService;

//此为示例代码,Value注解应该能够理解
@Value("userModule.version")
private String version;

2.1 改造的切入点AnnotationBean

Reference注解由AnnotationBean进行解析,所以第一步是对AnnotationBean进行改造.

思路如下:

  1. 将version和group相关需要的全局配置改造成与配置中心相关联
  2. xml去除dubbo:annotation配置
  3. 同时对父类方法和字段进行解析

3.动态获取dubbo接口

有时候需要在某些场景,静态获取dubbo接口,就像Spring中ApplicationContext中getBean方法一样
实际其内部还是构造一个ReferenceBean对象

代码示例5

public static <T> T getDubboBean(Class<T> referenceClass,String version) {
    if (referenceClass == null) {
        throw new IllegalStateException("请输入接口类型");
    } else if (!referenceClass.isInterface()) {
        throw new IllegalStateException("The @Reference undefined interfaceClass or interfaceName, and the property type " + referenceClass.getName() + " is not a interface.");
    }
    String interfaceName = referenceClass.getName();
    String key = interfaceName;
    ReferenceBean<?> referenceConfig = referenceConfigs.get(key);
    if (referenceConfig == null) {
        referenceConfig = new ReferenceBean<Object>();
        referenceConfig.setInterfaceClass(referenceClass);
    }
    if (SpringContextUtil.getApplicationContext() != null) {
        referenceConfig.setApplicationContext(SpringContextUtil.getApplicationContext());
        try {
            referenceConfig.afterPropertiesSet();
        } catch (RuntimeException e) {
            throw (RuntimeException) e;
        } catch (Exception e) {
            throw new IllegalStateException(e.getMessage(), e);
        }
    }
    referenceConfigs.putIfAbsent(key, referenceConfig);
    referenceConfig = referenceConfigs.get(key);
    referenceConfig.setVersion(version);

    //获取配置中心配置
    version=SpringPropertiesUtil.getPropertiestValue("dubbo.common.version");
    String group=SpringPropertiesUtil.getPropertiestValue("dubbo.common.group");

    if(SysStringUtils.isNotEmpty(version))
    {
        referenceConfig.setVersion(version);
    }

    if(SysStringUtils.isNotEmpty(group))
    {
        referenceConfig.setGroup(group);
    }

    T obj=null;
    try {
        if(referenceConfig!=null) {
            obj=(T) referenceConfig.get();
        }
    } catch (Exception e) {

    }
    return obj;
}

以上方案为2.5.3版本中的方案
Reference注解已经在dubbo新版本中标记为废弃,所以提早记录下

上一篇 下一篇

猜你喜欢

热点阅读