基於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();

}