什么是 Netidx

Netidx 是一种中间件，它使得在一个程序中发布一个值（如 42），并在另一个程序中（无论是同一台机器还是通过网络）消费该值成为可能。

值在分层命名空间中具有全局唯一的名称。例如，我们发布的 42 可能被命名为 /the-ultimate-answer（通常我们不会将值直接放在根下面，但在这个例子中是合适的）。网络上的任何其他程序都可以通过该名称引用 42，并且会在 /the-ultimate-answer 发生变化（可能性不大）的情况下收到更新。

与其他系统的比较

• 类似于 LDAP

  • Netidx 跟踪一个值的分层目录
  • Netidx 在一定程度上可浏览和可查询
  • Netidx 支持身份验证、授权和加密
  • Netidx 值可以写入也可以读取。
  • 可以通过在较小的系统之间添加引用来构建较大的 Netidx 系统。解析器服务器集群可能有父级和子级。

• 不同于 LDAP

  • 在 Netidx 中，解析器服务器（如 slapd）只记录具有数据的发布者的位置，而不是数据本身。
  • 没有“条目”、“属性”、“ldif 记录”等。系统中的每个名称要么是结构性的，要么是一个单个值。使用层次结构创建类似条目的结构。因此，也没有模式检查。
  • 可以订阅一个值，如果它改变，就会立即通知。
  • 没有全局数据过滤器，例如，您不能查询 (&(cn=bob)(uid=foo))，因为 netidx 不是一个数据库。是否以及存在查询机制取决于发布者。然而，您可以查询结构，例如，/foo/**/bar 会返回以 bar 结尾的 foo 下的任何路径。

• 类似于 MQTT

  • Netidx 值是发布/订阅
  • 单个 Netidx 值可以有多达多个订阅者
  • 当订阅的值更改时，所有 Netidx 订阅者都会收到更新。
  • Netidx 消息传递是可靠和有序的。

• 不同于 MQTT

  • 在 Netidx 中，没有集中的消息代理。消息直接从发布者流到订阅者，通过 TCP。解析器服务器只存储发布值的发布者/发布者的地址。

更多详情请参阅 netidx 书籍

以下是一个发布 cpu 温度并包含相应消费数据的订阅者的示例服务。

发布者

use netidx::{
    publisher::{Publisher, Value, BindCfg},
    config::Config,
    resolver::Auth,
    path::Path,
};
use tokio::time;
use std::time::Duration;
use anyhow::Result;

fn get_cpu_temp() -> f32 { 42. }

async fn run() -> Result<()> {
    // load the site cluster config. You can also just use a file.
    let cfg = Config::load_default()?;

    // no authentication (kerberos v5 is the other option)
    // listen on any unique address matching 192.168.0.0/16
    let publisher = Publisher::new(cfg, Auth::Anonymous, "192.168.0.0/16".parse()?).await?;

    let temp = publisher.publish(
        Path::from("/hw/washu-chan/cpu-temp"),
        Value::F32(get_cpu_temp())
    )?;

    loop {
        time::sleep(Duration::from_millis(500)).await;
        let mut batch = publisher.start_batch();
        temp.update(&mut batch, Value::F32(get_cpu_temp()));
        batch.commit(None).await;
    }
    Ok(())
}

订阅者

use netidx::{
    subscriber::{Subscriber, UpdatesFlags},
    config::Config,
    resolver::Auth,
    path::Path,
};
use futures::{prelude::*, channel::mpsc};
use anyhow::Result;

async fn run() -> Result<()> {
    let cfg = Config::load_default()?;
    let subscriber = Subscriber::new(cfg, Auth::Anonymous)?;
    let path = Path::from("/hw/washu-chan/cpu-temp");
    let temp = subscriber.subscribe_one(path, None).await?;
    println!("washu-chan cpu temp is: {:?}", temp.last());

    let (tx, mut rx) = mpsc::channel(10);
    temp.updates(UpdatesFlags::empty(), tx);
    while let Some(mut batch) = rx.next().await {
        for (_, v) in batch.drain(..) {
            println!("washu-chan cpu temp is: {:?}", v);
        }
    }
    Ok(())
}

发布的内容始终有一个值，新的订阅者最初会收到。此后，订阅是一个无损耗的有序流，就像 Tcp 连接一样，除了传输单元不是字节而是 publisher::Value。由于订阅者可以写值回发布者，所以连接是双向的，就像 Tcp 流一样。

值包括许多有用的基本类型，包括零拷贝的字节数据缓冲区（使用出色的bytes crate），因此您可以轻松地使用netidx来高效地发送任何喜欢的消息。然而，建议您坚持使用基本类型，并以层次结构中的多个已发布值来表示结构，因为这样做可以使您的系统更容易被发现，并且也相当高效。

netidx包括对kerberos v5（包括Active Directory）的可选支持。如果启用，所有组件将在解析器、订阅者和发布者之间进行相互认证，并对所有传输数据进行加密。

在krb5模式下，解析器服务器维护并执行整个命名空间的一组授权权限。系统管理员可以集中执行谁可以发布在哪里，以及谁可以订阅什么。