从 dubbo zookeeper 注册地址提取 zookeeper 地址
  TEZNKK3IfmPf 2023年11月15日 23 0


本文仅为个人记录,方便以后查阅。

项目中使用了 dubbo,注册中心使用的 zookeeper,使用 zookeeper 实现了一个简单的分布式锁(依赖 curator),因为配置文件存在 dubbo.registry 配置,为了直接使用这个地址来创建分布式锁,写了一个简单的方法来提取 zookeeper 地址。

效果

dubbo.registry 有多种配置方式,支持所有情况,下面是常见的例子和提取结果:

zookeeper://localhost:2181
zookeeper://localhost:2181?client=zkclient
zookeeper://localhost:2181?backup=localhost:2182,localhost:2183
zookeeper://localhost:2181?client=zkclient&backup=localhost:2182,localhost:2183
------------结果------------
Optional[localhost:2181]
Optional[localhost:2181]
Optional[localhost:2181,localhost:2182,localhost:2182]
Optional[localhost:2181,localhost:2183,localhost:2183]

代码

 java.util.Optional;

   {
        PREFIX  ;
        BACKUP  ;

      Optional convertDubboRegistryToZookeeperURL( dubboRegistry){
         zookeeperURL   ();
        (dubboRegistry    dubboRegistry.startsWith(PREFIX)){
            dubboRegistry  dubboRegistry.substring(PREFIX.length());
             index  dubboRegistry.indexOf();
            (index  ){
                zookeeperURL.append(dubboRegistry.substring(, index));
                dubboRegistry  dubboRegistry.substring(index  );
                [] dubboRegistries  dubboRegistry.split();
                 ( i  ; i  dubboRegistries.length; i) {
                    (dubboRegistries[i].startsWith(BACKUP)){
                        [] backups  dubboRegistries[i].substring(BACKUP.length()).split();
                         ( j  ; j  backups.length; j) {
                            zookeeperURL.append().append(backups[i]);
                        }
                    }
                }
            }  {
                zookeeperURL.append(dubboRegistry);
            }
             Optional.of(zookeeperURL.toString());
        }
         Optional.empty();
    }

       main([] args) {
        System.out.println(convertDubboRegistryToZookeeperURL());
        System.out.println(convertDubboRegistryToZookeeperURL());
        System.out.println(convertDubboRegistryToZookeeperURL());
        System.out.println(convertDubboRegistryToZookeeperURL());
    }

}


【版权声明】本文内容来自摩杜云社区用户原创、第三方投稿、转载,内容版权归原作者所有。本网站的目的在于传递更多信息,不拥有版权,亦不承担相应法律责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@moduyun.com

  1. 分享:
最后一次编辑于 2023年11月15日 0

暂无评论

推荐阅读
TEZNKK3IfmPf