【導讀】的遠程液位監(jiān)控軟件。本軟件依靠.NET類庫中。信，達到了實時傳輸和遠程監(jiān)控的要求。同時利用內部的垃圾回收機制，有效的。避免了資源浪費和內存泄露等缺陷。在滿足企業(yè)個性化設計需求的同時還保證了。測控平臺的工作性能和測控質量，極大的提高了工業(yè)生產(chǎn)效率。

　　

【正文】 ar)。 if (bytesRead 0) { content_receive = (, 0, bytesRead)。 Receive_text()。 } } private void Send(Socket handler, String data) { byte[] byteData = (data)。 (byteData, 0, , 0, new AsyncCallback(SendCallback), handler)。 } private static void SendCallback(IAsyncResult ar) { Socket handler = (Socket)。 int bytesSent = (ar)。 } /// summary /// 關閉服務器 /// /summary /// param name=sender/param /// param name=e/param private void but_close_Click(object sender, EventArgs e) { DialogResult answer = (這將關閉服務器。您是否確實要關閉它？ , 提示框 , )。 if (answer == ) { ()。 湖南理工學院畢業(yè)設計（論文） 31 //()。 //()。 } if (answer == ) { return。 } } /// summary /// 發(fā)送接收數(shù)據(jù) /// /summary /// param name=sender/param /// param name=e/param private void but_send_Click(object sender, EventArgs e) { //先發(fā)送再接收 if () { Send_text()。 if ( != ) { Send(handler, )。 } (, 0, , 0, new AsyncCallback(ReadCallback), state)。 } } /// summary /// 安全調用 text_receive 控件 /// /summary private void Receive_text() { = new Thread(new ThreadStart())。 湖南理工學院畢業(yè)設計（論文） 32 ()。 } private void ThreadProcSafe() { (content_receive)。 } private void SetText(string text) { if () { SetTextCallback d = new SetTextCallback(SetText)。 (d, new object[] { text })。 } else { = text。 } } /// summary /// 安全調用 text_send 控件 /// /summary private void Send_text() { = new Thread(new ThreadStart())。 ()。 } private void ThreadSend() { (content_send)。 } private void SendText(string text) { if () { 湖南理工學院畢業(yè)設計（論文） 33 SetTextCallback d = new SetTextCallback(SendText)。 (d, new object[] { text })。 } else { content_send = 。 } } private void Form1_Load(object sender, EventArgs e) { } } } } 湖南理工學院畢業(yè)設計（論文） 34 客戶端： using System。 using 。 using 。 using 。 using 。 using 。 using 。 using 。 using 。 using 。 using 。 namespace text_client { public partial class Form1 : Form { public Form1() { InitializeComponent()。 } public class StateObject { public Socket workSocket = null。 public const int BufferSize = 256。 public byte[] buffer = new byte[BufferSize]。 public StringBuilder sb = new StringBuilder()。 } private ManualResetEvent connectDone = new ManualResetEvent(false)。 private ManualResetEvent sendDone = new ManualResetEvent(false)。 湖南理工學院畢業(yè)設計（論文） 35 private ManualResetEvent receiveDone = new ManualResetEvent(false)。 private Socket client = new Socket(, , )。 private String content_receive = 。 private String content_send = 。 private Thread demoThread = null。 delegate void SetTextCallback(string text)。 /// summary /// 連接客戶端 /// /summary /// param name=sender/param /// param name=e/param private void but_con_Click(object sender, EventArgs e) { if ( == || == ) { (請輸入要連接的 IP和端口 )。 return。 } IPAddress ipAddress = ()。 IPEndPoint remoteEP = new IPEndPoint(ipAddress, ())。 (remoteEP, new AsyncCallback(ConnectCallback), client)。 ()。 if () { Receive(client)。 } } private void ConnectCallback(IAsyncResult ar) { try { 湖南理工學院畢業(yè)設計（論文） 36 Socket client = (Socket)。 (ar)。 ()。 } catch (Exception e) { (())。 } } private void Receive(Socket client) { try { StateObject state = new StateObject()。 = client。 (, 0, , 0, new AsyncCallback(ReceiveCallback), state)。 } catch (Exception e) { } } private void ReceiveCallback(IAsyncResult ar) { StateObject state = (StateObject)。 Socket client = 。 int bytesRead = (ar)。 if (bytesRead 0) { content_receive = (, 0, bytesRead)。 Receive_text()。 } } private void Send(Socket client, String data) 湖南理工學院畢業(yè)設計（論文） 37 { byte[] byteData = (data)。