rtcrtmp

package module
v0.0.0-...-e6d42a4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 5, 2020 License: MIT Imports: 18 Imported by: 0

README

rtc-rtmp

WebRTC to RTMP and RTMP to WebRTC

Install


cd  rtc-rtmp/
go get ./...

cd examples/rtmp2rtc/

go run main.go


打开obs  推 rtmp://127.0.0.1/live/live
打开浏览器  http://127.0.0.1:8000/

Documentation

Index

Constants

View Source
const (
	DefaultOpusSSRC = 111111111
	DefaultH264SSRC = 333333333

	OpusPayloadType = 111
	H264PayloadTYpe = 127
)

Variables

View Source
var NALUHeader = []byte{0, 0, 0, 1}

Functions

This section is empty.

Types

type RTCRouter

type RTCRouter struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRTCRouter

func NewRTCRouter(streamURL string, endpoint string) (router *RTCRouter, err error)

func (*RTCRouter) CreateSubscriber

func (self *RTCRouter) CreateSubscriber() (*RTCTransport, error)

func (*RTCRouter) Stop

func (self *RTCRouter) Stop() (err error)

func (*RTCRouter) StopSubscriber

func (self *RTCRouter) StopSubscriber(transport *RTCTransport)

type RTCStreamer

type RTCStreamer struct {
}

type RTCTransport

type RTCTransport struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRTCTransport

func NewRTCTransport(id string, endpoint string) (*RTCTransport, error)

func (*RTCTransport) GetLocalSDP

func (self *RTCTransport) GetLocalSDP(sdpType webrtc.SDPType) (string, error)

func (*RTCTransport) ID

func (self *RTCTransport) ID() string

func (*RTCTransport) SetRemoteSDP

func (self *RTCTransport) SetRemoteSDP(sdpstr string, sdpType webrtc.SDPType) error

func (*RTCTransport) Stop

func (self *RTCTransport) Stop() (err error)

func (*RTCTransport) WriteRTP

func (self *RTCTransport) WriteRTP(packet *rtp.Packet) (err error)

type RtmpStreamer

type RtmpStreamer struct {
	// contains filtered or unexported fields
}

func NewRtmpStreamer

func NewRtmpStreamer(streamURL string) (*RtmpStreamer, error)

func (*RtmpStreamer) Close

func (r *RtmpStreamer) Close()

func (*RtmpStreamer) GetLocalSDP

func (r *RtmpStreamer) GetLocalSDP(sdpType webrtc.SDPType) (string, error)

func (*RtmpStreamer) PullStream

func (r *RtmpStreamer) PullStream()

func (*RtmpStreamer) SetRemoteSDP

func (r *RtmpStreamer) SetRemoteSDP(sdpStr string, sdpType webrtc.SDPType) error

Directories

Path Synopsis
examples

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL