Rust NOSTR协议中继池库nostr-relay-pool的使用：实现高效分布式消息中继与网络连接管理

功能标志

以下是可用的crate功能标志：

状态

该库处于ALPHA状态，已实现的功能通常可以工作，但API将会以不兼容的方式发生变化。

捐赠

rust-nostr是免费和开源的。这意味着我们不会通过出售它来获得任何收入。相反，我们依赖于您的财务支持。如果您积极使用任何rust-nostr库/软件/服务，请考虑捐赠。

许可证

该项目采用MIT软件许可证分发 - 详情请参阅LICENSE文件

安装

在项目目录中运行以下Cargo命令：

cargo add nostr-relay-pool

或者将以下行添加到您的Cargo.toml中：

nostr-relay-pool = "0.43.0"

示例代码

以下是使用nostr-relay-pool库的完整示例：

use nostr_relay_pool::RelayPool;
use nostr::prelude::*;
use tokio::time::{sleep, Duration};

#[tokio::main]
async fn main() -> Result<()> {
    // 创建密钥对
    let keys = Keys::generate();
    
    // 初始化中继池
    let relay_pool = RelayPool::new();
    
    // 添加中继URL
    relay_pool.add_relay("wss://relay.damus.io", None).await?;
    relay_pool.add_relay("wss://nostr.wine", None).await?;
    
    // 连接到所有中继
    relay_pool.connect().await;
    
    // 创建事件
    let event = EventBuilder::new_text_note("Hello from nostr-relay-pool!", &[])
        .to_event(&keys)?;
    
    // 发送事件到所有中继
    relay_pool.send_event(event).await?;
    
    // 订阅事件
    let subscription = Filter::new()
        .kind(Kind::TextNote)
        .limit(10);
    
    relay_pool.subscribe("my-subscription", vec![subscription]).await;
    
    // 处理接收到的消息
    while let Ok(notification) = relay_pool.notifications().recv().await {
        match notification {
            RelayPoolNotification::Event(_sub_id, event) => {
                println!("Received event: {:?}", event);
            },
            RelayPoolNotification::Message(_relay_url, message) => {
                println!("Received message: {:?}", message);
            },
            _ => {}
        }
    }
    
    // 等待一段时间
    sleep(Duration::from_secs(30)).await;
    
    // 断开所有中继连接
    relay_pool.disconnect().await?;
    
    Ok(())
}

这个示例展示了：

1. 创建密钥对
2. 初始化中继池
3. 添加多个中继服务器
4. 连接到所有中继
5. 创建并发送事件
6. 订阅和接收事件
7. 处理不同类型的通知
8. 断开连接

完整示例代码

以下是基于上述内容的完整示例demo：

// 引入必要的库
use nostr_relay_pool::RelayPool;
use nostr::prelude::*;
use tokio::time::{sleep, Duration};

#[tokio::main]
async fn main() -> Result<()> {
    // 1. 创建密钥对 - 用于签名事件
    let keys = Keys::generate();
    println!("生成公钥: {}", keys.public_key());
    
    // 2. 初始化中继池
    let relay_pool = RelayPool::new();
    
    // 3. 添加多个中继服务器
    let relays = vec![
        "wss://relay.damus.io",
        "wss://nostr.wine",
        "wss://nos.lol"
    ];
    
    for relay in relays {
        match relay_pool.add_relay(relay, None).await {
            Ok(_) => println!("成功添加中继: {}", relay),
            Err(e) => eprintln!("添加中继失败 ({}): {}", relay, e),
        }
    }
    
    // 4. 连接到所有中继
    println!("连接中继中...");
    relay_pool.connect().await;
    
    // 5. 创建并发送文本事件
    println!("准备发送事件...");
    let event = EventBuilder::new_text_note("Hello from nostr-relay-pool demo!", &[])
        .to_event(&keys)?;
    
    match relay_pool.send_event(event).await {
        Ok(_) => println!("事件发送成功"),
        Err(e) => eprintln!("事件发送失败: {}", e),
    }
    
    // 6. 订阅文本事件
    println!("订阅文本事件...");
    let subscription = Filter::new()
        .kind(Kind::TextNote)
        .limit(10);
    
    relay_pool.subscribe("text-note-subscription", vec![subscription]).await;
    
    // 7. 处理接收到的消息
    println!("开始监听事件...");
    tokio::spawn(async move {
        while let Ok(notification) = relay_pool.notifications().recv().await {
            match notification {
                RelayPoolNotification::Event(sub_id, event) => {
                    println!("[{}] 收到事件 ({}): {}", 
                        sub_id, 
                        event.kind, 
                        event.content
                    );
                },
                RelayPoolNotification::Message(relay_url, message) => {
                    println!("来自 {} 的消息: {:?}", relay_url, message);
                },
                RelayPoolNotification::RelayStatus(url, status) => {
                    println!("中继状态变化: {} -> {:?}", url, status);
                },
                _ => {}
            }
        }
    });
    
    // 8. 等待一段时间让程序运行
    println!("运行30秒...");
    sleep(Duration::from_secs(30)).await;
    
    // 9. 断开所有中继连接
    println!("断开中继连接...");
    relay_pool.disconnect().await?;
    
    println!("程序结束");
    Ok(())
}

这个完整示例扩展了原始示例，增加了：

1. 更多错误处理和日志输出
2. 添加了多个中继服务器的循环处理
3. 增加了对中继状态变化的监听
4. 使用tokio::spawn来异步处理通知
5. 更详细的运行状态输出

注意：该库仍处于ALPHA阶段，API可能会发生变化。使用时请参考最新文档。