mirror of
https://github.com/pion/mediadevices.git
synced 2025-09-26 20:41:46 +08:00
d86fc4a3e9
I420 format is a common format that's required by encoders. Therefore, the video pipeline is significantly faster than other formats since there's no format conversion.
79 lines
1.6 KiB
Go
79 lines
1.6 KiB
Go
package main
|
|
|
|
import (
|
|
"fmt"
|
|
"math/rand"
|
|
"net"
|
|
"os"
|
|
|
|
"github.com/pion/mediadevices"
|
|
"github.com/pion/mediadevices/pkg/codec/x264" // This is required to use H264 video encoder
|
|
_ "github.com/pion/mediadevices/pkg/driver/camera" // This is required to register camera adapter
|
|
"github.com/pion/mediadevices/pkg/frame"
|
|
"github.com/pion/mediadevices/pkg/prop"
|
|
)
|
|
|
|
const (
|
|
mtu = 1000
|
|
)
|
|
|
|
func must(err error) {
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
}
|
|
|
|
func main() {
|
|
if len(os.Args) != 2 {
|
|
fmt.Printf("usage: %s host:port\n", os.Args[0])
|
|
return
|
|
}
|
|
dest := os.Args[1]
|
|
|
|
x264Params, err := x264.NewParams()
|
|
must(err)
|
|
x264Params.Preset = x264.PresetMedium
|
|
x264Params.BitRate = 1_000_000 // 1mbps
|
|
|
|
codecSelector := mediadevices.NewCodecSelector(
|
|
mediadevices.WithVideoEncoders(&x264Params),
|
|
)
|
|
|
|
mediaStream, err := mediadevices.GetUserMedia(mediadevices.MediaStreamConstraints{
|
|
Video: func(c *mediadevices.MediaTrackConstraints) {
|
|
c.FrameFormat = prop.FrameFormat(frame.FormatI420)
|
|
c.Width = prop.Int(640)
|
|
c.Height = prop.Int(480)
|
|
},
|
|
Codec: codecSelector,
|
|
})
|
|
must(err)
|
|
|
|
videoTrack := mediaStream.GetVideoTracks()[0]
|
|
defer videoTrack.Close()
|
|
|
|
rtpReader, err := videoTrack.NewRTPReader(x264Params.RTPCodec().MimeType, rand.Uint32(), mtu)
|
|
must(err)
|
|
|
|
addr, err := net.ResolveUDPAddr("udp", dest)
|
|
must(err)
|
|
conn, err := net.DialUDP("udp", nil, addr)
|
|
must(err)
|
|
|
|
buff := make([]byte, mtu)
|
|
for {
|
|
pkts, release, err := rtpReader.Read()
|
|
must(err)
|
|
|
|
for _, pkt := range pkts {
|
|
n, err := pkt.MarshalTo(buff)
|
|
must(err)
|
|
|
|
_, err = conn.Write(buff[:n])
|
|
must(err)
|
|
}
|
|
|
|
release()
|
|
}
|
|
}
|