rtcrtmp

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
• Variables
• type RTCRouter
  • func NewRTCRouter(streamURL string, endpoint string) (router *RTCRouter, err error)
  • func (self *RTCRouter) CreateSubscriber() (*RTCTransport, error)
  • func (self *RTCRouter) Stop() (err error)
  • func (self *RTCRouter) StopSubscriber(transport *RTCTransport)
• type RTCStreamer
• type RTCTransport
  • func NewRTCTransport(id string, endpoint string) (*RTCTransport, error)
  • func (self *RTCTransport) GetLocalSDP(sdpType webrtc.SDPType) (string, error)
  • func (self *RTCTransport) ID() string
  • func (self *RTCTransport) SetRemoteSDP(sdpstr string, sdpType webrtc.SDPType) error
  • func (self *RTCTransport) Stop() (err error)
  • func (self *RTCTransport) WriteRTP(packet *rtp.Packet) (err error)
• type RtmpStreamer
  • func NewRtmpStreamer(streamURL string) (*RtmpStreamer, error)
  • func (r *RtmpStreamer) Close()
  • func (r *RtmpStreamer) GetLocalSDP(sdpType webrtc.SDPType) (string, error)
  • func (r *RtmpStreamer) PullStream()
  • func (r *RtmpStreamer) SetRemoteSDP(sdpStr string, sdpType webrtc.SDPType) error

Constants

const (
	DefaultOpusSSRC = 111111111
	DefaultH264SSRC = 333333333

	OpusPayloadType = 111
	H264PayloadTYpe = 127
)

Variables

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

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