前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >dubbo+zookeeper 通过获取全部服务的方式来判断要调用哪个服务方案

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

作者头像
用户9131103
发布2023-07-17 19:53:36
4370
发布2023-07-17 19:53:36
举报
文章被收录于专栏:工作经验

*maven 非必须的*

代码语言:javascript
复制
<dependency>
  <groupId>org.apache.dubbo</groupId>
  <artifactId>dubbo-registry-zookeeper</artifactId>
  <version>{Dubbo版本号}</version>
</dependency>

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

代码语言:javascript
复制
// 创建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列表。

案例:

代码语言:javascript
复制
// 创建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"表示要获取的服务名称。

具体解释如下:

代码语言:javascript
复制
协议名称: Dubbo使用URL来唯一标识一个服务,其中URL包括了协议名称、IP地址、端口号、服务名称和其他参数。Dubbo支持的协议有dubbo、http、hessian等。

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

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

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

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

代码语言:javascript
复制
// 创建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());
    }
代码语言:javascript
复制
在这里,我们首先通过调用getExtensionLoader方法获取RegistryFactory接口的实例对象,然后通过这个实例来创建一个Zookeeper注册中心的实例。接着,通过调用Registry对象的lookup方法获取指定服务名称的全部URL列表,并遍历输出每个URL对应的主机和端口信息。

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

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

// 创建Zookeeper注册中心实例

代码语言:javascript
复制
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地址和端口等信息替换为实际情况,如果还有疑问,请随时向我提问。

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2023年04月23日,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
微服务引擎 TSE
微服务引擎(Tencent Cloud Service Engine)提供开箱即用的云上全场景微服务解决方案。支持开源增强的云原生注册配置中心(Zookeeper、Nacos 和 Apollo),北极星网格(腾讯自研并开源的 PolarisMesh)、云原生 API 网关(Kong)以及微服务应用托管的弹性微服务平台。微服务引擎完全兼容开源版本的使用方式,在功能、可用性和可运维性等多个方面进行增强。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档