代码拉取完成，页面将自动刷新
rust实现的nacos客户端。
nacos_rust_client是我在写r-nacos (用rust重写的nacos服务)过程中实现的客户端，服务端与客户端相互验证，目前已比较稳定推荐使用。
0.3.x版本开始同时支持nacos 1.x版http协议和2.x版本协议，支持在创建client时指定使用协议类型。
0.2.x版本只支持nacos 1.x版http协议.
0.3.x版本兼容0.2版本api，建议使用nacos_rust_client都升级到0.3.x版本。
特点：
首先加入引用
[dependencies]
nacos_rust_client = "0.3"
使用ClientBuilder创建配置客户端，支持设置集群地址列表，支持验权校验.
use nacos_rust_client::client::config_client::ConfigClient;
use nacos_rust_client::client::ClientBuilder;
//...
//兼容旧版本的创建方式，旧版本创建方式使用http协议
//let config_client = ConfigClient::new_with_addrs("127.0.0.1:8848,127.0.0.1:8848",tenant,auth_info);
let config_client = ClientBuilder::new()
.set_endpoint_addrs("127.0.0.1:8848,127.0.0.1:8848")
.set_auth_info(auth_info)
.set_tenant(tenant)
.set_use_grpc(true) //select communication protocol
.build_config_client();
创建客户端,后会把客户端的一个引用加入到全局对象,可以通过 get_last_config_client获取.
let config_client = nacos_rust_client::get_last_config_client().unwrap();
let key = ConfigKey::new("data_id","group_name","" /*tenant_id*/);
config_client.set_config(&key, "config_value").await.unwrap();
let v=config_client.get_config(&key).await.unwrap();
实时的接收服务端的变更推送，更新监听器的内容，用于应用配置动态下发。
#[derive(Debug,Serialize,Deserialize,Default,Clone)]
pub struct Foo {
pub name: String,
pub number: u64,
}
//...
let foo_config_obj_listener = Box::new(ConfigDefaultListener::new(key.clone(),Arc::new(|s|{
//字符串反序列化为对象，如:serde_json::from_str::<T>(s)
Some(serde_json::from_str::<Foo>(s).unwrap())
})));
config_client.subscribe(foo_config_obj_listener.clone()).await;
let foo_obj_from_listener = foo_config_obj_listener.get_value().unwrap();
使用NamingClient::new_with_addrs创建配置客户端，支持设置集群地址列表，支持验权校验.
use nacos_rust_client::client::naming_client::NamingClient;
use nacos_rust_client::client::ClientBuilder;
//...
//兼容旧版本的创建方式，旧版本创建方式使用http协议
//let naming_client = NamingClient::new_with_addrs("127.0.0.1:8848,127.0.0.1:8848",namespace_id,auth_info);
let naming_client = ClientBuilder::new()
.set_endpoint_addrs("127.0.0.1:8848,127.0.0.1:8848")
.set_auth_info(auth_info)
.set_tenant(tenant)
.set_use_grpc(true) //select communication protocol
.build_naming_client();
创建客户端,后会把客户端的一个引用加入到全局对象,可以通过 get_last_naming_client获取.
let naming_client = nacos_rust_client::get_last_naming_client().unwrap();
只要调拨一次注册实例，客户端会自动在后面维持心跳保活。
let instance = Instance::new_simple(&ip,port,service_name,group_name);
naming_client.register(instance);
查询指定服务的地址列表
let params = QueryInstanceListParams::new_simple(service_name,group_name);
let instance_list_result=client.query_instances(params).await;
查询指定服务的地址列表并按重选中一个地址做服务调用。
let params = QueryInstanceListParams::new_simple(service_name,group_name);
let instance_result=client.select_instance(params).await;
如果要在tonic中使用服务地址选择,可以使用对tonic的适配 (nacos-tonic-discover)[https://crates.io/crates/nacos-tonic-discover]
应用结束时，nacos_rust_client可能还有后台的调用，可以调用nacos_rust_client::close_current_system() 优雅退出nacos_rust_client后台线程。
运行下面的例子，需要先启动nacos服务，把例子中的host改成实际的地址。
例子完整依赖与代码可以参考 examples/下的代码。
use std::time::Duration;
use std::sync::Arc;
use nacos_rust_client::client::{ HostInfo, ClientBuilder, AuthInfo };
use nacos_rust_client::client::config_client::{
ConfigClient,ConfigKey,ConfigDefaultListener
};
use serde::{Serialize,Deserialize};
use serde_json;
#[derive(Debug,Serialize,Deserialize,Default,Clone)]
pub struct Foo {
pub name: String,
pub number: u64,
}
#[tokio::main]
async fn main() {
std::env::set_var("RUST_LOG","INFO");
env_logger::init();
//let host = HostInfo::parse("127.0.0.1:8848");
//let config_client = ConfigClient::new(host,String::new());
let tenant = "public".to_owned(); //default teant
//let auth_info = Some(AuthInfo::new("nacos","nacos"));
let auth_info = None;
//let config_client = ConfigClient::new_with_addrs("127.0.0.1:8848,127.0.0.1:8848",tenant,auth_info);
let config_client = ClientBuilder::new()
.set_endpoint_addrs("127.0.0.1:8848,127.0.0.1:8848")
.set_auth_info(auth_info)
.set_tenant(tenant)
.set_use_grpc(true)
.build_config_client();
tokio::time::sleep(Duration::from_millis(1000)).await;
let key = ConfigKey::new("001","foo","");
//设置
config_client.set_config(&key, "1234").await.unwrap();
//获取
let v=config_client.get_config(&key).await.unwrap();
println!("{:?},{}",&key,v);
check_listener_value().await;
nacos_rust_client::close_current_system();
}
async fn check_listener_value(){
//获取全局最后一次创建的config_client
let config_client = nacos_rust_client::get_last_config_client().unwrap();
let mut foo_obj= Foo {
name:"foo name".to_owned(),
number:0u64,
};
let key = ConfigKey::new("foo_config","foo","");
let foo_config_obj_listener = Box::new(ConfigDefaultListener::new(key.clone(),Arc::new(|s|{
//字符串反序列化为对象，如:serde_json::from_str::<T>(s)
Some(serde_json::from_str::<Foo>(s).unwrap())
})));
let foo_config_string_listener = Box::new(ConfigDefaultListener::new(key.clone(),Arc::new(|s|{
//字符串反序列化为对象，如:serde_json::from_str::<T>(s)
Some(s.to_owned())
})));
config_client.set_config(&key,&serde_json::to_string(&foo_obj).unwrap()).await.unwrap();
//监听
config_client.subscribe(foo_config_obj_listener.clone()).await;
config_client.subscribe(foo_config_string_listener.clone()).await;
//从监听对象中获取
println!("key:{:?} ,value:{:?}",&key.data_id,foo_config_string_listener.get_value());
for i in 1..10 {
foo_obj.number=i;
let foo_json_string = serde_json::to_string(&foo_obj).unwrap();
config_client.set_config(&key,&foo_json_string).await.unwrap();
// 配置推送到服务端后， 监听更新需要一点时间
tokio::time::sleep(Duration::from_millis(1000)).await;
let foo_obj_from_listener = foo_config_obj_listener.get_value().unwrap();
let foo_obj_string_from_listener = foo_config_string_listener.get_value().unwrap();
// 监听项的内容有变更后会被服务端推送,监听项会自动更新为最新的配置
println!("foo_obj_from_listener :{}",&foo_obj_string_from_listener);
assert_eq!(foo_obj_string_from_listener.to_string(),foo_json_string);
assert_eq!(foo_obj_from_listener.number,foo_obj.number);
assert_eq!(foo_obj_from_listener.number,i);
}
}
use nacos_rust_client::client::naming_client::{ServiceInstanceKey, InstanceDefaultListener};
use std::sync::Arc;
use std::time::Duration;
use nacos_rust_client::client::{HostInfo, ClientBuilder, AuthInfo, naming_client::{NamingClient, Instance,QueryInstanceListParams}};
#[tokio::main]
async fn main(){
//std::env::set_var("RUST_LOG","INFO");
std::env::set_var("RUST_LOG","INFO");
env_logger::init();
//let host = HostInfo::parse("127.0.0.1:8848");
//let client = NamingClient::new(host,"".to_owned());
let namespace_id = "public".to_owned(); //default teant
//let auth_info = Some(AuthInfo::new("nacos","nacos"));
let auth_info = None;
//let client = NamingClient::new_with_addrs("127.0.0.1:8848,127.0.0.1:8848", namespace_id, auth_info);
let client = ClientBuilder::new()
.set_endpoint_addrs("127.0.0.1:8848,127.0.0.1:8848")
.set_auth_info(auth_info)
.set_tenant(namespace_id)
.set_use_grpc(true)
.set_app_name("foo".to_owned())
.build_naming_client();
let servcie_key = ServiceInstanceKey::new("foo","DEFAULT_GROUP");
//可以通过监听器获取指定服务的最新实现列表，并支持触发变更回调函数,可用于适配微服务地址选择器。
let default_listener = InstanceDefaultListener::new(servcie_key,Some(Arc::new(
|instances,add_list,remove_list| {
println!("service instances change,count:{},add count:{},remove count:{}",instances.len(),add_list.len(),remove_list.len());
})));
client.subscribe(Box::new(default_listener.clone())).await.unwrap();
let ip = local_ipaddress::get().unwrap();
let service_name = "foo";
let group_name="DEFAULT_GROUP";
for i in 0..10{
let port=10000+i;
let instance = Instance::new_simple(&ip,port,service_name,group_name);
//注册
client.register(instance);
tokio::time::sleep(Duration::from_millis(1000)).await;
}
//tokio::spawn(async{query_params2().await.unwrap();});
//let client2 = client.clone();
tokio::spawn(
async move {
query_params().await;
}
);
//let mut buf = vec![0u8;1];
//stdin().read(&mut buf).unwrap();
tokio::signal::ctrl_c().await.expect("failed to listen for event");
println!("n:{}",&client.namespace_id);
}
async fn query_params() -> anyhow::Result<()>{
//get client from global
let client = nacos_rust_client::get_last_naming_client().unwrap();
let service_name = "foo";
let group_name="DEFAULT_GROUP";
let params = QueryInstanceListParams::new_simple(service_name,group_name);
// 模拟每秒钟获取一次实例
loop{
//查询并按权重随机选择其中一个实例
match client.select_instance(params.clone()).await{
Ok(instances) =>{
println!("select instance {}:{}",&instances.ip,&instances.port);
},
Err(e) => {
println!("select_instance error {:?}",&e)
},
}
tokio::time::sleep(Duration::from_millis(1000)).await;
}
Ok(())
}
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。