mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-10-14 14:17:56 +00:00
fix[provider]: provider format check error
This commit is contained in:
1 parent
02ad965755
commit
331812f836
2 files changed
+8
-7
No files matched your search
@@ -62,11 +62,11 @@ public class ConfigManager implements IConfigManager {
|
|||||||
// 服务提供者名字Set列表
|
// 服务提供者名字Set列表
|
||||||
var providerSet = new HashSet<String>();
|
var providerSet = new HashSet<String>();
|
||||||
// 检查并且替换配置文件中的ProtocolModule
|
// 检查并且替换配置文件中的ProtocolModule
|
||||||
for (var providerModule : providerConfig.getProviders()) {
|
for (var provider : providerConfig.getProviders()) {
|
||||||
var provider = providerModule.getProvider();
|
var protocolModule = provider.getProtocolModule();
|
||||||
var protocolModule = ProtocolManager.moduleByModuleName(provider);
|
var providerName = provider.getProvider();
|
||||||
AssertionUtils.isTrue(protocolModule != null, "provider:[{}] does not exist in the protocol manager", provider);
|
AssertionUtils.isTrue(ProtocolManager.moduleByModuleName(protocolModule) != null, "provider:[{}] does not exist in the protocol manager", provider);
|
||||||
AssertionUtils.isTrue(providerSet.add(provider), "provider:[{}] has duplicate provider name module [provider:{}]", provider, protocolModule);
|
AssertionUtils.isTrue(providerSet.add(providerName), "provider:[{}] has duplicate provider name module [provider:{}]", provider, protocolModule);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -365,7 +365,8 @@ public class ZookeeperRegistry implements IRegistry {
|
|||||||
var localProviderVoStr = localRegisterVO.toProviderString();
|
var localProviderVoStr = localRegisterVO.toProviderString();
|
||||||
var localProviderPath = PROVIDER_ROOT_PATH + StringUtils.SLASH + localProviderVoStr;
|
var localProviderPath = PROVIDER_ROOT_PATH + StringUtils.SLASH + localProviderVoStr;
|
||||||
|
|
||||||
// /zfoo/provider/tankHome | 192.168.3.2:12400 | provider:[3-tankHome-tankHomeProvider] | consumer:[4-tankCache-consistent-hash-tankCacheProvider]
|
// /zfoo/provider
|
||||||
|
// applicationNameTest | 192.168.1.104:12400 | provider:[providerTest-myProvider1, providerTest-myProvider2]
|
||||||
var localProviderStat = curator.checkExists().forPath(localProviderPath);
|
var localProviderStat = curator.checkExists().forPath(localProviderPath);
|
||||||
if (Objects.isNull(localProviderStat)) {
|
if (Objects.isNull(localProviderStat)) {
|
||||||
curator.create()
|
curator.create()
|
||||||
@@ -396,7 +397,7 @@ public class ZookeeperRegistry implements IRegistry {
|
|||||||
* @throws Exception
|
* @throws Exception
|
||||||
*/
|
*/
|
||||||
private void initConsumerCache() throws Exception {
|
private void initConsumerCache() throws Exception {
|
||||||
// tankHome | 192.168.3.2:12400 | provider:[3-tankHome-tankHomeProvider] | consumer:[4-tankCache-consistent-hash-tankCacheProvider]
|
// applicationNameTest | 192.168.1.104:12400 | provider:[providerTest-myProvider1, providerTest-myProvider2]
|
||||||
var localRegisterVO = NetContext.getConfigManager().getLocalConfig().toLocalRegisterVO();
|
var localRegisterVO = NetContext.getConfigManager().getLocalConfig().toLocalRegisterVO();
|
||||||
// 初始化providerCacheSet
|
// 初始化providerCacheSet
|
||||||
// 遍历provider下注册的所有节点
|
// 遍历provider下注册的所有节点
|
||||||
|
|||||||
Reference in new issue
Block a user