| | |
| | | Array.Copy(bytes, 0, packet.Bytes, 0, packet.Bytes.Length); |
| | | |
| | | //mqtt连接数据读取 |
| | | if (packet.RemoteEndPoint.ToString() == "172.16.2.237:6688") |
| | | { |
| | | //var reString = DAL.CommonPage.MyEncodingUTF8.GetString(bytes); |
| | | //var jt = Newtonsoft.Json.JsonConvert.DeserializeObject<Newtonsoft.Json.Linq.JObject>(reString); |
| | | //var gateway_objects = jt.GetValue("objects").ToString(); |
| | | //var jt2 = Newtonsoft.Json.JsonConvert.DeserializeObject<Newtonsoft.Json.Linq.JObject>(gateway_objects); |
| | | //MqttCommon.mqttClientIP = jt2.GetValue("gateway_ip").ToString(); |
| | | //MqttCommon.mqttGatewayMAC = jt2.GetValue("board_id").ToString(); |
| | | } |
| | | //if (((IPEndPoint)packet.RemoteEndPoint).Port == 6688) |
| | | //{ |
| | | // var reString = DAL.CommonPage.MyEncodingUTF8.GetString(bytes); |
| | | // var jt = Newtonsoft.Json.JsonConvert.DeserializeObject<Newtonsoft.Json.Linq.JObject>(reString); |
| | | // var gateway_objects = jt.GetValue("objects").ToString(); |
| | | // var jt2 = Newtonsoft.Json.JsonConvert.DeserializeObject<Newtonsoft.Json.Linq.JObject>(gateway_objects); |
| | | // Mqtt_A_Protocol.mqttClientIP = jt2.GetValue("gateway_ip").ToString(); |
| | | // Mqtt_A_Protocol.mqttGatewayMAC = jt2.GetValue("board_id").ToString(); |
| | | // Mqtt_A_Protocol.StartMqtt(); |
| | | //} |
| | | |
| | | packet.Manager(); |
| | | } |