1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
| package device
|
| import (
| "vamicro/iotData-service/model"
| )
|
| var CollectorMsgChan = make(chan model.Device, 100)
|
| func Collector() {
| // RT02信息接收
| go RT02MsgServer()
|
| // 处理消息
| for {
| select {
| case msg := <-CollectorMsgChan:
| // 插入设备数据
| msg.Update()
|
| }
| }
| }
|
|
