public class StaticUdpDal{private static Socket socket = null;private bool IsRun = true, _IsSuccse = false;private int num = 0, recNum;private int _LoopNum = 3;//循环计数器和循环等待次数private bool _IsReadMsgType = true;//是否读取消息类型public int LoopNum{get { return _LoopNum; }set { _LoopNum = value; }}private EndPoint point;/// <summary>///  是否成功收到消息/// </summary>public bool IsSuccse{get { return _IsSuccse; }set { _IsSuccse = value; }}private ProtocolModel pModel;/// <summary>/// 数据发送接收之间需要的数据模型/// </summary>public ProtocolModel PModel{get { return pModel; }set { pModel = value; }}private MemoryStream sendStream;/// <summary>/// //发送内容/// </summary>public MemoryStream SendStream{get { return sendStream; }set { sendStream = value; }}/// <summary>/// 是否读取消息类型,默认读取/// </summary>public bool IsReadMsgType{get { return _IsReadMsgType; }set { _IsReadMsgType = value; }}public StaticUdpDal(){//绑定IP端口if (socket == null){socket = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);string UdpSendIP = ConfigurationManager.AppSettings["UdpSendIP"].ToString();string UdpSendPort = ConfigurationManager.AppSettings["UdpSendPort"].ToString();IPEndPoint ipep = new IPEndPoint(string.IsNullOrWhiteSpace(UdpSendIP) ? IPAddress.Any : IPAddress.Parse(UdpSendIP),string.IsNullOrWhiteSpace(UdpSendPort) ? 50090 : int.Parse(UdpSendPort));//本机预使用的IP和端口
                socket.Bind(ipep);}}/// <summary>/// UDP发送接收主函数/// </summary>public BinaryReader UdpMain(){Task<BinaryReader> taskRecive = Task<BinaryReader>.Factory.StartNew(() => ReciveMsg());Task taskSend = Task.Factory.StartNew(() => sendMsg());taskRecive.Wait();return taskRecive.Result;}/// <summary>/// 向特定ip的主机的端口发送数据报/// </summary>public void sendMsg(){while (true){if (num >= _LoopNum || !IsRun){IsRun = false;return;}num++;try{byte[] buffer = sendStream.ToArray();point = new IPEndPoint(IPAddress.Parse(pModel.DisplayIP), pModel.DisplayPort);socket.SendTo(buffer, buffer.Length, SocketFlags.None, point);//发送
                }catch (Exception ex){ZP.Comm.ErrHandler.WriteError(ex, "UDP通信异常-发送");IsRun = false; return;}Thread.Sleep(1000);//时间间隔为1秒
            }}/// <summary>/// 接收发送给本机ip对应端口号的数据报/// </summary>public BinaryReader ReciveMsg(){byte[] data = new byte[1500];while (true){recNum++;if (recNum > 30 || !IsRun) // 3秒未接收到消息,或标记变为停止，停止
                {IsRun = false;return null;}if (socket == null || socket.Available < 1){ Thread.Sleep(200); continue; }try{int len = socket.Receive(data);//接收  socket.Receive(data,SocketFlags.None);  //
                }catch (Exception ex){// 在出现未处理的错误时运行的代码ZP.Comm.ErrHandler.WriteError(ex, "UDP通信异常-接收");IsRun = false; return null;}BinaryReader reader = GetReciveData(data);//基础判断if (!_IsSuccse){ Thread.Sleep(200); continue; }//socket.Close();IsRun = false;//修改运行标记return reader;}}/// <summary>/// 根据模型获取基础发送内容/// </summary>/// <returns></returns>public MemoryStream GetBaseContent(ProtocolModel _pModel){pModel = _pModel;sendStream = new MemoryStream();BinaryWriter writer = new BinaryWriter(sendStream);writer.Write(System.Net.IPAddress.HostToNetworkOrder((short)0));//长度writer.Write(System.Net.IPAddress.HostToNetworkOrder((int)pModel.Key));//keywriter.Write(System.Net.IPAddress.HostToNetworkOrder((int)pModel.TalkType));//请求类型
writer.Write(System.Net.IPAddress.HostToNetworkOrder((int)pModel.Sender.Length * 2));//发送者
            writer.Write(Encoding.BigEndianUnicode.GetBytes(pModel.Sender));writer.Write(System.Net.IPAddress.HostToNetworkOrder((int)pModel.Receiver.Length * 2));//接收者
            writer.Write(Encoding.BigEndianUnicode.GetBytes(pModel.Receiver));writer.Write(System.Net.IPAddress.HostToNetworkOrder((int)pModel.MsgType));//消息类型if (pModel.UseType == 2){writer.Write(System.Net.IPAddress.HostToNetworkOrder((int)pModel.DisplayNo.Length * 2)); //终端编号 日光温室
                writer.Write(Encoding.BigEndianUnicode.GetBytes(pModel.DisplayNo));}return sendStream;}/// <summary>/// 根据当前模型,获取接受信息/// </summary>/// <param name="data"></param>/// <returns></returns>public BinaryReader GetReciveData(byte[] data){MemoryStream stream2 = new MemoryStream(data);BinaryReader reader = new BinaryReader(stream2);short packageLen = System.Net.IPAddress.NetworkToHostOrder(reader.ReadInt16());//长度int key = System.Net.IPAddress.NetworkToHostOrder(reader.ReadInt32());//keyif (!((!pModel.IsConServer && key == (int)GhMsgEnum.Key) || (pModel.IsConServer && key == (int)GhMsgEnum.Key1)))//987656789  123454321return reader;//-----------------------------------------不同的地方--------------------------------------------------int replyKind = System.Net.IPAddress.NetworkToHostOrder(reader.ReadInt32());//回复的类型 3if (replyKind != PModel.AnswerType)//3return reader;int senderLen = System.Net.IPAddress.NetworkToHostOrder(reader.ReadInt32());//发送者的长度byte[] temp = new byte[1024];temp = reader.ReadBytes(senderLen);string No = Encoding.BigEndianUnicode.GetString(temp);int receiveLen = System.Net.IPAddress.NetworkToHostOrder(reader.ReadInt32());//接收者的长度string receive;if (receiveLen > 0)receive = Encoding.BigEndianUnicode.GetString(reader.ReadBytes(receiveLen));//-----------------------------------------不同的地方--------------------------------------------------if (IsReadMsgType){int msgType = System.Net.IPAddress.NetworkToHostOrder(reader.ReadInt32());//消息类型 160 设备信息if (msgType != PModel.AnswerMsgType)//160，155，156，158return reader;}//获取公用参数_IsSuccse = true;return reader;}}

/// <summary>/// 写入手动控制操作信息  文档2 手动控制，打开关闭设备； 未完成（检查开关状态）/// </summary>/// <param name="GreenhouseID"></param>/// <param name="UserName"></param>/// <param name="isDoing">true：打开；false：关闭</param>/// <param name="coilStatus"></param>public long WriteDevice(int GreenhouseID, string UserName, bool isDoing, long coilStatus){GreenHouseDal ghDal = new GreenHouseDal();D_GreenhouseInfo ghModel = ghDal.GetModel(new D_GreenhouseInfo() { GreenhouseID = GreenhouseID });//获取终端ProtocolModel pModel = new ProtocolModel(){UseType = 1,//使用类型，温室IsConServer = ghModel.ConnectType != 1,//是否服务器转发TalkType = (int)GhMsgEnum.TALK,//请求类型AnswerType = (int)GhMsgEnum.TALK,//应答类型
Sender = string.IsNullOrWhiteSpace(UserName) ? "server" : UserName,//发送者Receiver = (ghModel.ConnectType != 1) ? ghModel.DisplayNo : "dev0",//接收者,网关编号MsgType = isDoing ? (int)GhMsgEnum.SWITCHCTLON : (int)GhMsgEnum.SWITCHCTLOFF,//消息类型为  512、打开开关；513、关闭开关AnswerMsgType = (int)GhMsgEnum.OutputCoil,//应答类型//DisplayIP ="192.168.101.31",// (ghModel.ConnectType != 1) ? _DisplayIP : ghModel.DisplayIP,//目标IP//DisplayPort =8085// (ghModel.ConnectType != 1) ? _DisplayPort : (int)ghModel.DisplayPort,//目标端口
DisplayIP = (ghModel.ConnectType != 1) ? _DisplayIP : ghModel.DisplayIP,//目标IPDisplayPort = (ghModel.ConnectType != 1) ? _DisplayPort : (int)ghModel.DisplayPort,//目标端口
            };StaticUdpDal bud = new StaticUdpDal();MemoryStream stream = bud.GetBaseContent(pModel);//获取基础发送内容
BinaryWriter writer = new BinaryWriter(stream);writer.Write(System.Net.IPAddress.HostToNetworkOrder((long)coilStatus));//写入消息内容
writer.Seek(0, SeekOrigin.Begin);writer.Write(System.Net.IPAddress.HostToNetworkOrder((short)(stream.Length - 2)));//写入长度bud.SendStream = stream;bud.LoopNum = 1;BinaryReader reader = bud.UdpMain();//开始发送和接收if (reader == null || !bud.IsSuccse) return (long)-1;//---------------------------------?long OutputStatus = System.Net.IPAddress.NetworkToHostOrder(reader.ReadInt64());return OutputStatus;}