1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
| package main
|
| import (
| "bytes"
| "context"
| "decoder/demo"
| "decoder/valib/ipc"
| "encoding/gob"
| "flag"
| "fmt"
| // "videoServer/demo"
| )
|
| var (
| streamURL string
| picFolder string
|
| ipcURL string
| proc string
| )
|
| func init() {
| flag.StringVar(&streamURL, "i", "rtsp://192.168.1.203:8554/16.mkv", "input url")
| flag.StringVar(&picFolder, "f", ".", "test pic folder")
|
| flag.StringVar(&ipcURL, "ipc", "ipc:///tmp/pic.ipc", "ipc label")
| }
|
| func test() {
| fmt.Println("start test")
|
| fmt.Println(picFolder)
|
| demo.SendByIPC(streamURL, "camera1", ipcURL)
| }
|
| type cameraInfo struct {
| cameraID string
| videoURL string
| }
|
| func recvFromIPC(ctx context.Context, url string) (cameraID, rtspURL string) {
| ipc := ipc.NewClient(ctx, url)
|
| for {
| msg := ipc.Recv()
|
| var buf bytes.Buffer
| buf.Write(msg)
|
| dec := gob.NewDecoder(&buf)
|
| var i cameraInfo
| if err := dec.Decode(&i); err != nil {
| fmt.Println("gob decode CameraImage error", err)
| continue
| }
| return i.cameraID, i.videoURL
| }
| }
|
| func main() {
| flag.Parse()
|
| ctx, cancel := context.WithCancel(context.Background())
| recvFromIPC(ctx, "tcp://192.168.1.156:7000")
|
| cancel()
| // test()
|
| }
|
|
