GB28181 协议库代码生成器

// gb28181-go 设备端（UAC）接入骨架 —— 由 Mi&Bee's 百宝箱 协议库代码生成器生成
// 库: github.com/mickeyzzc/gb28181-go v0.11.0 · MIT
// 安装: go get github.com/mickeyzzc/gb28181-go
package main

import (
	"context"
	"log"
	"time"

	"github.com/mickeyzzc/gb28181-go/device"
)

func main() {
	cfg := device.Config{
		Enabled:               true,
		PlatformSIPAddress:    "192.168.1.10",
		PlatformSIPPort:       5060,
		DeviceID:              "34020000001320000001",
		ChannelID:             "34020000001310000001",
		SIPDomain:             "3402000000",
		Password:              "your-platform-password", // 与平台约定的摘要认证密码——换成你自己的
		LocalSIPPort:          5060,
		RegisterIntervalSecs:  3600,
		HeartbeatIntervalSecs: 60,
		HeartbeatTimeoutCount: 3,
		Transport:             "udp", // udp | tcp | tls（SIPS，GB/T 28181-2022）
	}

	// FrameHub 是现成的 FrameSource：有界通道、满则丢弃。
	// 生产环境把编码器输出接到 hub.Write(au)，替换下面的合成帧循环。
	hub := device.NewFrameHub()

	srv := device.New(cfg, device.DeviceInfo{
		Name:         "Front Door",
		Manufacturer: "MiBee Studio",
		Model:        "MiBee Eye",
	}, hub)

	// 可选：录像段索引，支持 RecordInfo/回放 INVITE。
	// srv.SetRecordingIndex(myIndex)

	ctx, cancel := context.WithCancel(context.Background())
	defer cancel()

	errCh := make(chan error, 1)
	go func() { errCh <- srv.Start(ctx) }() // Start 阻塞：注册、保活、目录应答、INVITE 全在其内

	// 合成帧循环占位：每秒 1 个 IDR + 1 个 P 帧。真实视频替换为编码器的 NALU 访问单元。
	ticker := time.NewTicker(time.Second)
	defer ticker.Stop()

	for i := 0; ; i++ {
		select {
		case <-ctx.Done():
			srv.Stop()
			return
		case <-ticker.C:
			au := device.AccessUnit{Timestamp: time.Now(), KeyFrame: i%5 == 0}
			if au.KeyFrame {
				au.NALUs = []device.NALU{
					{Type: 7, IsSPS: true, Data: []byte{0x67, 0x42}},
					{Type: 8, IsPPS: true, Data: []byte{0x68, 0xEB}},
					{Type: 5, IsIDR: true, Data: []byte{0x65, 0x01}},
				}
			} else {
				au.NALUs = []device.NALU{{Type: 1, Data: []byte{0x41, 0x02}}}
			}
			hub.Write(au)
		case err := <-errCh:
			log.Fatalf("device server: %v", err)
		}
	}
}