当前位置：首页 > news >正文

SkeyeVSS中国标GB28181、流媒体源RTMP/RTSP/HTTP/ONVIF、RTMP推流等协议视频流实时播放流程详解

news 2026/3/26 5:04:16

本文基于core/app/sev/vss/internal/logic/http/video/stream_play.go的源码：从参数与设备查询，到按接入协议分支、触发 MS 拉流或 GB28181 Invite，再到返回StreamResp与异步处理。

源码地址点击直达

一、接口入口与请求体

项目	说明
注册	`internal/handler/http/routers.go`：`router.POST(video.VStreamPlayLogic.Path(), ...)`
Path	`/video/stream`（挂在 Gin 的`/api`组下，完整路径为`POST /api/video/stream`）
Logic	`StreamPlayLogic.DO(req types.VideoStreamReq)`

VideoStreamReq（internal/types/types.go）主要字段：

字段	含义
`deviceUniqueId`/`channelUniqueId`	必填；用于拉取设备+通道及绑定 MS。
`startAt`/`endAt`	毫秒时间戳；均大于 0时视为回放（`playType = playback`）。
`download`	是否下载场景（透传给 GB Invite）。
`speed`	回放倍率等（透传 Invite）。
`https`	影响 MS 节点选择时是否按 HTTPS 能力投票（`ms.New(...).WithHttps(req.Https)`）。

流名称覆盖：若 Handler 注入了*gin.Context且 Query 里存在streamName，则用其覆盖stream.New().Produce(...)的默认流名称（便于与已有会话对齐）。

二、主流程总览

三、步骤说明

3.1 参数与设备通道

若deviceUniqueId或channelUniqueId为空，直接返回参数错误。
RpcClients.Device.DeviceChannel拉取DeviceChannel；设备或通道为空则设备获取失败。

3.2 直播 / 回放与 MS 超时参数

默认playType = play（直播），autoStopPullAfterNoOutMs = 60000。
当req.EndAt > 0 && req.StartAt > 0：playType = playback，autoStopPullAfterNoOutMs = 10000（回放更快放弃无输出拉流，避免长时间占资源）。

3.3 流名称与 MS 节点

streamName = stream.New().Produce(device, channel, playType)
- 直播：stream_{deviceUniqueId}_{channelUniqueId}_play。
- 回放：带全局递增PlaybackCount后缀，保证多路回放流名称隔离（见core/common/stream/main.go）。
ms.New(ctx, svcCtx).WithHttps(req.Https).VoteNode(device.MSIds)选择媒体节点；nil则返回「未设置流媒体源」。

3.4 响应体`StreamResp`与播放地址`Addresses`

填充ctypes.StreamResp：接入协议文案、MS 信息、设备/通道 ID、流名称、通道在线状态、StreamUrl占位等；通道/设备展示名优先Label否则Name。

MediaServerNode.IsDef分支（是否「默认/简略」节点）：

非默认：再调GetMSConf(http://{msAddress})取HTTP/HTTPS/RTSP/RTMP等端口，拼stream.PlayAddress(StreamPlayProxyPath, MSVoteNodeResp+端口, streamName)。
默认：直接用已有msNode调PlayAddress。

回放时间：startAt/endAt> 0 时格式化为字符串写入data.StartAt/data.EndAt（供调用端展示）。

PlayAddress在core/common/stream/main.go中根据代理配置、MS 端口与流名称生成多协议播放 URL 集合（HTTP-FLV、WebSocket、HLS 等——具体字段见ctypes.PlayAddress）。

3.5 按`AccessProtocol`分支（核心）❗❗❗

常量来自repositories/models/devices：

值	含义	`stream_play`行为
1	流媒体源	`streamUrl = device.StreamUrl`；传输层`MediaProtocolMode == 0`时`rtspMode = 1`（UDP），否则 TCP。后续`StartRelyPull`。
2	RTMP 推流	不配`streamUrl`，注释说明由设备推流触发`on_pub_start`，不调用`start_relay_pull`。
3	ONVIF	`streamUrl = channel.StreamUrl`，同样按`MediaProtocolMode`决定 RTSP UDP/TCP，再`StartRelyPull`。
4	GB28181	回放：先`StopMultiMSStream`停掉与当前流名称前缀相关、带`playback`的旧流，睡眠 1s降低抢流冲突；再`gbs.InviteLogic.Invite(...)`下发SIP Invite（含起止时间、`Download`、`Speed`、流名称等）。成功则`go saveChannelSnapshot`并直接返回`Data`（不再走本文件末尾的`StartRelyPull`）。
default	其它	未匹配的协议类型。

传输协议：transportProtocol := res.Data.Device.TransportProtocol()，用于 RTSPTCP/UDP与后续 MS 参数一致。

3.6 MS`start_relay_pull`

当streamUrl != ""时调用：

POST http://{msAddress}/api/ctrl/start_relay_pull

参数包括：stream_name、url、auto_stop_pull_after_no_out_ms、pull_timeout_ms、rtsp_mode等（见internal/pkg/ms/api.goStartRelyPull）。失败则整体HTTP 错误响应。

3.7 CDN 转发

若通道开启 CDN（CdnState == 1）且CdnUrl以rtmp开头，在返回前go StartRelayPush向 MS 启relay_push，把当前流推到 CDN；错误仅打日志，不阻塞主流程返回。

3.8 异步通道快照`saveChannelSnapshot`

go saveChannelSnapshot(streamName, res.Data)（GB 分支在 Invite 成功后也会调用）。
用ms.Snapshot(device, streamName)取一帧，经临时.raw/.jpg文件，ff.FFMpeg.SnapFile转码，再Mv到SaveVideoSnapshotDir下由stream.Snapshot(dir, deviceId, channelId)规则命名的路径。
全程defer recover与日志，失败不影响播放接口成功返回。

四、与`gbs.Invite`的关系

GB28181 路径：是由Invite走完整链路（Catalog 在线、StreamInfo、GetStreamGroup、端口范围、防重复 Invite、SipSendVideoLiveInvite等，详见video_live_invite.go）。

stream_play传入的InviteParams包括：设备/通道业务 ID、PlayType、格式化后的起止时间字符串、Download、Speed、StreamName、以及已查好的DeviceItem/ChannelItem，Caller标记为http 请求stream play invite，便于日志区分来源。

五、播放流程总结

统一出口：平台无论网页还是内部服务，只要设备+通道即可拿同一套StreamResp（MS 节点、流名称、多协议地址），客户端按能力选播。
协议差异分支（switch）：流媒体源/ONVIF 走拉流 URL + MS；RTMP 推流走设备主动 pub；GB28181 走信令 Invite，避免一种模式套所有协议。
直播与回放：用时间区间切换playType与流名称生成策略（回放带计数后缀），并差异化autoStopPullAfterNoOutMs。
MS 抽象：拉流统一StartRelyPull；GB仍由 RTP/SIP 与 MS API 协作，此接口只负责触发 Invite。
快照与播放解耦：快照慢或失败不影响拉流流程。

六、注意点

说明
GB 回放 StopMultiMSStream	按流名称前缀 + playback模糊停流时，需要注意不同流流名称是否相同。
RTMP（= 2）	本请求可能只返回地址信息，需要注意MS`on_pub_start`通知是否有达到。
Invite 与重复请求	`Invite`内部有`InviteRequestState`与 MS 上`Pub`状态判断； `stream_play`高频重入，需要注意防抖；防抖可以参考`core/pkg/dt`。
流图片快照	临时文件与 FFmpeg 依赖配置`FFMpeg`、磁盘`SaveVideoSnapshotDir`；未设置会导致快照失败。

七、相关源码索引

说明	路径
流播放 Logic	`core/app/sev/vss/internal/logic/http/video/stream_play.go`
GB Invite	`core/app/sev/vss/internal/logic/http/gbs/video_live_invite.go`
MS`start_relay_pull`/`start_relay_push`	`core/app/sev/vss/internal/pkg/ms/api.go`
流名称与`PlayAddress`	`core/common/stream/main.go`
响应	`core/common/types/stream.go`（`StreamResp`、`PlayAddress`）
HTTP 路由	`core/app/sev/vss/internal/handler/http/routers.go`