Rust SSDP客户端库 ssdp-client 使用指南

简介

ssdp-client 是一个用于实现简单服务发现协议(SSDP)的Rust库，它允许你在本地网络中搜索UPnP设备和服务。SSDP是UPnP(通用即插即用)协议的基础，常用于发现网络设备如智能电视、媒体服务器、路由器等。

主要功能

• 发送M-SEARCH请求发现网络设备
• 监听SSDP通知消息
• 解析设备响应和通知
• 支持IPv4和IPv6

安装

在Cargo.toml中添加依赖：

[dependencies]
ssdp-client = "0.1"

基本使用方法

1. 搜索网络设备

use ssdp_client::SearchTarget;
use std::time::Duration;

async fn search_devices() -> Result<(), Box<dyn std::error::Error>> {
    // 创建搜索请求
    let search_target = SearchTarget::RootDevices;
    let timeout = Duration::from_secs(3);
    
    // 发送搜索请求并接收响应
    let responses = ssdp_client::search(&search_target, timeout, 2).await?;
    
    // 处理响应
    for response in responses {
        println!("发现设备:");
        println!("位置: {}", response.location());
        println!("USN: {}", response.usn());
        println!("服务类型: {}", response.search_target());
        println!("缓存时间: {}秒", response.cache_control());
        println!();
    }
    
    Ok(())
}

#[tokio::main]
async fn main() {
    if let Err(e) = search_devices().await {
        eprintln!("错误: {}", e);
    }
}

2. 监听通知消息

use ssdp_client::NotifyHeaders;
use std::time::Duration;

async fn listen_notifications() -> Result<(), Box<dyn std::error::Error>> {
    // 创建通知接收器
    let mut receiver = ssdp_client::listen_notify().await?;
    
    println!("开始监听SSDP通知...");
    
    // 接收通知消息
    while let Ok(notification) = receiver.recv_timeout(Duration::from_secs(10)).await {
        match notification {
            NotifyHeaders::Alive(alive) => {
                println!("设备上线通知:");
                println!("USN: {}", alive.usn);
                println!("位置: {}", alive.location);
                println!("服务类型: {}", alive.notification_type);
                println!("缓存时间: {}秒", alive.cache_control);
            },
            NotifyHeaders::Update(update) => {
                println!("设备更新通知:");
                println!("USN: {}", update.usn);
                println!("位置: {}", update.location);
                println!("新USN: {}", update.new_usn);
            },
            NotifyHeaders::Byebye(byebye) => {
                println!("设备下线通知:");
                println!("USN: {}", byebye.usn);
                println!("服务类型: {}", byebye.notification_type);
            }
        }
        println!();
    }
    
    Ok(())
}

#[tokio::main]
async fn main() {
    if let Err(e) = listen_notifications().await {
        eprintln!("错误: {}", e);
    }
}

高级用法

自定义搜索目标

use ssdp_client::SearchTarget;

// 搜索特定类型的设备
let media_server_target = SearchTarget::URN("schemas-upnp-org", "device", "MediaServer", 1);

// 搜索特定服务
let content_directory_target = SearchTarget::URN("schemas-upnp-org", "service", "ContentDirectory", 1);

处理设备描述信息

发现设备后，通常需要获取设备的详细描述：

use reqwest;

async fn fetch_device_description(location: &str) -> Result<String, Box<dyn std::error::Error>> {
    let resp = reqwest::get(location).await?;
    let description = resp.text().await?;
    Ok(description)
}

注意事项

1. SSDP使用UDP多播地址239.255.255.250和端口1900
2. 确保网络允许SSDP通信（防火墙设置）
3. 搜索响应可能会有延迟，适当设置超时时间
4. 设备可能会发送多个响应

完整示例：发现所有媒体服务器

use ssdp_client::SearchTarget;
use std::time::Duration;

async fn discover_media_servers() -> Result<(), Box<dyn std::error::Error>> {
    let target = SearchTarget::URN("schemas-upnp-org", "device", "MediaServer", 1);
    let timeout = Duration::from_secs(5);
    
    println!("搜索媒体服务器...");
    
    let responses = ssdp_client::search(&target, timeout, 3).await?;
    
    if responses.is_empty() {
        println!("未发现媒体服务器");
    } else {
        println!("发现 {} 个媒体服务器:", responses.len());
        for (i, response) in responses.iter().enumerate() {
            println!("\n服务器 #{}:", i + 1);
            println!("名称: {}", response.server());
            println!("位置: {}", response.location());
            println!("USN: {}", response.usn());
        }
    }
    
    Ok(())
}

#[tokio::main]
async fn main() {
    if let Err(e) = discover_media_servers().await {
        eprintln!("错误: {}", e);
    }
}

这个库为Rust开发者提供了简单而强大的SSDP功能实现，可以方便地集成到各种网络应用和设备发现场景中。