1.dubbo服務過多引用的問題
1.1 dubbo服務以xml配置消費者
由于引用多個dubbo服務時锦聊，在未使用前無法得知需要使用哪個接口丽柿，如果以xml配置的形式來調(diào)用,應該如下代碼
代碼示例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的數(shù)量將非常龐大,不利于團隊之間的合作開發(fā)
1.3 使用Reference注解的形式
使用注解后，就可以在實際情況下引用即可,非常方便
代碼示例3
@Reference
private UserService userService;
2.Reference注解的問題
- 當需要配置某個模塊的version和group時,希望能夠統(tǒng)一修改,與配置中心綁定
- 使用注解時,當在父類使用該注解時不生效灶壶，因為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進行改造.
思路如下:
- 將version和group相關需要的全局配置改造成與配置中心相關聯(lián)
- xml去除dubbo:annotation配置
- 同時對父類方法和字段進行解析
3.動態(tài)獲取dubbo接口
有時候需要在某些場景哥捕，靜態(tài)獲取dubbo接口,就像Spring中ApplicationContext中getBean方法一樣
實際其內(nèi)部還是構造一個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注解已經(jīng)在dubbo新版本中標記為廢棄，所以提早記錄下
