re_video

rerun系列crate的一部分。

用于解析视频容器并解码其内容的crate。

它封装了其他crate，以统一解析容器和视频解码器的接口。

元数据

pkg:cargo/re_video@0.24.1

15天前

v1.85.0

MIT OR Apache-2.0

70.3 KiB

安装

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

cargo add re_video

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

re_video = “0.24.1”

主页

rerun.io

文档

docs.rs/re_video/0.24.1

仓库

github.com/rerun-io/rerun

所有者

rerun.io

完整示例代码：

use re_video::{VideoDecoder, Container};

fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 打开视频文件
    let container = Container::open("video.mp4")?;
    
    // 创建视频解码器
    let mut decoder = VideoDecoder::new(container)?;
    
    // 解码视频帧
    while let Some(frame) = decoder.next_frame()? {
        // 处理视频帧数据
        let frame_data = frame.data();
        println!("Decoded frame with size: {} bytes", frame_data.len());
        
        // 这里可以添加流媒体播放逻辑
        // 例如将帧数据发送到显示设备或网络流
    }
    
    Ok(())
}

// 更完整的示例，包含错误处理和配置选项
use re_video::{VideoDecoder, Container, DecoderConfig};

fn advanced_video_processing() -> Result<(), Box<dyn std::error::Error>> {
    // 配置解码器参数
    let config = DecoderConfig {
        enable_hardware_acceleration: true,
        max_frame_buffer_size: Some(10), // 限制帧缓冲区大小
        ..Default::default()
    };
    
    // 打开视频容器
    let container = Container::open("input_video.mkv")?;
    
    // 使用配置创建解码器
    let mut decoder = VideoDecoder::with_config(container, config)?;
    
    // 获取视频元数据
    let metadata = decoder.metadata();
    println!("Video duration: {:?}", metadata.duration);
    println!("Frame rate: {}", metadata.frame_rate);
    println!("Resolution: {}x{}", metadata.width, metadata.height);
    
    // 逐帧解码和处理
    let mut frame_count = 0;
    while let Some(frame) = decoder.next_frame()? {
        frame_count += 1;
        
        let frame_data = frame.data();
        let timestamp = frame.timestamp();
        
        println!("Frame {} at {}ms: {} bytes", 
                frame_count, 
                timestamp.as_millis(),
                frame_data.len());
        
        // 这里可以实现编解码转换或流媒体传输
        // 例如将帧编码为不同的格式或通过网络流式传输
    }
    
    println!("Total frames decoded: {}", frame_count);
    Ok(())
}

完整示例demo：

use re_video::{VideoDecoder, Container, DecoderConfig, Frame};
use std::error::Error;
use std::time::Duration;

/// 视频处理示例：解码视频并提取关键信息
fn process_video_file(video_path: &str) -> Result<(), Box<dyn Error>> {
    // 配置解码器参数
    let config = DecoderConfig {
        enable_hardware_acceleration: true,  // 启用硬件加速
        max_frame_buffer_size: Some(15),     // 设置帧缓冲区大小限制
        ..Default::default()
    };
    
    // 打开视频容器
    println!("Opening video file: {}", video_path);
    let container = Container::open(video_path)?;
    
    // 使用配置创建解码器
    let mut decoder = VideoDecoder::with_config(container, config)?;
    
    // 获取并显示视频元数据
    let metadata = decoder.metadata();
    println!("=== Video Metadata ===");
    println!("Duration: {:?}", metadata.duration);
    println!("Frame rate: {:.2} fps", metadata.frame_rate);
    println!("Resolution: {}x{}", metadata.width, metadata.height);
    println!("Codec: {:?}", metadata.codec);
    println!("======================");
    
    // 解码和处理每一帧
    let mut frame_count = 0;
    let mut total_bytes = 0;
    let start_time = std::time::Instant::now();
    
    while let Some(frame) = decoder.next_frame()? {
        frame_count += 1;
        
        // 获取帧数据和时间戳
        let frame_data = frame.data();
        let timestamp = frame.timestamp();
        total_bytes += frame_data.len();
        
        // 每10帧显示一次进度
        if frame_count % 10 == 0 {
            let elapsed = start_time.elapsed();
            let fps = frame_count as f64 / elapsed.as_secs_f64();
            println!("Frame {} @ {}ms - Size: {} bytes (FPS: {:.1})", 
                    frame_count, 
                    timestamp.as_millis(),
                    frame_data.len(),
                    fps);
        }
        
        // 这里可以添加自定义的视频处理逻辑
        // process_frame_data(&frame_data, timestamp);
    }
    
    // 输出解码统计信息
    let elapsed = start_time.elapsed();
    println!("\n=== Decoding Complete ===");
    println!("Total frames: {}", frame_count);
    println!("Total data: {} MB", total_bytes / 1024 / 1024);
    println!("Decoding time: {:.2}s", elapsed.as_secs_f64());
    println!("Average FPS: {:.1}", frame_count as f64 / elapsed.as_secs_f64());
    
    Ok(())
}

/// 帧数据处理函数示例
fn process_frame_data(frame_data: &[u8], timestamp: Duration) {
    // 示例：简单的帧数据分析
    let avg_brightness = frame_data.iter().map(|&b| b as u32).sum::<u32>() / frame_data.len() as u32;
    
    // 可以根据需要实现更复杂的处理逻辑
    // 如：图像处理、特征提取、编码转换等
}

fn main() -> Result<(), Box<dyn Error>> {
    // 处理视频文件
    process_video_file("example_video.mp4")?;
    
    Ok(())
}

/// 高级功能示例：视频流处理
#[allow(dead_code)]
fn stream_processing_example() -> Result<(), Box<dyn Error>> {
    use std::io::Write;
    
    let container = Container::open("stream.mp4")?;
    let mut decoder = VideoDecoder::new(container)?;
    
    // 创建输出文件（模拟流媒体输出）
    let mut output_file = std::fs::File::create("output_stream.bin")?;
    
    while let Some(frame) = decoder.next_frame()? {
        let frame_data = frame.data();
        
        // 将帧数据写入输出流
        output_file.write_all(frame_data)?;
        
        // 这里可以实现网络流传输
        // network_stream.send(frame_data);
    }
    
    Ok(())
}