GB28181国标设备注册源码实现

本文将讲解在VSS中国标设备REGISTER的接入流程：从 gosip 收包、types.Request构建，到RegisterLogic鉴权、DeviceUpsert落库，以及上线/注销后触发的 Catalog、设备信息、心跳等下游任务。实现以VSS仓库源码为准。

相关文档：2.4.1.2 信令发送流水线（注册后 Catalog /SendLogic）、2.4.1.3 设备与通道在线状态（在线状态与SetDeviceOnline）。

项目源码地址https://github.com/openskeye/go-vss

1. 在Vss架构中的位置

注册成功后，后续MESSAGE（Catalog、DeviceInfo、Keepalive）、SUBSCRIBE、INVITE等信令，都依赖SipCatalogLoopMap中缓存的types.Request（与注册报文对齐的 From/Via/传输等），见 2.4.1.2。

2. 请求转为types.Request

入口：sip_handler.run在调用具体 Logic 前执行ParseToRequest(h.req)；失败则400。

ParseToRequest核心字段（节选）：

func ParseToRequest(req sip.Request) (*types.Request, error) { from, ok := req.From() if !ok || from.Address == nil { return nil, errors.New("OnRegister, no from") } return &types.Request{ ID: from.Address.User().String(), Source: req.Source(), Body: req.Body(), Original: req, DeviceAddr: sip.Address{ DisplayName: from.DisplayName, Uri: from.Address, }, Authorization: req.GetHeaders("Authorization"), TransportProtocol: getTransportProtocol(req), }, nil }

3.RegisterLogic.DO流程

3.1 流程图

3.2 关键步骤

1）设备 ID 长度

func (l *RegisterLogic) DO() *types.Response { if len(l.req.ID) < 18 { return nil

• <18：当前实现直接return nil。在sip_handler.success中res == nil时仍会回复200 OK。若需拒绝非法 ID，应改为显式BadRequest/Unauthorized（避免「静默成功」），这里需要自行修改。

2）密码与鉴权

• Config.Sip.UsePassword == true且无 Authorization：401，提示 Authorization 为空。
• 有 Authorization 时：auth内Digest与配置Sip.Password比对，REGISTER参与CalcResponse，失败401。

3）Expires

• 从Expires头取值：当前代码用strings.Split(header.String(), ":")取第二段再Atoi。格式需与库打印的 header 字符串一致，否则解析失败走401（expire 已过期文案实为解析失败分支）。
• expire == 0：注销，record.Online = 0。

4）入库字段（默认上线）

var ( now = functions.NewTimer().Now() record = &devices.Item{ Devices: &devices.Devices{ Name: l.req.Source, AccessProtocol: devices.AccessProtocol_4, DeviceUniqueId: l.req.ID, State: 1, Online: 1, Expire: uint64(now) + uint64(expire), Address: l.req.Source, RegisterAt: uint64(now), }, }

• AccessProtocol_4：固定为GB28181。
• Expire：当前 Unix 秒 + 注册生存期（秒）。
• 注册不经过SetDeviceOnline：在线状态由DeviceUpsert一并写入；与心跳里的SetDeviceOnline队列（见 2.4.1.3）是不同路径。

5）200 OK与附加 SIP 头（BeforeResponse）

• 若存在Authorization且匹配成功，在响应中附加Expires/User-Agent/Server，并RemoveHeader("Allow")（与设备交互兼容相关，以现网设备为准）。
• 未带 Authorization时，BeforeResponse里ok == false可能不追加上述头，依赖设备是否要求 Expires。

6）注销（expire == 0）

• SipCatalogLoop：Online: false，CatalogLoopLogic从SipCatalogLoopMap移除该设备。
• SipHeartbeatLoop：仅ID，用于更新/清理心跳 map 中条目（与上线时携带Now/RegisterExpireAt的完整结构不同）。

7）上线成功后的异步任务（Sleep 1s）

go func() { time.Sleep(1 * time.Second) l.svcCtx.SipCatalogLoop <- &types.SipCatalogLoopReq{ Req: l.req, Online: true, Now: now } l.req.Caller = functions.CallerFile(1) l.svcCtx.SipSendCatalog <- l.req l.svcCtx.SipSendDeviceInfo <- l.req l.svcCtx.SipHeartbeatLoop <- &types.SipHeartbeatLoopReq{ ID: record.DeviceUniqueId, Now: now, RegisterExpireAt: now + int64(expire), } }()

延迟 1 秒：降低被对端或中间网络丢弃的概率，这里属于折中方案，可以优化。

4. 调试与排障建议

5. 源码索引