程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> C語言 >> 關於C語言 >> C#實時申請技術(1)

C#實時申請技術(1)

編輯:關於C語言

Real time Application 實時申請技術在本文裡是作為一個實例來演示在用戶(TcpclIEnt)申請與服務器(TcpServer)申請之間使用Socket類的情況 。該項目同樣也演示在實時項目中如何使用listvIEw控制以及如何傳遞XML格式信息。

TcpServer.exe 文件顯示了在單獨的thread當中(而不是在GUI 線程之中)TCP socket的相互通訊。

TcpClient.exe文件同樣也使用一條單獨的線程 從Socket中讀取數據,然後對表單中的list vIEw控件進行更新。

步聚如下:

1.TcpServer 監聽端口8002,並且發射線程等待客戶端連結。

Hashtable socketHolder = new Hashtable();
Hashtable threadHolder = new Hashtable();
public Form1()
{
 // Required for Windows Form Designer support
 //
 InitializeComponent();
 tcpLsn = new TcpListener(8002);
 tcpLsn.Start();
 // tcpLsn.LocalEndpoint may have a bug, it only show 0.0.0.0:8002
 stpanel.Text = "Listen at: " + tcpLsn.LocalEndpoint.ToString();
 Thread tcpThd = new Thread(new ThreadStart(WaitingForClIEnt));
 threadHolder.Add(connectId, tcpThd);
 tcpThd.Start() ;
}
2. TcpClIEnt與TcpSrv連接上後,發送客戶端信息數據包至TcpServer,然後發射線程,該線程是用來接收通過Socket傳來的數據。

private void menuConn_Click(object sender, System.EventArgs e)
{
 ConnectDlg myDlg = new ConnectDlg();
 myDlg.ShowDialog(this);
 if( myDlg.DialogResult==DialogResult.OK)
 {
  s = new Socket(AddressFamily.InterNetwork, SocketType.Stream,ProtocolType.Tcp );
  IPAddress hostadd = IPAddress.Parse(myDlg.IpAdd);
  int port=Int32.Parse(myDlg.PortNum);
  IPEndPoint EPhost = new IPEndPoint(hostadd, port);
  Try
  {
   s.Connect(EPhost);
   if (s.Connected)
   {
    Byte[] bBuf;
    string buf;
    buf = String.Format("{0}:{1}", myDlg.UserName,myDlg.PassWord);
    bBuf=ASCII.GetBytes(buf);
    s.Send(bBuf, 0 , bBuf.Length,0);
    t = new Thread(new ThreadStart(StartRecIEve));
    t.Start();
    sbar.Text="Ready to recIEve data";
   }
  }
  catch (Exception e1)
  {
   MessageBox.Show(e1.ToString());
  }
 }
}
private void StartRecIEve()
{
 miv = new MethodInvoker(this.UpdateListVIEw);
 int cnt=0;
 string tmp=null;
 Byte[] firstb= new Byte[1];
 while (true)
 {
  try
  {
   Byte[] receive = new Byte[1];
   int ret = s.Receive(receive, 1, 0);
   if (ret > 0)
   {
    switch(receive[0])
    {
     case 11: //check start message
       cnt=0;
       break;
     case 10: // check end message
       cnt=0;
       if(firstb[0] == ':')
        HandleCommand(tmp);
       else if(firstb[0] == '<')
        HandleXML(tmp);
       else
        HandleText(tmp);
        tmp=null;
        break;
       default:
        if (cnt == 0)
         firstb[0] = receive[0];
         tmp += System.Text.Encoding
         .ASCII.GetString(receive);
         cnt++;
         break;
        }
       }
    }
    catch (Exception e)
    {
     if( !s.Connected )
      {
       break;
      }
     }
   }
   t.Abort();
  }
3.TcpServer接收來自TcpClient的連接請求,並且將socket 實例保存到Hash表中,然後發射線程以便控制socket的通訊,同時將客戶端信息在listvIEw 控件中顯示出來。

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved