package service
|
|
import (
|
"context"
|
"fmt"
|
"time"
|
|
"github.com/muesli/cache2go"
|
)
|
|
var decoderMsgCache = cache2go.Cache("duanliu")
|
|
// 山东断流监控
|
func WatchDuanliu() {
|
url := "ipc:///tmp/shandong-decoder-duanliu-report.ipc"
|
|
sock := newPull(context.Background(), url, 6)
|
for {
|
if d, err := sock.Recv(); err == nil {
|
decoderMsgCache.Add(string(d), time.Duration(30)*time.Second, true)
|
fmt.Println("======>> Recv watchDuanliu:", string(d), "map size", decoderMsgCache.Count())
|
} else {
|
time.Sleep(10 * time.Second)
|
}
|
}
|
}
|
|
func GetDuanliuIds() []string {
|
var ids []string
|
|
decoderMsgCache.Foreach(func(key interface{}, item *cache2go.CacheItem) {
|
ids = append(ids, key.(string))
|
})
|
|
return ids
|
}
|
