dubbo+zookeeper 通过获取全部服务的方式来判断要调用哪个服务方案

这篇文章距离上次修改已过357天，其中的内容可能已经有所变动。

*maven
非必须的*

<dependency>
  <groupId>org.apache.dubbo</groupId>
  <artifactId>dubbo-registry-zookeeper</artifactId>
  <version>{Dubbo版本号}</version>
</dependency>

在服务消费者端的代码中获取Zookeeper注册中心上的全部可用服务

// 创建Zookeeper注册中心实例
RegistryService registryService = ExtensionLoader.getExtensionLoader(RegistryFactory.class)
        .getExtension("zookeeper")
        .getRegistry(new URL("zookeeper", "localhost", 2181));
// 获取可用的服务列表
List<URL> urls = registryService.lookup(new URL("dubbo", "localhost", 0, "org.example.UserService"));
for (URL url : urls) {
    System.out.println(url.getHost() + ":" + url.getPort());
}

以上示例代码中，通过RegistryFactory的getExtension方法获取到ZookeeperRegistryFactory实例，然后通过其getRegistry方法构造一个Zookeeper注册中心实例。然后，通过调用RegistryService的lookup方法获取到全部可用服务的URL列表。

案例：

// 创建Zookeeper注册中心实例
RegistryService registryService = ExtensionLoader.getExtensionLoader(RegistryFactory.class)
        .getExtension("zookeeper")
        .getRegistry(new URL("zookeeper", "localhost", 2181));
// 获取可用的服务列表
List<URL> urls = registryService.lookup(new URL("dubbo", "localhost", 0, "org.example.UserService"));
// 判断服务列表中是否包含指定的服务
if (!urls.isEmpty()) {
    // 调用UserService提供的方法
    ReferenceConfig<UserService> reference = new ReferenceConfig<>();
    reference.setInterface(UserService.class);
    reference.setUrl(urls.get(0).toString());
    UserService userService = reference.get();
    userService.sayHello();
} else {
    System.out.println("未找到UserService服务！");
}

以上示例代码中，通过判断获取到的URL列表是否为空来确定是否能够调用指定的服务。如果URL列表不为空，则通过ReferenceConfig对象来调用UserService提供的方法。

new URL("dubbo", "localhost", 0, "org.example.UserService")
这里的第一个参数"dubbo"表示协议名称，第二个参数"localhost"表示注册中心的地址，第三个参数0表示启动时监听的端口号，第四个参数"org.example.UserService"表示要获取的服务名称。

具体解释如下：

协议名称： Dubbo使用URL来唯一标识一个服务，其中URL包括了协议名称、IP地址、端口号、服务名称和其他参数。Dubbo支持的协议有dubbo、http、hessian等。

注册中心地址： 注册中心是用来存储服务提供者信息和服务消费者信息的中心化服务。Dubbo支持的注册中心有Zookeeper、Nacos、Etcd等。

启动时监听的端口号： 在这个示例中，由于我们只需要获取可用的服务列表，因此不需要指定具体的端口号，可以将其设置为0，表示随机生成一个端口号。

服务名称： 表示要获取的服务名，即在注册中心上注册的服务名，该服务名通常是唯一的，以便服务消费者能够准确地找到需要调用的服务提供者。

希望这些信息对你有所帮助，如果还有其他问题，请随时向我提问。

// 创建Zookeeper注册中心实例
Registry registry = ExtensionLoader.getExtensionLoader(RegistryFactory.class)
        .getExtension("zookeeper")
        .getRegistry(new URL("zookeeper", "localhost", 2181));
// 获取服务目录
List<URL> urls = registry.lookup(new URL("dubbo", "localhost", 0, "org.example.UserService"));
// 遍历输出每个URL对应的主机和端口信息
for (URL url : urls) {
    System.out.println(url.getHost() + ":" + url.getPort());
    }

在这里，我们首先通过调用getExtensionLoader方法获取RegistryFactory接口的实例对象，然后通过这个实例来创建一个Zookeeper注册中心的实例。接着，通过调用Registry对象的lookup方法获取指定服务名称的全部URL列表，并遍历输出每个URL对应的主机和端口信息。

另外，请注意将代码中的服务名、Zookeeper地址和端口等信息替换为实际情况，如果还有疑问，请随时向我提问。

如果你的Dubbo接口中设置了版本号（version），那么在获取可用服务列表时，需要将版本号包含在服务名中一起传递。具体做法是，在lookup方法中传递一个完整的服务URL对象，其中包含了版本号信息。示例代码如下：

// 创建Zookeeper注册中心实例

Registry registry = ExtensionLoader.getExtensionLoader(RegistryFactory.class)
        .getExtension("zookeeper")
        .getRegistry(new URL("zookeeper", "localhost", 2181));
// 构建服务URL对象
URL serviceUrl = new URL("dubbo", "localhost", 0, "org.example.UserService");
serviceUrl = serviceUrl.addParameter("version", "1.0.0");  // 在URL中添加版本号参数
// 获取服务目录
List<URL> urls = registry.lookup(serviceUrl);
// 遍历输出每个URL对应的主机和端口信息
for (URL url : urls) {
    System.out.println(url.getHost() + ":" + url.getPort());

}

在这里，我们创建了一个URL对象来描述需要获取的服务，然后使用addParameter方法向URL中添加了版本号参数。在调用lookup方法时，我们将这个完整的服务URL对象传递给它，以便能正确地获取带有版本号信息的服务列表。

另外，请注意将示例代码中的服务名、Zookeeper地址和端口等信息替换为实际情况，如果还有疑问，请随时向我提问。