server-rust-gstreamer-rtp

Example of usage of Gstreamer bindings for Rust

Authors

• Guilherme Marcello <guilemosmarcello@gmail.com> - @guilherme-marcello

Run Locally

Install Rust toolchain manager (optional)

curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh

Clone the project

  git clone https://github.com/guilherme-marcello/server-rust-gstreamer-rtp

Go to the project directory

  cd server-rust-gstreamer-rtp

Build project

  cargo build --release

Start the server

  ./target/release/server-rust-gstreamer-rtp

Deployment with Docker

Build the app's container image

  docker build -t server-rust-gstreamer-rtp .

Start a container running the image we just created

  docker run --rm -e UDP_HOST=${HOST_IP} server-rust-gstreamer-rtp

Packet sniffing

Capture incoming packets from container

  tcpdump -v -i any -n udp port ${UDP_PORT}

Or, process incoming UDP packets using gst-launch-1.0 and display the video stream on the screen

  gst-launch-1.0 -v udpsrc port=${UDP_PORT} ! "application/x-rtp, media=(string)video, clock-rate=(int)90000, encoding-name=(string)H264, payload=(int)96" ! rtph264depay ! h264parse ! decodebin ! videoconvert ! autovideosink sync=false

Documentation

new(), start() and build() are the default desired "signatures" for our pipeline usage inside a Gstreamer application.

• new() → create a pipeline without any elements in the bin

• build() → create all the necessary Gst elements, links them together and adds them to the bin (Using ENV variables).

• start() → change the pipeline state to PLAYING.

So a trait was created for this purpose, named "BasicPipeline".

// ./src/utils/ingestor.rs
pub trait BasicPipeline {
    fn new() -> Self;
    fn start(&self);
    fn build(&self);
}

The main advantage of this approach for pipeline design is that we can call the same methods on all of the defined pipelines.

This way, whenever we want to add a new pipeline in our project, for example, we create a struct named 'NewPipeline' and do the implementation of the BasicPipeline trait on the 'NewPipeline' struct:

// ./src/utils/ingestor.rs
pub struct NewPipeline {
    pipeline: Pipeline
}

impl BasicPipeline for NewPipeline {
    fn new() -> Self {
      ...
    }

    fn build(&self) {
      ...
    }

    fn start(&self) {
      ...
    }
}

Feedback

If you have any feedback, please reach out to me at guilemosmarcello@gmail.com

License

MIT