jittr

지트르

대기 시간이 없는 UDP/RTP 스트림을 위한 바이너리 힙 기반 지터 버퍼 구현

이 구현은 네트워크 지터를 방지하고 UDP 패킷을 통해 안정적인 미디어 스트림을 생성하도록 설계되었습니다. 순서가 지정되지 않은 패킷과 다양한 네트워크 지연은 UDP(대부분 RTP)를 통해 오디오를 지속적으로 스트리밍하려고 할 때 가장 큰 문제 중 하나입니다. 이 데이터 구조는 패킷을 버퍼링하고 지연을 최소화하면서 순서를 변경합니다.

예

작

지터 버퍼를 통해 udp/rtp 스트림에서 opus 패킷을 재생합니다.

 use async_std :: stream :: interval ;
use std :: time :: Duration ;
use jittr :: { JitterBuffer , Packet } ;

let mut rtp_stream = /* your rtp stream */ ;

/// Your Packet implementation
struct Opus { .. }
impl Packet for Opus { .. }

/// Create a jitter buffer for Opus packets
/// It can hold up to 10 packets before it starts to discard old packets
let mut jitter = JitterBuffer :: < Opus , 10 > :: new ( ) ;

/// Create an interval for packet playback
/// A typical length for audio packets is between 10 and 20ms
let mut playback = interval ( Duration :: from_millis ( 20 ) ) ;

loop {
    futures :: select! {
        _ = playback . next ( ) . fuse ( ) => {
            let packet = jittr . pop ( ) ;

            let pcm = /* Opus decodes audio if present or infers if none */

            // Write pcm to speaker
        } ,
        rtp = rtp_stream . next ( ) . fuse ( ) => {
            let opus : Opus = rtp . unwrap ( ) ;
            jittr . push ( opus ) ;
        } ,
    }
} 

이 코드는 원래 HUM Systems에서 게시되었습니다. 이 저장소는 안타깝게도 오픈 소스 노력을 중단하면서 이 라이브러리의 개발을 계속하고 있습니다.