1 个不稳定版本

0.1.0	2020年9月3日

#1694 in 数据结构

MIT/Apache

8KB
123 行

纳威

从一致性哈希算法出发思考分布式系统的构建。

纳威的愿景是成为构建稳健且高可用分布式系统的基础。可能的最终产品是一系列重要的算法或某种意义上的框架。

当然，您已经可以在项目中使用它了，目前仅是 rust-hash-ring 的移植版。

功能

移植 rust-hash-ring，使用 xxhash 替代 md5。

用法

哈希环

extern crate nave;

use nave::HashRing;

/// Custom Node Info. 
#[derive(Clone, Debug)]
struct NodeInfo {
    pub host: &'static str,
    pub port: u16,
}

/// Impl ToString to format NodeInfo
impl ToString for NodeInfo {
    fn to_string(&self) -> String {
        format!("{}:{}", self.host, self.port)
    }
}

fn main() {
    let mut nodes: Vec<NodeInfo> = Vec::new();
    nodes.push(NodeInfo { host: "localhost", port: 15324 });
    nodes.push(NodeInfo { host: "localhost", port: 15325 });
    nodes.push(NodeInfo { host: "localhost", port: 15326 });
    nodes.push(NodeInfo { host: "localhost", port: 15327 });
    nodes.push(NodeInfo { host: "localhost", port: 15328 });
    nodes.push(NodeInfo { host: "localhost", port: 15329 });

    let mut hash_ring: HashRing<NodeInfo> = HashRing::new(nodes, 10);

    println!("{}", hash_ring.get_node(("hello").to_string()).unwrap().to_string());

    println!("{}", hash_ring.get_node(("dude").to_string()).unwrap().to_string());

    println!("{}", hash_ring.get_node(("martian").to_string()).unwrap().to_string());

    println!("{}", hash_ring.get_node(("tardis").to_string()).unwrap().to_string());

    hash_ring.remove_node(&NodeInfo { host: "localhost", port: 15329 });

    println!("{}", hash_ring.get_node(("hello").to_string()).unwrap().to_string());

    hash_ring.add_node(&NodeInfo { host: "localhost", port: 15329 });

    println!("{}", hash_ring.get_node(("hello").to_string()).unwrap().to_string());
}