C#.net同步異步SOCKET通訊和多線程總結

同步套接字通信

Socket支援下的網上點對點的通信

服務端實作監聽連接配接，用戶端實作發送連接配接請求，建立連接配接後進行發送和接收資料的功能

伺服器端建立一個socket，設定好本機的ip和監聽的端口與socket進行綁定，開始監聽連接配接請求，當接收到連接配接請求後，發送确認，同用戶端建立連接配接，開始與用戶端進行通信。

用戶端建立一個socket，設定好伺服器端的IP和提供服務的端口，發出連接配接請求，接收到服務的确認後，盡力連接配接，開始與伺服器進行通信。

伺服器端和用戶端的連接配接及它們之間的資料傳送均采用同步方式。

Socket

Socket是tcp/ip網絡協定接口。内部定義了許多的函數和例程。可以看成是網絡通信的一個端點。在網絡通信中需要兩個主機或兩個程序。通過網絡傳遞資料，程式在網絡對話的每一端需要一個socket。

       Tcp/IP傳輸層使用協定端口将資料傳送給一個主機的特定應用程式，協定端口是一個應用程式的程序位址。傳輸層子產品的網絡軟體子產品要于另一個程式通信，它将使用協定端口，socket是運作在傳輸層的api，使用socket建立連接配接發送資料要指定一個端口給它。

Socket：

Stream Socket流套接字 Socket提供雙向、有序、無重複的資料流服務，出溜大量的網絡資料。

Dgram socket資料包套接字 支援雙向資料流，不保證傳輸的可靠性、有序、無重複。

Row socket 原始套接字 通路底層協定

建立socket 用C#

命名空間:using System.Net;using System.Net.Socket;

構造新的socket對象：socket原型：

Public socket (AddressFamily addressFamily,SocketType sockettype,ProtocolType protocolType)

AddressFamily 用來指定socket解析位址的尋址方案。Inte.Network标示需要ip版本4的位址，Inte.NetworkV6需要ip版本6的位址

SocketType參數指定socket類型Raw支援基礎傳輸協定通路，Stream支援可靠，雙向，基于連接配接的資料流。

ProtocolType表示socket支援的網絡協定

定義主機對象：

IPEndPoint類：IPEndPoint構造方法  位置:System.Net

原型:1)   public IPEndPoint(IPAddress address,int port)     2)public IPEndPoint(long address,int port) 參數1整型int64如123456,參數2端口int32

主機解析：

利用DNS伺服器解析主機，使用Dns.Resolve方法

原型：public static IPHostEntry Resolve(string hostname) 參數：待解析的主機名稱，傳回IPHostEntry類值，IPHostEntry為Inte.Net主機位址資訊提供容器，該容器提供存有IP位址清單，主機名稱等。

Dns.GetHostByName擷取本地主機名稱

原型:public static IPHostEntry GetHostByName(string hostname)

GetHostByAddress

原型：1)public static IPHostEntry GetHostByAddress(IPAddress address) 參數:IP位址 2)public static IPHostEntry GetHostByAddress(string address) IP位址格式化字元串

端口綁定和監聽：

同步套接字伺服器主機的綁定和端口監聽

Socket類的Bind（綁定主機）,Listen（監聽端口）,Accept（接收用戶端的連接配接請求）

Bind：原型:public void Bind(EndPoint LocalEP)參數為主機對象 IPEndPoint

Listen:原型：public void Listen(int backlog) 參數整型數值，挂起隊列最大值

accept:原型：public socket accept() 傳回為套接字對象

示範程式：

IPAddress myip=IPAddress.Parse(“127.0.0.1”);

IPEndPoint myserver=new IPEndPoint(myip,2020);

Socket sock=new Socket(AddressFamily.Inte.Network,SocketType.Stream,ProtocolType.Tcp);

Sock.Bind(myserver);

Sock.Listen(50);

Socket bbb=sock.Accept();

發送資料：方法1：socket類的send方法二.NetworkStream類Write

send原型：public int Send(byte[] buffer) 位元組數組 

public int Send(byte[],SocketFlags)原型2說明，SocketFlags成員清單：DontRoute(不使用路由表發送)，MaxIOVectorLength(為發送和接收資料的wsabuf結構數量提供标準值)None 不對次調用使用标志） OutOfBand（消息的部分發送或接收）Partial（消息的部分發送或接收） Peek（檢視傳入的消息）

原型三：public int Send(byte[],int,SocketFlags) 參數二要發送的位元組數

原型四：public int Send(byte[],int,int,SocketFlags) 參數二為Byte[]中開始發送的位置

示範：

Socket bbb=sock.Accept();

Byte[] bytes=new Byte[64];

string send="aaaaaaaaaaaa";

bytes=System.Text.Encoding.BigEndianUnicode.GetBytes(send.ToCharArray());

bbb.Send(bytes,bytes.length,0);//将byte數組全部發送

.NetWordStream類的Write方法發送資料

原型：public override void write(byte[] buffer,int offset,int size) 位元組數組，開始位元組位置，總位元組數

Socket bbb=sock.Accept();

.NetWorkStream stre=new NewWorkStream(bbb);

Byte[] ccc=new Byte[512];

string sendmessage="aaaaaaaaaaaaaa";

ccc=System.Text.Encoding.BigEndianUnicode.GetBytes(sendmessage);

stre.Write(ccc,0,ccc.length);

接收資料：Socket類Receive.NetworkStream類Read

Socket類Receive方法

原型：public int Receive(byte[] buffer)   

2)public int Receive(byte[],SocketFlags)

3)public int Receive(byte[],int,SocketFlags)   

4)public int Receive(byte[],int,int,SocketFlags)

.....

Socket bbb=sock.Accept();

........

Byte[] ccc=new Byte[512];

bbb.Receive(ccc,ccc.Length,0);

string rece=System.Text.Encoding.BigEndianUnicode.GetString(ccc);

richTextBox1.AppendText(rece+"/r/n");

.NetworkStream類的Read方法接收資料

public override int Read(int byte[] buffer,int offset,int size)

示範：bbb=sock.Accept();

.......

.NetworkStream stre=new.NetworkStream(bbb);

Byte[] ccc=new Byte[512];

stre.Read(ccc,0,ccc.Length);

string readMessage=System.Text.Encoding.BigEndianUnicode.GetString(ccc);

線程

線程建立：System.Threading空間下的Thread類的構造方法：

原型：public Thread(ThreadStart start) ThreadStart類型值     

       Thread thread=new Thread(new ThreadStart(accp));

       Private void accp(){}//使用線程操作

線程啟動

Thread thread=new Thread(new ThreadStart(accp));

線程暫停與重新啟動

啟動線程使用Thread.Sleep是目前線程阻塞一段時間Thread.Sleep(Timeout.Infinite)是線程休眠，直到被調用Thread.Interrrupt的另一個線程中斷或被Thread.Abort中止。

一個線程不能對另一個調用Sleep,可以使用Thread.Suspend來暫停線程，當線程對自身調用Thread.Suspend将阻塞，直到該線程被另一個線程繼續，當一個線程對另一個調用，該調用就成為使另一個線程暫停的非阻塞調用。調用Thread.Resume使另一個線程跳出挂起狀态并使該線程繼續執行，而與調用Thread.Suspend的次數無關

線程休眠：Thread.Sleep(10000);

線程挂起：Thread thread=new Thread(new ThreadStart(accp));

                Thread.start();

                Thread.Suspend();

重新啟動:Thread thread=new Thread(new ThreadStart(accp));

               Thread.start();

               Thread.Suspend();

               Thread.Resume();

阻塞線程的方法：thread.Join使用一個線程等待另一個線程停止

Thread.Join

Public void Join();

Public void Join(int millisecondsTimeout);毫秒

Public bool Join(TimeSpan timeout);時間間隔類型值

執行個體：Thread thread=new Thread(new ThreadStart(accp));

              Thread.start();

              Thread.Join(10000);

線程銷毀：

Thread.Abort,Thread.Interrupt

Abort方法引發ThreadAbortException，開始中止此線程的過程，是一個可以由應用程式代碼捕獲的特殊異常，ResetAbort可以取消Abort請求，可以組織ThreadAbortException終止此線程，線程不一定會立即終止，根本不終止。

對尚未啟動的線程調用Abort，則當調用Start時該線程将終止。對已經挂起的線程調用Abort，則該線程将繼續，然後終止。對阻塞或正在休眠的線程調用Abort，則該線程被中斷，然後終止。

Thread類的Abort方法：

Public void Abort()

Public void Abort(object stateinfo);

示範：

Thread thread=new Thread(new ThreadStart(accp));

Thread.Start();

Thread.Abort();

Thread.Join(10000);

Socket程式設計原理：

Unix的i/o指令集，模式為開－讀/寫－關 open write/read close

使用者程序進行i/o操作

使用者程序調用打開指令，擷取檔案或裝置的使用權，并傳回描述檔案或裝置的整數，以描述使用者打開的程序，該程序進行讀寫操作，傳輸資料，操作完成，程序關閉，通知os對哪個對象進行了使用。

Unix網絡應用程式設計：BSD的套接字socket，unix的System V 的TLI。

套接字程式設計的基本概念：

網間程序通信：源于單機系統，每個程序在自己的位址範圍内進行運作，保證互相不幹擾且協調工作。作業系統為程序之間的通信提供設施：

Unix BSD 管道pipe,命名管道named pipe軟中斷信号signal

Unix System V 消息message 共享存儲區 shared memory 信号量semaphore

以上僅限于本機程序之間通信。

端口：網絡上可以被命名和尋址的通信端口，是作業系統可以配置設定的一種資源，網絡通信的最終位址不是主機位址，是可以描述程序的摸中辨別符。TCP/IP提出協定端口porotocol port端口，表示通信程序。

       程序通過os調用綁定連接配接端口，而在傳輸層傳輸給該端口的資料傳入程序中處理，同樣在程序的資料需要傳給傳輸層也是通過綁定端口實作。程序對端口的操作相當于對os中的i/o檔案進行操作，每一個端口也對應着一個端口号，tcp/ip協定分為tcp和udp，雖然有相同port number的端口，但是互相也不沖突。 端口号的配置設定有全局配置設定，本地配置設定（動态配置設定），當程序需要通路傳輸層，os配置設定給程序一個端口号。全局配置設定，就是os固定配置設定的端口，标準的伺服器都有固定的全局公認的端口号提供給服務。小于256的可以作為保留端口。

       位址：網絡通信中的兩台機器，可以不再同一個網絡，可能間隔（網關，網橋，路由器等），是以可以分為三層尋址

機器在不同的網絡則有該網絡的特定id

同一個網絡中的機器應該有唯一的機器id

一台機器内的程序應該有自己的唯一id

通常主機位址＝網絡ID＋主機ID  tcp/ip中使用16位端口号來表示程序。

網絡位元組順序，高價先存，tcp和udp都使用16或32整數位的高價存儲，在協定的頭檔案中。

半相關：在網絡中一個程序為協定＋本地位址＋端口号＝三元組，也叫半相關，表示半部分。

全相關：兩台機器之間通信需要使用相同協定

              協定＋本地位址＋本地端口号＋遠端位址＋遠端端口号 五元組 全相關。

順序：兩個連續的封包在網絡中可能不會通過相同的路徑到達，是以接收的順序會和發送的順序不一緻。順序是接收順序與發送順序一緻。Tcp/ip提供該功能。

差錯控制：檢查資料差錯：檢查和CheckSum機制 檢查連接配接差錯：雙方确認應答機制。

流控制：雙方傳輸資料過程中，保證資料傳輸速率的機制，保證資料不丢失。

位元組流：把傳輸中的封包當作一個位元組序列，不提供任何資料邊界。

全雙工/半雙工：兩個方向發送或一個方向發送

緩存/帶外資料：位元組流服務中，沒有封包邊界，可以同一時刻讀取任意長度的資料。為保證傳輸正确或流協定控制，需要使用緩存，互動型的應用程式禁用緩存。

資料傳送中，希望不通過正常傳輸方式傳送給使用者以便及時處理的某一類資訊（unix系統的中斷鍵delete,Control-c）、終端流控制符Control-s、Control-q)為帶外資料。

客戶/伺服器模式主動請求方式:

1.       打開通信通道，通知本地主機，在某一個公認位址上接收客戶請求

2.       等待客戶請求到達端口

3.       接收到重複服務請求，處理請求發送應答信号。接收到并發服務請求。要激活一個新程序處理客戶請求，unix系統fork、exec，新程序處理客戶請求，不需要對其他請求作出應答，服務完成後，關閉此程序與客戶的通信鍊路。終止

4.       傳回第二步，等待另一個客戶請求。

5.       關閉服務端

客戶方：

1.       打開一通信通道，并連接配接到伺服器所在主機的特定端口。

2.       向伺服器發送服務請求封包，等待并接收應答；繼續提出請求…….

3.       請求結束以後關閉通信通道并終止。

：

1.       客戶與伺服器程序的作用非對稱，編碼不同

2.       服務程序先于客戶請求而啟動，系統運作，服務程序一緻存在，直到正常退出或強迫退出

套接字類型：

TCP/IP的socket

Sock_stream可靠的面對連接配接資料傳輸，無差錯、無重複發送，安照順序發送接收，内設流量控制，避免資料流超限，資料為位元組流，無長度限制，ftp流套接字。

Sock_DGRAM 無連接配接的服務，資料包以獨立包的形式發送，不提供無措保證，資料可能丢失重複，發送接收的順序混亂，網絡檔案系統nfs使用資料報式套接字。

Sock_Ram 接口允許較底層協定，IP，ICMP直接通路，檢查新的協定實作或通路現有服務中配置的新裝置。

服務端：

using System.Net;

using System.Net.Sockets;

using System.Text;

using System.Threading;

Thread mythread ;

Socket socket;

// 清理所有正在使用的資源。

        protected override void Dispose( bool disposing )

         {

              try

　            {

　　          socket.Close();//釋放資源

　　          mythread.Abort ( ) ;//中止線程

　            }

　            catch{ }

             if( disposing )

              {

                   if (components != null)

                   {

                       components.Dispose();

                   }

              }

              base.Dispose( disposing );

         }       

         public static IPAddress GetServerIP()

         {

              IPHostEntry ieh=Dns.GetHostByName(Dns.GetHostName());

              return ieh.AddressList[0];

         }

         private void BeginListen()

         {

              IPAddress ServerIp=GetServerIP();

              IPEndPoint iep=new IPEndPoint(ServerIp,8000);

              socket=new

                       Socket(AddressFamily.Inte.Network,SocketType.Stream,ProtocolType.Tcp);

              byte[] byteMessage=new byte[100]; 

              this.label1.Text=iep.ToString();

              socket.Bind(iep); 

//            do

              while(true)

              {

                   try

                   {

                       socket.Listen(5);

                       Socket newSocket=socket.Accept();

                       newSocket.Receive(byteMessage);

                       string sTime = DateTime.Now.ToShortTimeString ( ) ;

string msg=sTime+":"+"Message from:";

msg+=newSocket.RemoteEndPoint.ToString()+Encoding.Default.GetString(byteMessage);

                       this.listBox1.Items.Add(msg);

                   }

                   catch(SocketException ex)

                   {

                       this.label1.Text+=ex.ToString();

                   }

              }

//            while(byteMessage!=null);

         }

         //開始監聽

         private void button1_Click(object sender, System.EventArgs e)

         {

              try

              {

                   mythread = new Thread(new ThreadStart(BeginListen));

                   mythread.Start();

              }

              catch(System.Exception er)

              {

                   MessageBox.Show(er.Message,"完成",MessageBoxButtons.OK,MessageBoxIcon.Stop);

              }

         }

用戶端：

using System.Net;

using System.Net.Sockets;

using System.Text;

         private void button1_Click(object sender, System.EventArgs e)

         {

              BeginSend();      

         }

         private void BeginSend()

         {            

              string ip=this.txtip.Text;

              string port=this.txtport.Text;

              IPAddress serverIp=IPAddress.Parse(ip);           

              int serverPort=Convert.ToInt32(port);

              IPEndPoint iep=new IPEndPoint(serverIp,serverPort); 

              byte[] byteMessage; 

//            do

//            {

                   Socket socket=new Socket(AddressFamily.Inte.Network,SocketType.Stream,ProtocolType.Tcp);

                   socket.Connect(iep);

                   byteMessage=Encoding.ASCII.GetBytes(textBox1.Text);

                   socket.Send(byteMessage);

                   socket.Shutdown(SocketShutdown.Both);

                   socket.Close();

//            }

//            while(byteMessage!=null);

         }

基于TCP協定的發送和接收端

TCP協定的接收端

using System.Net.Sockets ; //使用到TcpListen類

using System.Threading ; //使用到線程 

using System.IO ; //使用到StreamReader類

         int port = 8000; //定義偵聽端口号

         private Thread thThreadRead; //建立線程，用以偵聽端口号，接收資訊

         private TcpListener tlTcpListen; //偵聽端口号

         private bool blistener = true; //設定标示位，判斷偵聽狀态

         private.NetworkStream nsStream; //建立接收的基本資料流 

         private StreamReader srRead;

         private System.Windows.Forms.StatusBar statusBar1;

         private System.Windows.Forms.Button button1;

         private System.Windows.Forms.ListBox listBox1; //從網絡基礎資料流中讀取資料

         private TcpClient tcClient ;

          private void Listen ( )

         {

              try

              {

                   tlTcpListen = new TcpListener ( port ) ; //以8000端口号來初始化TcpListener執行個體

                   tlTcpListen.Start ( ) ; //開始監聽

                   statusBar1.Text = "正在監聽..." ;

                   tcClient = tlTcpListen.AcceptTcpClient ( ) ; //通過TCP連接配接請求

                   nsStream = tcClient.GetStream ( ) ; //擷取用以發送、接收資料的網絡基礎資料流

                   srRead=new StreamReader(nsStream);//以得到的網絡基礎資料流來初始化StreamReader執行個體

                   statusBar1.Text = "已經連接配接！";

                    while( blistener ) //循環偵聽

                   {

                       string sMessage = srRead.ReadLine();//從網絡基礎資料流中讀取一行資料

                       if ( sMessage == "STOP" ) //判斷是否為斷開TCP連接配接控制碼

                       {

                            tlTcpListen.Stop(); //關閉偵聽

                            nsStream.Close(); //釋放資源

                            srRead.Close();

                            statusBar1.Text = "連接配接已經關閉！" ;

                            thThreadRead.Abort(); //中止線程

                            return;

                       }

                       string sTime = DateTime.Now.ToShortTimeString ( ) ; //擷取接收資料時的時間

                       listBox1.Items.Add ( sTime + " " + sMessage ) ;

                   }

              }

              catch ( System.Security.SecurityException )

              {

                   MessageBox.Show ( "偵聽失敗！" , "錯誤" ) ;

              }

         }

         //開始監聽

         private void button1_Click(object sender, System.EventArgs e)

         {

              thThreadRead = new Thread ( new ThreadStart ( Listen ) );

              thThreadRead.Start();//啟動線程          

              button1.Enabled=false;

         }

         // 清理所有正在使用的資源。

         protected override void Dispose( bool disposing )

         {

              try

              {

                   tlTcpListen.Stop(); //關閉偵聽

                   nsStream.Close();

                   srRead.Close();//釋放資源

                   thThreadRead.Abort();//中止線程

              }

              catch{}

              if( disposing )

              {

                   if (components != null)

                   {

                       components.Dispose();

                   }

             }

              base.Dispose( disposing );

         }

TCP協定的發送端

using System.Net.Sockets; //使用到TcpListen類

using System.Threading; //使用到線程

using System.IO; //使用到StreamWriter類

using System.Net; //使用IPAddress類、IPHostEntry類等

          private StreamWriter swWriter; //用以向網絡基礎資料流傳送資料　

         private.NetworkStream nsStream; //建立發送資料的網絡基礎資料流　

         private TcpClient tcpClient;

         private System.Windows.Forms.Button button1;

         private System.Windows.Forms.TextBox textBox1;

         private System.Windows.Forms.Button button2;

         private System.Windows.Forms.TextBox textBox2;

         private System.Windows.Forms.StatusBar statusBar1;

         private System.Windows.Forms.Label label1;

         private System.Windows.Forms.Label label2; //通過它實作向遠端主機提出TCP連接配接申請　

         private bool tcpConnect = false; //定義辨別符，用以表示TCP連接配接是否建立

          //連接配接　

         private void button1_Click(object sender, System.EventArgs e)

         {

              IPAddress ipRemote ;

              try

              {

                   ipRemote = IPAddress.Parse ( textBox1.Text ) ;

              }

              catch //判斷給定的IP位址的合法性

              {

                   MessageBox.Show ( "輸入的IP位址不合法！" , "錯誤提示！" ) ;

                   return ;

              }

              IPHostEntry ipHost ;

              try

              {

                   ipHost = Dns.Resolve ( textBox1.Text ) ;　

              }

              catch //判斷IP位址對應主機是否線上

              {

                   MessageBox.Show ("遠端主機不線上！" , "錯誤提示！" ) ;

                   return ;

              }

              string sHostName = ipHost.HostName ;

              try

              {

                   TcpClient tcpClient = new TcpClient(sHostName,8000);//對遠端主機的8000端口提出TCP連接配接申請

                   nsStream = tcpClient.GetStream();//通過申請，并擷取傳送資料的網絡基礎資料流　　

                   swWriter = new StreamWriter(nsStream);//使用擷取的網絡基礎資料流來初始化StreamWriter執行個體

                   button1.Enabled = false ;

                   button2.Enabled = true ;

                   tcpConnect = true ;

                   statusBar1.Text = "已經連接配接！" ;

              }

              catch

              {

                   MessageBox.Show ( "無法和遠端主機8000端口建立連接配接！" , "錯誤提示！" ) ;

                   return ;

              }

         }

          //發送

         private void button2_Click(object sender, System.EventArgs e)

         {

              if (textBox2.Text !="")

              {

                   swWriter.WriteLine(textBox2.Text);//重新整理目前資料流中的資料

                   swWriter.Flush();

              }

              else

              {

                   MessageBox.Show("發送資訊不能為空！","錯誤提示！");

              }

         }

         // 清理所有正在使用的資源。

         protected override void Dispose( bool disposing )

         {

              if ( tcpConnect )

              {

                   swWriter.WriteLine ( "STOP" ) ; //發送控制碼　　

                   swWriter.Flush (); //重新整理目前資料流中的資料　　

                   nsStream.Close (); //清除資源

                   swWriter.Close ();

              }

              if( disposing )

              {

                   if (components != null)

                   {

                       components.Dispose();

                   }

              }

              base.Dispose( disposing );

         }

異步套接字

BeginAccept

Public IAsyncResult BeginAccept{AsyncCallback callback,object state}

AsyncCallback異步回調方法 object state自定義對象， 傳回IasyncResult

Using System;

Namespace mySocket

{

       Public class  Stateobject

{

       Public StateObject(){構造函數邏輯}

}

}à>

Using System;

Using System.Net;

Using System.Net.Sockets;

Using System.Threading;

Using System.Text;

Namespace mysocket

{

       Public Class StateObject

{

       Public Socket worksocket=null;

       Public const int buffersize=1024;

       Public byte[] buffer=new byte[buffersize];

       Public StringBuilder sb=new StringBuilder();

       Public StateObject()

       {}

}

}

實作主機綁定和端口監聽：

Private IPAddress myIP=IPAddress.Parse(“127.0.0.1”);

Private IPEndPoint MyServer;

Private Socket mySocket;

Private Socket Handler;

Private Static ManualResetEvent myreset =new ManualResetEvent(false);

Try

{

       IPHostEntry myhost=new IPHostEntry();

       Myhost=dns.gethostbyName(“”);

       String IPString =myhost.Addresslist[0].tostring();

       Myip=IPAddress.Parse(IPString);

}

Catch{MessageBox.Show(“您輸入的IP位址格式不正确，重新輸入！”);}

Try

{

       MyServer=new IPEndPoint(myIP,Int32.Parse(“Port”));

       Mysocket=new Socket(AddressFamily.Inte.Network,SocketType.Stream,Protocol.Tcp);

       Mysocket.Bind(Myserver);

       Mysocket.Listen(50);

       Thread thread=new Thread(new ThreadStart(target));

       Thread.Start();

}

Catch(Exception ee){}

線程target

Private void target()

{

       While(true)

{

       myReset.Reset();

       mysocket.BeginAccept(new AsyncCallBack(AcceptCallback),mysocket);

       myReset.WaitOne();

}

}

異步回調方法AcceptCallBack

Private void AcceptCallback(IAsyncResault ar)

{

       myReset.Set();

       Socket Listener=(Socket)ar.AsyncState;

       Handler=Listener.EndAccept(ar);

       StateObject state=new StateObject();

       State.workSocket=handler;

       Try

       {

       Byte[] byteData=System.Text.Encoding.BigEndianUnicode.GetBytes(“通話！”+”/n/r”);

    Handler.BeginSend(byuteData,0,byteData.Length,0,new AsyncCallback(SendCallback),handler);

}

Catch(Exception ee)

{MessageBox.Show(ee.Message);}

Thread thread=new Thread(new ThreadStart(begreceive));

Thread.Start();

}

多線程：

每個窗體自己都在不同的線程上面運作，如果需要在窗體之間互動，需要線上程之間互動

當線程sleep，系統就使之退出執行隊列，當睡眠結束，系統産生時鐘中斷，使該線程回到執行隊列中，回複線程的執行。

如果父線程先于子線程結束，那麼子線程在父線程結束的時候被迫結束，Thread.Join()是父線程等待子線程結束。Abort帶來的是不可回複的終止線程

起始線程為主線程，前台線程全部結束，則主線程可以終止，背景線程無條件終止。

前台線程不妨礙程式終止，一旦程序的所有前台線程終止，則clr調用任意一個還存活的背景線程的abort來徹底終止程序。

挂起，睡眠（阻塞，暫停）

Thread.Suspend不會使線程立即停止執行，直到線程到達安全點的時候它才可以将該線程挂起，如果線程尚未運作或這已經停止，則不能被挂起，調用thread.resume使另一個線程跳出挂起狀态，繼續執行。

一個線程不能對另一個線程調用sleep，但是可以suspend。

Lock可以把一段代碼定義為互斥段critical section 互斥段在一個時刻内隻允許一個線程進入執行，其他線程必須等待

多線程公用對象，不應該使用lock，monitor提供了線程共享資源的方案，monitor可以鎖定一個對象，線程隻有得到鎖才可以對該對象進行操作

一個程序開始至少有一個主線程。系統加載程式時建立主執行線程

消息隊列與線程相關

一開始建立線程就産生消息隊列了，一個線程可以建立多個窗體,而發給這些窗體的消息都同意發送到同一個消息隊列中了，消息結構中有msg.hwnd指出該條消息與哪個窗體相關

DispatchMessage()函數依照這個保證消息分派處理自動化而且不會出錯。

線程控制方法：

Start線程開始運作

Sleep 是線程暫停一段指定時間

Suspend 線程在到達安全點後暫停

Abort 線程到達安全點後停止

Resume 重新啟動挂起的線程

Join 目前線程等待其他線程運作結束。如果使用逾時值，且線程在配置設定的時間内結束，方法傳回true

安全點：代碼中的某些位置，這些位置公共語言運作時可以安全的執行自動垃圾回收，即釋放未使用的變量并回收記憶體，調用線程的abort和suspend方法時，公共語言運作時将分析代碼并确定線程停止運作的适當位置。