其實只要用到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
……
}
}……