| 12345678910111213141516171819202122232425262728293031 |
- package MqttServer
- //func MqttPolling() {
- //
- // var DevicePollingMap map[string]int /*创建集合 */
- // DevicePollingMap = make(map[string]int)
- //
- // for true {
- //
- // for k, _ := range DevicePollingMap {
- // Dpm, ok := DevicePollingMap[k]
- // if ok {
- // r_Device, err := Device.Read_Device_ByT_sn(k)
- // if err != nil {
- // delete(DevicePollingMap, k)
- // continue
- // }
- // Read_DeviceSensorParameter(r_Device.T_sn)
- //
- // DevicePollingMap[k] = Dpm - 1
- // if Dpm <= 1 {
- // delete(DevicePollingMap, k)
- // }
- //
- // }
- // time.Sleep(10 * time.Millisecond)
- // }
- //
- // time.Sleep(10 * time.Second)
- // }
- //}
|
