程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> .NET網頁編程 >> C# >> C#入門知識 >> c#中的socket(tcp)

c#中的socket(tcp)

編輯:C#入門知識

實只要用到Socket聯接,基本上就得使用Thread,是交叉使用的。
C#封裝的Socket用法基本上不算很復雜,只是不知道托管之後的Socket有沒有其他性能或者安全上的問題。
在C#裡面能找到的最底層的操作也就是socket了,概念不做解釋。
程序模型如下:
WinForm程序 : 啟動端口偵聽;監視Socket聯接情況;定期關閉不活動的聯接;
Listener:處理Socket的Accept函數,偵聽新鏈接,建立新Thread來處理這些聯接(Connection)。
Connection:處理具體的每一個聯接的會話。

1:WinForm如何啟動一個新的線程來啟動Listener:
       //start the server
        private void btn_startServer_Click(object sender, EventArgs e)
        {
            //this.btn_startServer.Enabled = false;
            Thread _createServer = new Thread(new ThreadStart(WaitForConnect));
            _createServer.Start();
        }
        //wait all connections
        private void WaitForConnect()
        {
            SocketListener listener = new SocketListener(Convert.ToInt32(this.txt_port.Text));
             listener.StartListening();
        }
因為偵聽聯接是一個循環等待的函數,所以不可能在WinForm的線程裡面直接執行,不然Winform也就是無法繼續任何操作了,所以才指定一個新的線程來執行這個函數,啟動偵聽循環。
這一個新的線程是比較簡單的,基本上沒有啟動的參數,直接指定處理函數就可以了。
2:Listener如何啟動循環偵聽,並且啟動新的帶有參數的線程來處理Socket聯接會話。
先看如何建立偵聽:(StartListening函數)
IPEndPoint localEndPoint = new IPEndPoint(_ipAddress, _port);
        // Create a TCP/IP socket.
        Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            // Bind the socket to the local endpoint and  listen for incoming connections.
            try
            {
                listener.Bind(localEndPoint);
                listener.Listen(20);//20 trucks

                // Start listening for connections.
                while (true)
                {
                   // here will be suspended while waiting for a new connection.
                    Socket connection = listener.Accept();
                    Logger.Log("Connect", connection.RemoteEndPoint.ToString());//log it, new connection
                ……
           }
         }……
基本步驟比較簡單:
建立本機的IPEndPoint對象,表示以本機為服務器,在指定端口偵聽;
然後綁定到一個偵聽Socket上;
進入while循環,等待新的聯接;
如果有新的聯接,那麼建立新的socket來對應這個聯接的會話。
   值得注意的就是這一句聯接代碼:listener.Accept()。執行這一句的時候,程序就在這個地方等待,直到有新的聯檢請求的時候程序才會執行下一句。這是同步執行,當然也可以異步執行。
 
   新的聯接Socket建立了(Accept之後),對於這些新的socket該怎麼辦呢?他們依然是一個循環等待,所以依然需要建立新的Thread給這些Socket去處理會話(接收/發送消息),而這個Thread就要接收參數了。
   Thread本身是不能接收參數的,為了讓它可以接收參數,可以采用定義新類,添加參數作為屬性的方法來解決。
   因為每一個Socket是一個Connection周期,所以我定義了這麼一個類public class Connection。這個類至少有這樣一個構造函數public Connection(Socket socket); 之所以這麼做,就是為了把Socket參數傳給這個Connection對象,然後好讓Listener啟動這個Thread的時候,Thread可以知道他正在處理哪一個Socket。
    具體處理的方法:(在Listener的StartListening函數,ocket connection = listener.Accept();之後)
    Connection gpsCn = new Connection(connection);
                    //each socket will be wait for data. keep the connection.
                    Thread thread = new Thread(new ThreadStart(gpsCn.WaitForSendData));
                    thread.Name = connection.RemoteEndPoint.ToString();
                    thread.Start();
 如此一來,這個新的socket在Accept之後就在新的Thread中運行了。
   3:Connection的會話處理
   建立了新的Connection(也就是socket),遠程就可以和這個socket進行會話了,無非就是send和receive。
   現在先看看怎麼寫的這個線程運行的Connection. WaitForSendData函數
    while (true)
            {
                bytes = new byte[1024];
                string data = "";
                //systm will be waiting the msg of receive envet. like Accept();
                //here will be suspended while waiting for socket income msg.
                int bytesRec = this._connection.Receive(bytes);
                _lastConnectTime = DateTime.Now;
                if (bytesRec == 0)//close envent
                {
                    Logger.Log("Close Connection", _connection.RemoteEndPoint.ToString());
                    break;
&nbs

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved