从dubbo zookeeper注册地址提取出zookeeper地址的方法_Java教程

从dubbo zookeeper注册地址提取出zookeeper地址的方法

2021-06-24 10:33isea533 Java教程

今天小编就为大家分享一篇关于从dubbo zookeeper注册地址提取出zookeeper地址的方法，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧

用途

项目中使用了 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]

代码

				?

									import java.util.optional;

									public class zookeeperurl {

									  public static final string prefix = "zookeeper://";

									  public static final string backup = "backup=";

									  public static optional<string> convertdubboregistrytozookeeperurl(string dubboregistry){

									    stringbuilder zookeeperurl = new stringbuilder();

									    if(dubboregistry != null && dubboregistry.startswith(prefix)){

									      dubboregistry = dubboregistry.substring(prefix.length());

									      int index = dubboregistry.indexof("?");

									      if(index > 0){

									        zookeeperurl.append(dubboregistry.substring(0, index));

									        dubboregistry = dubboregistry.substring(index + 1);

									        string[] dubboregistries = dubboregistry.split("&");

									        for (int i = 0; i < dubboregistries.length; i++) {

									          if(dubboregistries[i].startswith(backup)){

									            string[] backups = dubboregistries[i].substring(backup.length()).split(",");

									            for (int j = 0; j < backups.length; j++) {

									              zookeeperurl.append(",").append(backups[i]);

									            }

									          }

									        }

									      } else {

									        zookeeperurl.append(dubboregistry);

									      }

									      return optional.of(zookeeperurl.tostring());

									    }

									    return optional.empty();

									  }

									  public static void main(string[] args) {

									    system.out.println(convertdubboregistrytozookeeperurl("zookeeper://localhost:2181"));

									    system.out.println(convertdubboregistrytozookeeperurl("zookeeper://localhost:2181?client=zkclient"));

									    system.out.println(convertdubboregistrytozookeeperurl("zookeeper://localhost:2181?backup=localhost:2182,localhost:2183"));

									    system.out.println(convertdubboregistrytozookeeperurl("zookeeper://localhost:2181?client=zkclient&backup=localhost:2182,localhost:2183"));

									  }

									}