Lib.rs

NACOS API

支持

服务

• register instance 注册实例
• remove instance 注销实例
• update instance 修改实例
• get instance list 查询实例列表
• get instance 查询实例详情
• heart beat 心跳感应
• create service 创建服务
• delete service 删除服务
• update service 修改服务
• get service information 查询服务详情
• get service list 查询服务列表
• get operator metrics 查询系统运载
• get operator servers 查询服务详情

配置

• upload config 上传配置
• get config 获取配置
• delete config 删除配置
• listen config 监听配置

使用方法

register current instance 注册当前实例

use nacos_api::{NacosClient, NacosConfig, ServerConfig};

#[tokio::main]
async fn main() {
    let nacos = NacosConfig::new("http", "192.168.0.132", 8848);
    let client = NacosClient::new(
        &nacos,
        ServerConfig::new("127.0.0.1", 8080, "test"),
    );

    client.register(&None).await;
    loop {}
}

尝试获取其他服务器地址

pub async fn try_req_server() {
    use nacos_api::{NacosClient, NacosConfig, ServerConfig};

    let nacos = NacosConfig::new("http", "192.168.0.132", 8848);
    let client = NacosClient::new(
        &nacos,
        ServerConfig::new("127.0.0.1", 8080, "test"),
    );

    let addr = client.get_addr_simple("test").await?;
    assert!("http://127.0.0.1:8080", addr.as_str());
}

listen configs center 监听配置中心

use nacos_api::{NacosConfigClient, NacosConfigApi, DeployConfig, NacosConfig};

#[tokio::main]
async fn main() {
    let client = NacosConfigClient::new("test_data", "test_grep", None);
    let nacos_config = NacosConfig::new("http", "192.168.0.132", 8848);
    // listen the nacos configs center
    client.listen_config(
        &nacos_config,
        |s| { println!(" perceive the configs changed to > {}", s) },
        10
    ).await;
    // make the program keep alive
    loop {}
}

声明

development by nacos v2.0.1