在開發的時候，可能多個專案會修改同乙個服務，那麼不能直接暴露出來，否則會被其他人給呼叫到，導致資料不正常，那麼這種情況下可以使用dubbo的多版本來解決這個問題，配置如下：
// 穩定環境下的provider和consumer
"com.foo.barservice" version="1.0.0" />
"barservice" inte***ce="com.foo.barservice" version="1.0.0" />
// 專案環境下的provider和consumer，我司用的是1.0.0加上專案字尾，這個只要能區分就ok
"com.foo.barservice" version="1.0.0***" />
"barservice" inte***ce="com.foo.barservice" version="1.0.0***" />
對於提供者來說，需要暴露兩個版本的服務，從zk上說的就是建立了兩個不一樣的節點。回顧一下當提供者接收到請求的時候，首先會先找到exporter，然後再找到invoker，那麼
- 如果是乙個機器上暴露了兩個版本的服務，這塊如何做區分呢？
這個問題要看下dubboprotocol類的export方法，因為這是講exporter儲存起來的地方
public
exporterexport(invokerinvoker) throws rpcexception
protected
static string servicekey(url url)
//protocolutils
public
static string servicekey(url url)
public
static string servicekey(int port, string servicename, string serviceversion, string servicegroup)
if (serviceversion != null && serviceversion.length() > 0 && !"0.0.0".equals(serviceversion))
return buf.tostring();
}
消費者這邊就比較複雜了，從zookeeperregistry的dosubscribe方法開始看起，因為這裡是處理zk相關節點的地方，而多版本在zk上是節點的不同，所以看下這裡是否有對節點做特殊處理
protected
void
dosubscribe(final url url, final notifylistener listener)
childlistener zklistener = listeners.get(listener);
if (zklistener == null)
});zklistener = listeners.get(listener);
}zkclient.create(path, false);
listchildren = zkclient.addchildlistener(path, zklistener);
if (children != null)
}notify(url, listener, urls);
//....
}
private listtourlswithempty(url consumer, string path, listproviders)
return urls;
}
private listtourlswithoutempty(url consumer, listproviders) }}
}return urls;
}
public
static
boolean
ismatch(url consumerurl, url providerurl)
if (! providerurl.getparameter(constants.enabled_key, true)
&& ! constants.any_value.equals(consumerurl.getparameter(constants.enabled_key)))
string consumergroup = consumerurl.getparameter(constants.group_key);
string consumerversion = consumerurl.getparameter(constants.version_key);
string consumerclassifier = consumerurl.getparameter(constants.classifier_key, constants.any_value);
string providergroup = providerurl.getparameter(constants.group_key);
string providerversion = providerurl.getparameter(constants.version_key);
string providerclassifier = providerurl.getparameter(constants.classifier_key, constants.any_value);
return (constants.any_value.equals(consumergroup) || stringutils.isequals(consumergroup, providergroup) || stringutils.iscontains(consumergroup, providergroup))
&& (constants.any_value.equals(consumerversion) || stringutils.isequals(consumerversion, providerversion))
&& (consumerclassifier == null || constants.any_value.equals(consumerclassifier) || stringutils.isequals(consumerclassifier, providerclassifier));
}
回到dosubscribe方法，獲取到urls之後，會呼叫notify方法，該方法一路呼叫到com.alibaba.dubbo.registry.integration.registrydirectory#refreshinvoker方法
private
void
refreshinvoker(listinvokerurls) else
}
在com.alibaba.dubbo.registry.integration.registrydirectory#dolist方法中會首先判斷該屬性
public list> dolist(invocation invocation)
//....
}
那麼又有乙個問題
對服務暴露和提供熟悉的應該會知道，消費者對providers節點設定了***，當節點變化，然後呼叫一下notify方法，如果新增的節點是匹配版本的那麼refreshinvoker中forbidden不為true，服務正常呼叫，如果不匹配，那麼和上面一樣的結果。
總結一下：
1. 提供者不同服務會再zk上建立不同的節點
2. 提供者儲存exporter的時候會根據version的不同去構造不同的key放到map中
3. 消費者會獲取providers下的節點，並比對版本是否一樣，如果不一樣則返回乙個empty協議的url
4. 如果協議為empty，那麼會將forbidden設定為true，呼叫會報錯
5. 當有節點發生變化又會執行比對的過程
Dubbo原始碼分析
dubbo原始碼分析 其實已經有很多比較好的原始碼分析部落格，結合部落格和開發經驗再去分析原始碼，就能對dubbo的實現有個整體全面的理解，也能深入去深究其中的具體實現細節。dubbo裡主要用到的spi service provider inte ce netty nio 同步非阻塞多路復用框架，d...
Dubbo服務註冊原始碼分析
服務在本地發布完成，那麼接下去要進入服務的註冊階段 final registry registry getregistry origininvoker final url registeredproviderurl geturltoregistry providerurl,registryurl d...
Dubbo原始碼分析之SPI（二）
本篇文章是dubbo spi原始碼分析的第二篇，接著第一篇繼續分析dubbo spi的內容，我們主要介紹 getdefaultextension 獲取預設擴充套件點方法。由於此方法比較簡單，我們略過示例部分，直接分析原始碼。獲取預設擴充套件方法getdefaultextension 是乙個publi...