Shikong/go-gb28181
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

实现启动时注册 register

Browse Source
This commit is contained in:
shikong 2025-01-25 19:17:40 +08:00
parent 3a5ac93d06
commit 0d5faca617
Signed by: Shikong
GPG Key ID: BD85FF18B373C341
2 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
cmd/client/main.go
View File

@ -81,6 +81,7 @@ func main() {
message.SetupMessageHandler(srv, client, clientConfig) message.SetupMessageHandler(srv, client, clientConfig)
device.SetupRegister(client, clientConfig) device.SetupRegister(client, clientConfig)
defer device.StopAllRegister()
keepalive.SetupKeepalive(client, clientConfig) keepalive.SetupKeepalive(client, clientConfig)
device.StartKeepAlive(client) device.StartKeepAlive(client)
defer device.StopKeepAlive() defer device.StopKeepAlive()

6
pkg/services/device/register.go
View File

@ -13,6 +13,12 @@ import (
var registerSenders = make(map[string]*time.Ticker) var registerSenders = make(map[string]*time.Ticker)
func StopAllRegister() {
for _, timer := range registerSenders {
timer.Stop()
}
}
func SetupRegister(client *sipgo.Client, clientConfig *config.ClientConfig) { func SetupRegister(client *sipgo.Client, clientConfig *config.ClientConfig) {
timer := time.NewTicker(time.Second * 3600) timer := time.NewTicker(time.Second * 3600)
registerSenders[clientConfig.DeviceId] = timer registerSenders[clientConfig.DeviceId] = timer