rtsp

README

RTSP插件

rtsp插件提供rtsp协议的推拉流能力，以及向远程服务器推拉rtsp协议的能力。

插件地址

https://github.com/Monibuca/plugin-rtsp

插件引入

import (
    _ "m7s.live/plugin/rtsp/v4"
)

推拉地址形式

rtsp://localhost/live/test

• localhost是m7s的服务器域名或者IP地址，默认端口554可以不写，否则需要写
• live代表appName
• test代表streamName
• m7s中live/test将作为streamPath为流的唯一标识

例如通过ffmpeg向m7s进行推流

ffmpeg -i [视频源] -c:v h264 -c:a aac -f rtsp rtsp://localhost/live/test

会在m7s内部形成一个名为live/test的流

如果m7s中已经存在live/test流的话就可以用rtsp协议进行播放

ffplay rtsp://localhost/live/test

配置

rtsp:
    publish:
        pubaudio: true # 是否发布音频流
        pubvideo: true # 是否发布视频流
        kickexist: false # 剔出已经存在的发布者，用于顶替原有发布者
        publishtimeout: 10s # 发布流默认过期时间，超过该时间发布者没有恢复流将被删除
        delayclosetimeout: 0 # 自动关闭触发后延迟的时间(期间内如果有新的订阅则取消触发关闭)，0为关闭该功能，保持连接。
        waitclosetimeout: 0 # 发布者断开后等待时间，超过该时间发布者没有恢复流将被删除，0为关闭该功能，由订阅者决定是否删除
        buffertime: 0 # 缓存时间，用于时光回溯，0为关闭缓存
    subscribe:
        subaudio: true # 是否订阅音频流
        subvideo: true # 是否订阅视频流
        subaudioargname: ats # 订阅音频轨道参数名
        subvideoargname: vts # 订阅视频轨道参数名
        subdataargname: dts # 订阅数据轨道参数名
        subaudiotracks: [] # 订阅音频轨道名称列表
        subvideotracks: [] # 订阅视频轨道名称列表
        submode: 0 # 订阅模式，0为跳帧追赶模式，1为不追赶（多用于录制），2为时光回溯模式
        iframeonly: false # 只订阅关键帧
        waittimeout: 10s # 等待发布者的超时时间，用于订阅尚未发布的流
    pull:
        repull: 0
        pullonstart: {}
        pullonsub: {}
    push:
        repush: 0
        pushlist: {}
    listenaddr: :554
    udpaddr: :8000
    rtcpaddr: :8001
    readbuffersize: 2048
    pullprotocol: 'auto'

:::tip 配置覆盖 publish subscribe 两项中未配置部分将使用全局配置 :::

API

rtsp/api/list

获取所有rtsp流

rtsp/api/pull?target=[RTSP地址]&streamPath=[流标识]

从远程拉取rtsp到m7s中

rtsp/api/push?target=[RTSP地址]&streamPath=[流标识]

将本地的流推送到远端

Documentation

Index

• Variables
• type RTSPConfig
  • func (*RTSPConfig) API_Pull(rw http.ResponseWriter, r *http.Request)
  • func (*RTSPConfig) API_Push(rw http.ResponseWriter, r *http.Request)
  • func (*RTSPConfig) API_list(w http.ResponseWriter, r *http.Request)
  • func (conf *RTSPConfig) OnAnnounce(ctx *gortsplib.ServerHandlerOnAnnounceCtx) (*base.Response, error)
  • func (conf *RTSPConfig) OnConnClose(ctx *gortsplib.ServerHandlerOnConnCloseCtx)
  • func (conf *RTSPConfig) OnConnOpen(ctx *gortsplib.ServerHandlerOnConnOpenCtx)
  • func (conf *RTSPConfig) OnDescribe(ctx *gortsplib.ServerHandlerOnDescribeCtx) (*base.Response, *gortsplib.ServerStream, error)
  • func (conf *RTSPConfig) OnEvent(event any)
  • func (conf *RTSPConfig) OnPlay(ctx *gortsplib.ServerHandlerOnPlayCtx) (*base.Response, error)
  • func (conf *RTSPConfig) OnRecord(ctx *gortsplib.ServerHandlerOnRecordCtx) (*base.Response, error)
  • func (conf *RTSPConfig) OnSessionClose(ctx *gortsplib.ServerHandlerOnSessionCloseCtx)
  • func (conf *RTSPConfig) OnSessionOpen(ctx *gortsplib.ServerHandlerOnSessionOpenCtx)
  • func (conf *RTSPConfig) OnSetup(ctx *gortsplib.ServerHandlerOnSetupCtx) (*base.Response, *gortsplib.ServerStream, error)
• type RTSPIO
• type RTSPPublisher
  • func (p *RTSPPublisher) OnPacket(m *media.Media, f format.Format, pack *rtp.Packet)
  • func (p *RTSPPublisher) SetTracks() error
• type RTSPPuller
  • func (p *RTSPPuller) Connect() error
  • func (p *RTSPPuller) Pull() (err error)
• type RTSPPusher
  • func (p *RTSPPusher) Connect() error
  • func (p *RTSPPusher) OnEvent(event any)
  • func (p *RTSPPusher) Push() (err error)
• type RTSPSubscriber
  • func (s *RTSPSubscriber) OnEvent(event any)

Variables

var RTSPPlugin = InstallPlugin(rtspConfig)

Types

type RTSPConfig

type RTSPConfig struct {
	config.Publish
	config.Subscribe
	config.Pull
	config.Push
	ListenAddr     string
	UDPAddr        string
	RTCPAddr       string
	ReadBufferSize int
	PullProtocol   string //tcp、udp、 auto（default）
	sync.Map
}

func (*RTSPConfig) API_Pull

func (*RTSPConfig) API_Pull(rw http.ResponseWriter, r *http.Request)

func (*RTSPConfig) API_Push

func (*RTSPConfig) API_Push(rw http.ResponseWriter, r *http.Request)

func (*RTSPConfig) API_list

func (*RTSPConfig) API_list(w http.ResponseWriter, r *http.Request)

func (*RTSPConfig) OnAnnounce

func (conf *RTSPConfig) OnAnnounce(ctx *gortsplib.ServerHandlerOnAnnounceCtx) (*base.Response, error)

func (*RTSPConfig) OnConnClose

func (conf *RTSPConfig) OnConnClose(ctx *gortsplib.ServerHandlerOnConnCloseCtx)

func (*RTSPConfig) OnConnOpen

func (conf *RTSPConfig) OnConnOpen(ctx *gortsplib.ServerHandlerOnConnOpenCtx)

func (*RTSPConfig) OnDescribe

func (conf *RTSPConfig) OnDescribe(ctx *gortsplib.ServerHandlerOnDescribeCtx) (*base.Response, *gortsplib.ServerStream, error)

called after receiving a DESCRIBE request.

func (*RTSPConfig) OnEvent

func (conf *RTSPConfig) OnEvent(event any)

func (*RTSPConfig) OnPlay

func (conf *RTSPConfig) OnPlay(ctx *gortsplib.ServerHandlerOnPlayCtx) (*base.Response, error)

func (*RTSPConfig) OnRecord

func (conf *RTSPConfig) OnRecord(ctx *gortsplib.ServerHandlerOnRecordCtx) (*base.Response, error)

func (*RTSPConfig) OnSessionClose

func (conf *RTSPConfig) OnSessionClose(ctx *gortsplib.ServerHandlerOnSessionCloseCtx)

func (*RTSPConfig) OnSessionOpen

func (conf *RTSPConfig) OnSessionOpen(ctx *gortsplib.ServerHandlerOnSessionOpenCtx)

func (*RTSPConfig) OnSetup

func (conf *RTSPConfig) OnSetup(ctx *gortsplib.ServerHandlerOnSetupCtx) (*base.Response, *gortsplib.ServerStream, error)

type RTSPIO

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

type RTSPPublisher

type RTSPPublisher struct {
	Publisher
	Tracks map[*media.Media]common.AVTrack `json:"-"`
	RTSPIO
}

func (*RTSPPublisher) OnPacket

func (p *RTSPPublisher) OnPacket(m *media.Media, f format.Format, pack *rtp.Packet)

func (*RTSPPublisher) SetTracks

func (p *RTSPPublisher) SetTracks() error

type RTSPPuller

type RTSPPuller struct {
	RTSPPublisher
	engine.Puller
	*gortsplib.Client `json:"-"`
	gortsplib.Transport
}

func (*RTSPPuller) Connect

func (p *RTSPPuller) Connect() error

func (*RTSPPuller) Pull

func (p *RTSPPuller) Pull() (err error)

type RTSPPusher

type RTSPPusher struct {
	RTSPSubscriber
	engine.Pusher
	*gortsplib.Client
	gortsplib.Transport
}

func (*RTSPPusher) Connect

func (p *RTSPPusher) Connect() error

func (*RTSPPusher) OnEvent

func (p *RTSPPusher) OnEvent(event any)

func (*RTSPPusher) Push

func (p *RTSPPusher) Push() (err error)

type RTSPSubscriber

type RTSPSubscriber struct {
	Subscriber
	RTSPIO
}

func (*RTSPSubscriber) OnEvent

func (s *RTSPSubscriber) OnEvent(event any)