rtsp

README

RTSP插件

插件地址

github.com/Monibuca/plugin-rtsp

插件引入

import (
    _ "github.com/Monibuca/plugin-rtsp"
)

默认插件配置

[RTSP]
# 端口接收推流
ListenAddr = ":554"
Reconnect = true
[RTSP.AutoPullList]
"live/rtsp1" = "rtsp://admin:admin@192.168.1.212:554/cam/realmonitor?channel=1&subtype=1"
"live/rtsp2" = "rtsp://admin:admin@192.168.1.212:554/cam/realmonitor?channel=2&subtype=1"

• ListenAddr是监听的地址
• Reconnect 是否自动重连
• RTSP.AutoPullList 可以配置多项，用于自动拉流，key是streamPath，value是远程rtsp地址

特殊功能

当自动拉流列表中当的streamPath为sub/xxx 这种形式的话，在gb28181的分屏显示时会优先采用rtsp流，已实现分屏观看子码流效果

插件功能

接收RTSP协议的推流

例如通过ffmpeg向m7s进行推流

ffmpeg -i **** rtsp://localhost/live/test

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

从远程拉取rtsp到m7s中

可调用接口 /api/rtsp/pull?target=[RTSP地址]&streamPath=[流标识]

使用编程方式拉流

new(RTSPClient).PullStream("live/user1","rtsp://xxx.xxx.xxx.xxx/live/user1") 

罗列所有的rtsp协议的流

可调用接口 /api/rtsp/list

从m7s中拉取rtsp协议流

直接通过协议rtsp://xxx.xxx.xxx.xxx/live/user1 即可播放

h265 编码拉流尚未实现，敬请期待

Documentation

Index

• func ListenRtsp(addr string) error
• func NewG711Track(payloadType uint8, law string) *gortsplib.Track
• func NewH265Track(payloadType uint8, sprop [][]byte) *gortsplib.Track
• type AACPayloader
  • func (p *AACPayloader) Payload(mtu uint16, payload []byte) [][]byte
• type H265Payloader
  • func (p *H265Payloader) Payload(mtu uint16, payload []byte) [][]byte
• type RTSPClient
  • func (rtsp *RTSPClient) PullStream(streamPath string, rtspUrl string) (err error)
  • func (rtsp *RTSPClient) PushStream(streamPath string, rtspUrl string) (err error)
• type RTSPServer
  • func (sh *RTSPServer) OnAnnounce(ctx *gortsplib.ServerHandlerOnAnnounceCtx) (*base.Response, error)
  • func (sh *RTSPServer) OnConnClose(ctx *gortsplib.ServerHandlerOnConnCloseCtx)
  • func (sh *RTSPServer) OnConnOpen(ctx *gortsplib.ServerHandlerOnConnOpenCtx)
  • func (sh *RTSPServer) OnDescribe(ctx *gortsplib.ServerHandlerOnDescribeCtx) (*base.Response, *gortsplib.ServerStream, error)
  • func (sh *RTSPServer) OnPacketRTP(ctx *gortsplib.ServerHandlerOnPacketRTPCtx)
  • func (sh *RTSPServer) OnPlay(ctx *gortsplib.ServerHandlerOnPlayCtx) (*base.Response, error)
  • func (sh *RTSPServer) OnRecord(ctx *gortsplib.ServerHandlerOnRecordCtx) (*base.Response, error)
  • func (sh *RTSPServer) OnSessionClose(ctx *gortsplib.ServerHandlerOnSessionCloseCtx)
  • func (sh *RTSPServer) OnSessionOpen(ctx *gortsplib.ServerHandlerOnSessionOpenCtx)
  • func (sh *RTSPServer) OnSetup(ctx *gortsplib.ServerHandlerOnSetupCtx) (*base.Response, *gortsplib.ServerStream, error)
• type RTSPSubscriber
• type RTSPublisher

Functions

func ListenRtsp

func ListenRtsp(addr string) error

func NewG711Track

func NewG711Track(payloadType uint8, law string) *gortsplib.Track

	return &gortsplib.Track{
		Media: &psdp.MediaDescription{
			MediaName: psdp.MediaName{
				Media:   "audio",
				Protos:  []string{"RTP", "AVP"},
				Formats: []string{typ},
			},
			Attributes: []psdp.Attribute{
				{
					Key: "rtpmap",
					Value: typ + " mpeg4-generic/" + strconv.FormatInt(int64(conf.SampleRate), 10) +
						"/" + strconv.FormatInt(int64(conf.ChannelCount), 10),
				},
				{
					Key: "fmtp",
					Value: typ + " profile-level-id=1; " +
						"mode=AAC-hbr; " +
						"sizelength=6; " +
						"indexlength=2; " +
						"indexdeltalength=2; " +
						"config=" + hex.EncodeToString(mpegConf),
				},
			},
		},
	}, nil
}

func NewH265Track

func NewH265Track(payloadType uint8, sprop [][]byte) *gortsplib.Track

Types

type AACPayloader

type AACPayloader struct{}

AACayloader payloads AAC packets

func (*AACPayloader) Payload

func (p *AACPayloader) Payload(mtu uint16, payload []byte) [][]byte

Payload fragments an AAC packet across one or more byte arrays

type H265Payloader

type H265Payloader struct{}

func (*H265Payloader) Payload

func (p *H265Payloader) Payload(mtu uint16, payload []byte) [][]byte

type RTSPClient

type RTSPClient struct {
	RTSPublisher
	Transport         gortsplib.Transport
	*gortsplib.Client `json:"-"`
}

func (*RTSPClient) PullStream

func (rtsp *RTSPClient) PullStream(streamPath string, rtspUrl string) (err error)

PullStream 从外部拉流

func (*RTSPClient) PushStream

func (rtsp *RTSPClient) PushStream(streamPath string, rtspUrl string) (err error)

type RTSPServer

type RTSPServer struct {
	sync.Map
}

接收RTSP推流：OnConnOpen->OnAnnounce->OnSetup->OnSessionOpen 接收RTSP拉流：OnConnOpen->OnDescribe->OnSetup->OnSessionOpen

func (*RTSPServer) OnAnnounce

func (sh *RTSPServer) OnAnnounce(ctx *gortsplib.ServerHandlerOnAnnounceCtx) (*base.Response, error)

called after receiving an ANNOUNCE request.

func (*RTSPServer) OnConnClose

func (sh *RTSPServer) OnConnClose(ctx *gortsplib.ServerHandlerOnConnCloseCtx)

called after a connection is closed.

func (*RTSPServer) OnConnOpen

func (sh *RTSPServer) OnConnOpen(ctx *gortsplib.ServerHandlerOnConnOpenCtx)

called after a connection is opened.

func (*RTSPServer) OnDescribe

func (sh *RTSPServer) OnDescribe(ctx *gortsplib.ServerHandlerOnDescribeCtx) (*base.Response, *gortsplib.ServerStream, error)

called after receiving a DESCRIBE request.

func (*RTSPServer) OnPacketRTP

func (sh *RTSPServer) OnPacketRTP(ctx *gortsplib.ServerHandlerOnPacketRTPCtx)

called after receiving a frame.

func (*RTSPServer) OnPlay

func (sh *RTSPServer) OnPlay(ctx *gortsplib.ServerHandlerOnPlayCtx) (*base.Response, error)

called after receiving a PLAY request.

func (*RTSPServer) OnRecord

func (sh *RTSPServer) OnRecord(ctx *gortsplib.ServerHandlerOnRecordCtx) (*base.Response, error)

called after receiving a RECORD request.

func (*RTSPServer) OnSessionClose

func (sh *RTSPServer) OnSessionClose(ctx *gortsplib.ServerHandlerOnSessionCloseCtx)

called after a session is closed.

func (*RTSPServer) OnSessionOpen

func (sh *RTSPServer) OnSessionOpen(ctx *gortsplib.ServerHandlerOnSessionOpenCtx)

called after a session is opened.

func (*RTSPServer) OnSetup

func (sh *RTSPServer) OnSetup(ctx *gortsplib.ServerHandlerOnSetupCtx) (*base.Response, *gortsplib.ServerStream, error)

called after receiving a SETUP request.

type RTSPSubscriber

type RTSPSubscriber struct {
	engine.Subscriber
	// contains filtered or unexported fields
}

type RTSPublisher

type RTSPublisher struct {
	*Stream `json:"-"`
	// contains filtered or unexported fields
}