Rust RTP协议处理库rtp-types的使用

简介

rtp-types是一个用于处理RTP协议(RFC 3550)的Rust库，包含解析器和写入器功能。

许可证

rtp-types采用双重许可证：

• MIT许可证
• Apache 2.0许可证

贡献

欢迎任何形式的贡献，可以通过提交pull request参与。除非您明确声明，否则您提交的贡献将被视为同时授权MIT许可证和Apache 2.0许可证。

安装

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

cargo add rtp-types

或者在Cargo.toml中添加：

rtp-types = "0.1.2"

使用示例

下面是一个完整的rtp-types库使用示例，展示如何解析和创建RTP包：

use rtp_types::{RtpPacket, MediaType};

fn main() {
    // 创建一个新的RTP包
    let mut packet = RtpPacket::new(
        96,                 // 负载类型
        12345,              // 序列号
        987654321,          // 时间戳
        123456789,          // SSRC
        vec![0x01, 0x02, 0x03], // 负载数据
    );
    
    // 设置标记位
    packet.set_marker(true);
    
    // 设置媒体类型
    packet.set_media_type(MediaType::Video);
    
    // 序列化为字节
    let bytes = packet.to_vec();
    println!("Serialized RTP packet: {:?}", bytes);
    
    // 从字节解析RTP包
    match RtpPacket::parse(&bytes) {
        Ok(parsed_packet) => {
            println!("Parsed RTP packet:");
            println!("Version: {}", parsed_packet.version());
            println!("Payload Type: {}", parsed_packet.payload_type());
            println!("Sequence Number: {}", parsed_packet.sequence_number());
            println!("Timestamp: {}", parsed_packet.timestamp());
            println!("SSRC: {}", parsed_packet.ssrc());
            println!("Payload: {:?}", parsed_packet.payload());
        }
        Err(e) => {
            println!("Failed to parse RTP packet: {}", e);
        }
    }
}

完整示例demo

以下是基于上述示例扩展的完整demo，展示更多rtp-types库的功能：

use rtp_types::{RtpPacket, MediaType, Extension, ExtensionMap};

fn main() {
    // 创建一个带有扩展头的RTP包
    let mut packet = RtpPacket::new(
        96,                            // 负载类型
        54321,                         // 序列号
        1234567890,                    // 时间戳
        987654321,                     // SSRC
        vec![0xAA, 0xBB, 0xCC, 0xDD],  // 负载数据
    );

    // 设置RTP头部属性
    packet.set_marker(true);
    packet.set_media_type(MediaType::Audio);
    packet.set_padding(true);

    // 创建扩展映射
    let mut extensions = ExtensionMap::new();
    extensions.add_extension(Extension::new(1, 16)); // ID=1, 长度=16字节

    // 设置扩展数据
    let ext_data = vec![0x01, 0x02, 0x03, 0x04];
    packet.set_extensions(&extensions, &ext_data).unwrap();

    // 序列化RTP包
    let serialized = packet.to_vec();
    println!("Serialized RTP packet with extensions: {:?}", serialized);

    // 解析RTP包
    match RtpPacket::parse(&serialized) {
        Ok(parsed) => {
            println!("Successfully parsed RTP packet:");
            println!("Version: {}", parsed.version());
            println!("Padding: {}", parsed.has_padding());
            println!("Marker: {}", parsed.marker());
            println!("Payload Type: {}", parsed.payload_type());
            println!("Sequence Number: {}", parsed.sequence_number());
            println!("Timestamp: {}", parsed.timestamp());
            println!("SSRC: {}", parsed.ssrc());
            
            // 获取扩展数据
            if let Some(ext) = parsed.extensions(&extensions) {
                println!("Extension data: {:?}", ext);
            }
            
            println!("Payload length: {} bytes", parsed.payload().len());
        }
        Err(e) => println!("Failed to parse RTP packet: {}", e),
    }

    // 修改并重新序列化包
    if let Ok(mut parsed_packet) = RtpPacket::parse(&serialized) {
        parsed_packet.set_sequence_number(9999);
        parsed_packet.set_timestamp(555555555);
        
        let modified_bytes = parsed_packet.to_vec();
        println!("Modified RTP packet: {:?}", modified_bytes);
    }
}

文档

更多详细使用说明请参考官方文档。

分类

• 编码
• 多媒体
• 多媒体::编码
• 网络编程
• 解析工具