<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    注銷

    注銷

      BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理 ::
      112 隨筆 :: 7 文章 :: 18 評論 :: 0 Trackbacks

    最近由于要做一些Socket方面的項目,所以又溫習了一下Socket和TCP協議編程的一些基本知識,整理一下放在這里。

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

    ???????? }

    ???????? //開始監聽

    ???????? 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協議的發送和接收端

    ?

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

    ???????? }

    posted on 2006-10-14 14:39 注銷..... 閱讀(270) 評論(0)  編輯  收藏 所屬分類: 閱讀摘要
    主站蜘蛛池模板: 免费国产美女爽到喷出水来视频| 日本免费xxxx| 亚洲&#228;v永久无码精品天堂久久 | 国产曰批免费视频播放免费s | 啦啦啦www免费视频| 亚洲一久久久久久久久| 成人免费视频小说| 亚洲精品永久在线观看| 狼友av永久网站免费观看| WWW亚洲色大成网络.COM | 亚洲一区二区三区国产精华液| 国产福利在线免费| 在线亚洲高清揄拍自拍一品区| 在线中文高清资源免费观看| 色婷婷六月亚洲综合香蕉| 亚洲av午夜成人片精品电影| gogo免费在线观看| 亚洲精品成人片在线播放| 伊人久久免费视频| 中文字幕亚洲精品无码| 亚洲精品成人在线| 大地资源中文在线观看免费版| 亚洲电影在线播放| 国产免费人成在线视频| a毛片免费全部在线播放** | 亚洲gay片在线gv网站| 亚洲欧洲精品成人久久奇米网| a毛片全部免费播放| 亚洲精品中文字幕无乱码麻豆| 韩国18福利视频免费观看| 精品97国产免费人成视频| 亚洲国产成人精品青青草原| 四虎永久在线精品免费观看地址 | 日韩免费一区二区三区| 少妇性饥渴无码A区免费| 色偷偷女男人的天堂亚洲网| 日韩精品电影一区亚洲| 99爱视频99爱在线观看免费| 国产精品亚洲AV三区| 99久久精品国产亚洲| 免费少妇a级毛片|