【導(dǎo)讀】的遠(yuǎn)程液位監(jiān)控軟件。本軟件依靠.NET類庫(kù)中。信，達(dá)到了實(shí)時(shí)傳輸和遠(yuǎn)程監(jiān)控的要求。同時(shí)利用內(nèi)部的垃圾回收機(jī)制，有效的。避免了資源浪費(fèi)和內(nèi)存泄露等缺陷。在滿足企業(yè)個(gè)性化設(shè)計(jì)需求的同時(shí)還保證了。測(cè)控平臺(tái)的工作性能和測(cè)控質(zhì)量，極大的提高了工業(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 /// 關(guān)閉服務(wù)器 /// /summary /// param name=sender/param /// param name=e/param private void but_close_Click(object sender, EventArgs e) { DialogResult answer = (這將關(guān)閉服務(wù)器。您是否確實(shí)要關(guān)閉它？ , 提示框 , )。 if (answer == ) { ()。 湖南理工學(xué)院畢業(yè)設(shè)計(jì)（論文） 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 /// 安全調(diào)用 text_receive 控件 /// /summary private void Receive_text() { = new Thread(new ThreadStart())。 湖南理工學(xué)院畢業(yè)設(shè)計(jì)（論文） 32 ()。 } private void ThreadProcSafe() { (content_receive)。 } private void SetText(string text) { if () { SetTextCallback d = new SetTextCallback(SetText)。 (d, new object[] { text })。 } else { = text。 } } /// summary /// 安全調(diào)用 text_send 控件 /// /summary private void Send_text() { = new Thread(new ThreadStart())。 ()。 } private void ThreadSend() { (content_send)。 } private void SendText(string text) { if () { 湖南理工學(xué)院畢業(yè)設(shè)計(jì)（論文） 33 SetTextCallback d = new SetTextCallback(SendText)。 (d, new object[] { text })。 } else { content_send = 。 } } private void Form1_Load(object sender, EventArgs e) { } } } } 湖南理工學(xué)院畢業(yè)設(shè)計(jì)（論文） 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)。 湖南理工學(xué)院畢業(yè)設(shè)計(jì)（論文） 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 ( == || == ) { (請(qǐng)輸入要連接的 IP和端口 )。 return。 } IPAddress ipAddress = ()。 IPEndPoint remoteEP = new IPEndPoint(ipAddress, ())。 (remoteEP, new AsyncCallback(ConnectCallback), client)。 ()。 if () { Receive(client)。 } } private void ConnectCallback(IAsyncResult ar) { try { 湖南理工學(xué)院畢業(yè)設(shè)計(jì)（論文） 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) 湖南理工學(xué)院畢業(yè)設(shè)計(jì)（論文） 37 { byte[] byteData = (data)。