服务发现

服务发现

Dubbo Rust服务发现简介

Dubbo Rust提供的是一种 Client-Based 的服务发现机制，依赖第三方注册中心组件来协调服务发现过程，支持的注册中心： Nacos、Zookeeper

以下是 Dubbo Rust服务发现机制的基本工作原理图：

service-discovery

服务发现包含提供者、消费者和注册中心三个参与角色，其中，Dubbo 提供者实例注册 URL 地址到注册中心，注册中心负责对数据进行聚合，Dubbo 消费者从注册中心读取地址列表并订阅变更，每当地址列表发生变化，注册中心将最新的列表通知到所有订阅的消费者实例。

  • Dubbo Rust注册中心以服务粒度聚合实例数据，消费者按消费需求精准订阅。

Dubbo Rust服务发现的一个示例：example

高效地址推送实现

从注册中心视角来看，它负责以服务名 (例如：org.apache.dubbo.sample.tri.Greeter) 对整个集群的实例地址进行聚合，每个对外提供服务的实例将自身的实例ip:port 地址信息 (例如：127.0.0.1:8848) 注册到注册中心。

配置方式

Dubbo Rust服务发现支持两种注册中心组件，既Nacos、Zookeeper，可以通过以下方式创建不同的注册中心，并将其绑定到Dubbo Rust框架。

配置方式： 假设有服务：Greeter，对应的服务实现为GreeterServerImpl

服务端：

  1.     //注册服务
  2.     register_server(GreeterServerImpl {
  3.         name: "greeter".to_string(),
  4.     });
  6.     //创建注册中心
  7.     let zkr = ZookeeperRegistry::default();
  9.     let r = RootConfig::new();
  10.     let r = match r.load() {
  11.         Ok(config) => config,
  12.         Err(_err) => panic!("err: {:?}", _err), // response was droped
  13.     };
  15.     //启动Dubbo框架
  16.     let mut f = Dubbo::new()
  17.         .with_config(r)
  18.         //将创建出的注册中心绑定Dubbo框架
  19.         .add_registry("zookeeper", Box::new(zkr));
  20.     f.start().await;

对于上述过程，可以通过修改创建注册中心的步骤来更改所使用的注册中心

客户端：

  1.     let mut builder = ClientBuilder::new();
  3.     //通过env获取注册中心地址
  4.     if let Ok(zk_servers) = env::var("ZOOKEEPER_SERVERS") {
  5.         //创建注册中心
  6.         let zkr = ZookeeperRegistry::new(&zk_servers);
  7.         //绑定注册中心
  8.         let directory = RegistryDirectory::new(Box::new(zkr));
  9.         builder = builder.with_directory(Box::new(directory));
  10.     } else if let Ok(nacos_url_str) = env::var("NACOS_URL") {
  11.         // NACOS_URL=nacos://mse-96efa264-p.nacos-ans.mse.aliyuncs.com
  12.         //创建注册中心
  13.         let nacos_url = Url::from_url(&nacos_url_str).unwrap();
  14.         let registry = NacosRegistry::new(nacos_url);
  15.         //绑定注册中心
  16.         let directory = RegistryDirectory::new(Box::new(registry));
  17.         builder = builder.with_directory(Box::new(directory));
  18.     } else {
  19.         builder = builder.with_host("http://127.0.0.1:8888");
  20.     }
  22.     let mut cli = GreeterClient::new(builder);

创建Nacos注册中心：

  1. //通过Url创建注册中心实例
  2. let nacos_url = Url::from_url("127.0.0.1:1221").unwrap();
  3. let registry = NacosRegistry::new(nacos_url);

创建Zookeeper注册中心：

  1. //直接创建Zookeeper注册中心
  2. let zkr = ZookeeperRegistry::new("127.0.0.1:1221");
  1. //使用default方法创建Zookeeper注册中心会默认使用环境变量中的值ZOOKEEPER_SERVERS
  2. let zkr = ZookeeperRegistry::default();

最后修改 September 13, 2024: Refactor website structure (#2860) (1a4b998f54b)