C# Socket程式設計

//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)

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)

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

mythread.Start();

catch(System.Exception er)

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

//用戶端：

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;

// {

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

// }

基于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 ( )

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 ( "偵聽失敗！" , "錯誤" ) ;

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

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

button1.Enabled=false;

nsStream.Close();

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

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

catch{}

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.TextBox textBox1;

private System.Windows.Forms.Button button2;

private System.Windows.Forms.TextBox textBox2;

private System.Windows.Forms.Label label1;

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

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

//連接配接　

IPAddress ipRemote ;

ipRemote = IPAddress.Parse ( textBox1.Text ) ;

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

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

return ;

IPHostEntry ipHost ;

ipHost = Dns.Resolve ( textBox1.Text ) ;　

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

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

string sHostName = ipHost.HostName ;

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端口建立連接配接！" , "錯誤提示！" ) ;

//發送

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

if (textBox2.Text !="")

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

swWriter.Flush();

else

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

if ( tcpConnect )

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

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

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

swWriter.Close ();

}