最近由于要做一些Socket方面的項目，所以又溫習了一下Socket和TCP協(xié)議編程的一些基本知識，整理一下放在這里。
Socket基本編程
服務端：
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.InterNetwork,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);
???????? }
???????? //開始監(jiān)聽
???????? 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.InterNetwork,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協(xié)議的發(fā)送和接收端
?
TCP協(xié)議的接收端
?
using System.Net.Sockets ; //使用到TcpListen類
using System.Threading ; //使用到線程?
using System.IO ; //使用到StreamReader類
?
???????? int port = 8000; //定義偵聽端口號
???????? private Thread thThreadRead; //創(chuàng)建線程，用以偵聽端口號，接收信息
???????? private TcpListener tlTcpListen; //偵聽端口號
???????? private bool blistener = true; //設定標示位，判斷偵聽狀態(tài)
???????? private NetworkStream nsStream; //創(chuàng)建接收的基本數(shù)據(jù)流?
???????? private StreamReader srRead;
???????? private System.Windows.Forms.StatusBar statusBar1;
???????? private System.Windows.Forms.Button button1;
???????? private System.Windows.Forms.ListBox listBox1; //從網(wǎng)絡基礎數(shù)據(jù)流中讀取數(shù)據(jù)
???????? private TcpClient tcClient ;
?
???????? private void Listen ( )
???????? {
????????????? try
????????????? {
?????????????????? tlTcpListen = new TcpListener ( port ) ; //以8000端口號來初始化TcpListener實例
?????????????????? tlTcpListen.Start ( ) ; //開始監(jiān)聽
?????????????????? statusBar1.Text = "正在監(jiān)聽..." ;
?????????????????? tcClient = tlTcpListen.AcceptTcpClient ( ) ; //通過TCP連接請求
?????????????????? nsStream = tcClient.GetStream ( ) ; //獲取用以發(fā)送、接收數(shù)據(jù)的網(wǎng)絡基礎數(shù)據(jù)流
?????????????????? srRead=new StreamReader(nsStream);//以得到的網(wǎng)絡基礎數(shù)據(jù)流來初始化StreamReader實例
?????????????????? statusBar1.Text = "已經(jīng)連接！";
?
?????????????????? while( blistener ) //循環(huán)偵聽
?????????????????? {
?????????????????????? string sMessage = srRead.ReadLine();//從網(wǎng)絡基礎數(shù)據(jù)流中讀取一行數(shù)據(jù)
?????????????????????? if ( sMessage == "STOP" ) //判斷是否為斷開TCP連接控制碼
?????????????????????? {
??????????????????????????? tlTcpListen.Stop(); //關閉偵聽
??????????????????????????? nsStream.Close(); //釋放資源
??????????????????????????? srRead.Close();
??????????????????????????? statusBar1.Text = "連接已經(jīng)關閉！" ;
??????????????????????????? thThreadRead.Abort(); //中止線程
??????????????????????????? return;
?????????????????????? }
?
?????????????????????? string sTime = DateTime.Now.ToShortTimeString ( ) ; //獲取接收數(shù)據(jù)時的時間
?????????????????????? listBox1.Items.Add ( sTime + " " + sMessage ) ;
?????????????????? }
????????????? }
????????????? catch ( System.Security.SecurityException )
????????????? {
?????????????????? MessageBox.Show ( "偵聽失敗！" , "錯誤" ) ;
????????????? }
???????? }
???????? //開始監(jiān)聽
???????? 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協(xié)議的發(fā)送端
?
using System.Net.Sockets; //使用到TcpListen類
using System.Threading; //使用到線程
using System.IO; //使用到StreamWriter類
using System.Net; //使用IPAddress類、IPHostEntry類等
?
???????? private StreamWriter swWriter; //用以向網(wǎng)絡基礎數(shù)據(jù)流傳送數(shù)據(jù)
???????? private NetworkStream nsStream; //創(chuàng)建發(fā)送數(shù)據(jù)的網(wǎng)絡基礎數(shù)據(jù)流
???????? 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; //通過它實現(xiàn)向遠程主機提出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();//通過申請，并獲取傳送數(shù)據(jù)的網(wǎng)絡基礎數(shù)據(jù)流
?????????????????? swWriter = new StreamWriter(nsStream);//使用獲取的網(wǎng)絡基礎數(shù)據(jù)流來初始化StreamWriter實例
?????????????????? button1.Enabled = false ;
?????????????????? button2.Enabled = true ;
?????????????????? tcpConnect = true ;
?????????????????? statusBar1.Text = "已經(jīng)連接！" ;
????????????? }
????????????? catch
????????????? {
?????????????????? MessageBox.Show ( "無法和遠程主機8000端口建立連接！" , "錯誤提示！" ) ;
?????????????????? return ;
????????????? }
???????? }
?
????????? //發(fā)送
???????? private void button2_Click(object sender, System.EventArgs e)
???????? {
????????????? if (textBox2.Text !="")
????????????? {
?????????????????? swWriter.WriteLine(textBox2.Text);//刷新當前數(shù)據(jù)流中的數(shù)據(jù)
?????????????????? swWriter.Flush();
????????????? }
????????????? else
????????????? {
?????????????????? MessageBox.Show("發(fā)送信息不能為空！","錯誤提示！");
????????????? }
???????? }
???????? // 清理所有正在使用的資源。
???????? protected override void Dispose( bool disposing )
???????? {
????????????? if ( tcpConnect )
????????????? {
?????????????????? swWriter.WriteLine ( "STOP" ) ; //發(fā)送控制碼
?????????????????? swWriter.Flush (); //刷新當前數(shù)據(jù)流中的數(shù)據(jù)
?????????????????? nsStream.Close (); //清除資源
?????????????????? swWriter.Close ();
????????????? }
????????????? if( disposing )
????????????? {
?????????????????? if (components != null)
?????????????????? {
?????????????????????? components.Dispose();
?????????????????? }
????????????? }
????????????? base.Dispose( disposing );
???????? }