dubbo-Reference注解改進(jìn)

1.dubbo服務(wù)過(guò)多引用的問(wèn)題

1.1 dubbo服務(wù)以xml配置消費(fèi)者

由于引用多個(gè)dubbo服務(wù)時(shí),在未使用前無(wú)法得知需要使用哪個(gè)接口,如果以xml配置的形式來(lái)調(diào)用,應(yīng)該如下代碼

代碼示例1

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

1.2 dubbo服務(wù)膨脹的問(wèn)題

由于需求不斷變更,引用的dubbo服務(wù)不斷增多,這時(shí)候配置將會(huì)如下

代碼示例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"/>
......

實(shí)際項(xiàng)目中引用的服務(wù)會(huì)更多,維護(hù)該xml的數(shù)量將非常龐大,不利于團(tuán)隊(duì)之間的合作開(kāi)發(fā)

1.3 使用Reference注解的形式

使用注解后,就可以在實(shí)際情況下引用即可,非常方便

代碼示例3

@Reference
private UserService userService;

2.Reference注解的問(wèn)題

  1. 當(dāng)需要配置某個(gè)模塊的version和group時(shí),希望能夠統(tǒng)一修改,與配置中心綁定
  2. 使用注解時(shí),當(dāng)在父類(lèi)使用該注解時(shí)不生效,因?yàn)镽eference注解并未對(duì)父類(lèi)方法和字段進(jìn)行解析

代碼示例4

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

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

//此為示例代碼,Value注解應(yīng)該能夠理解
@Value("userModule.version")
private String version;

2.1 改造的切入點(diǎn)AnnotationBean

Reference注解由AnnotationBean進(jìn)行解析,所以第一步是對(duì)AnnotationBean進(jìn)行改造.

思路如下:

  1. 將version和group相關(guān)需要的全局配置改造成與配置中心相關(guān)聯(lián)
  2. xml去除dubbo:annotation配置
  3. 同時(shí)對(duì)父類(lèi)方法和字段進(jìn)行解析

3.動(dòng)態(tài)獲取dubbo接口

有時(shí)候需要在某些場(chǎng)景,靜態(tài)獲取dubbo接口,就像Spring中ApplicationContext中g(shù)etBean方法一樣
實(shí)際其內(nèi)部還是構(gòu)造一個(gè)ReferenceBean對(duì)象

代碼示例5

public static <T> T getDubboBean(Class<T> referenceClass,String version) {
    if (referenceClass == null) {
        throw new IllegalStateException("請(qǐng)輸入接口類(lèi)型");
    } 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注解已經(jīng)在dubbo新版本中標(biāo)記為廢棄,所以提早記錄下

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書(shū)系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容