具有缓冲区功能的UDP数据传输类.docVIP

具有缓冲区功能的UDP数据传输类 using System; using System.Text; using System.Collections; using System.Windows.Forms; using System.Net; using System.Threading; using System.Collections.Generic;//QueueT; using System.Net.Sockets;//UdpClient的命名空间 namespace UDP { /// summary /// ----名称:UDP通讯类 /// /summary /// remarks /// ----使用说明与定义: /// /remarks public class UDPConnect//具有缓冲区功能的UDP数据传输类 { /// summary /// 缓冲区 /// /summary private readonly Queuestring sendQueue = new Queuestring(1000); //发送队列 private readonly Queuestring RecQueue = new Queuestring(1000); //接收队列 /// summary /// Udp对象 /// /summary private UdpClient m_Client; /// summary /// 对方IP /// /summary private string m_RemoteIP; /// summary /// 远程通讯端口 /// /summary private int m_RemotePort; public UDPConnect(string remoteIP,int remotePort,int localPort) { m_Client = new UdpClient(localPort);//绑定本地端口 m_RemoteIP = remoteIP; m_RemotePort = remotePort; } public void startSendData()//开启发送数据 { m_Client.Connect(m_RemoteIP, m_RemotePort);//连接远程ip //开一线程 Thread th = new Thread(new ThreadStart(listenSendData)); //设置为后台 th.IsBackground = true; th.Start(); } private void listenSendData()//发送信息,一直从队列中取出信息发送到指定远程ip端口 { while (true) { try { if (sendQueue.Count != 0) { Byte[] sendBytes = Encoding.UTF8.GetBytes(sendQueue.Dequeue());//从发送缓冲区中取出数据化为二进制 m_Client.Send(sendBytes, sendBytes.Length);//将二进制数据发送到指定IP的指定端口 } } catch (Exception err)