| | |
| | | /// 通讯ID |
| | | /// </summary> |
| | | public const int msg_id = 1; |
| | | /// <summary> |
| | | /// 通讯端口 |
| | | /// </summary> |
| | | public int port = 0; |
| | | |
| | | /// <summary> |
| | | /// 控制失败次数 |
| | |
| | | new System.Threading.Thread(() => |
| | | { |
| | | System.Threading.Thread.Sleep(1000); |
| | | UdpSocket._BusSocket.Start(); |
| | | UdpSocket._BusSocket.Start(6000); |
| | | controlLostCount = 0; |
| | | }) |
| | | { IsBackground = true }.Start(); |
| | |
| | | { |
| | | try |
| | | { |
| | | var sendJob = new JObject { { "id", msg_id.ToString() }, { "time_stamp", (DateTime.Now.Ticks / 10000).ToString() } }; |
| | | var sendJob = new JObject { { "id", msg_id.ToString() }, { "time_stamp", (DateTime.Now.Ticks / 100000).ToString() } }; |
| | | var bodyString = JsonConvert.SerializeObject(sendJob); |
| | | var bodyBytes = Encoding.ASCII.GetBytes(bodyString); |
| | | var sendBytes = A_Protocal_Common.apc.ConvertSendBodyData(CommunicationTopic.SearchLoaclGateway, bodyString); |
| | | |
| | | var sendBytes = Control.Ins.ConvertSendBodyData(CommunicationTopic.SearchLoaclGateway, bodyString); |
| | | //组播发送 |
| | | Packet = new Packet(sendBytes, new System.Net.IPEndPoint(System.Net.IPAddress.Parse("239.0.168.188"), 8585)); |
| | | Packet.HaveSendCount = 4;//ps:没有重发,后期有时间可以增加重发判断 |