關於socket的Accept阻塞模式的退出方法分析

衆所周知，socket的Accept會阻塞當前線程。若是子程序，或者類在被回收時，沒有正確的停止socket，則會引起一些異常。我說下經常使用的一些處理方法：

1.強行中斷線程。

    這種方法我以爲是最差的，由於強行中斷正在執行的線程，可能會引起一些意想不到的結果，這是最差的方法。

2.在Socket上調用Pending()方法。

    這種作法的原理就是：

       a.看Socket是否有鏈接請求。若是沒有，則返回失敗

       b.失敗後調用Sleep方法等待線程，而後再循環到a

    我認爲，這也不是一種好的辦法，至關於人工進行了可控制的等待，Accept原本就有阻塞功能，這樣作不是畫蛇添足嗎？

3.在.net程序中用異常捕捉法，以下代碼所示：

public void init(int nProt = 9988)
{
    tlTcpListen = new TcpListener(IPAddress.Parse("127.0.0.1"), nProt);
    tlTcpListen.Start();
    Thread client = new Thread(new ThreadStart(DoListen));
    client.Start();
}
 
static void DoListen()
{
    try
    {
    //if (!tlTcpListen.Pending())
    TcpClient tcpClient = tlTcpListen.AcceptTcpClient();
    Debug.WriteLine("有鏈接進入");
    int id = Thread.CurrentThread.ManagedThreadId;
    info.Add(Thread.CurrentThread.ManagedThreadId, tcpClient);
 
    }
    catch (ObjectDisposedException)
    {
;
    }
    catch (SocketException socketException)
    {
    if (socketException.ErrorCode == (int)SocketError.Interrupted)
    {
            Debug.WriteLine("已取消阻止 System.Net.Sockets.Socket 調用的操做。");
            return;
    }
    Debug.WriteLine("有錯誤發生，代碼爲" + socketException.ErrorCode.ToString());
    }
}
public void Dispose()
{
    if (tlTcpListen != null)tlTcpListen.Stop();
}

  在CSDN的論壇中我看到有人說，用異常捕捉總給人感受很差。可是若是你查一下文檔，就會發現SocketError.Interrupted是很正常的狀態，大可沒必要介意。
其實C++也是這麼作的，可是不會出異常。
相應的代碼以下，我也給出來代你們參考，但願能消除你們內心對.net 異常處理的各類不爽

bool NetWorkGate::init(UINT nPort)
{
    //啓動套接字
    WSADATA wsaData;
    //ZeroMemory(&wsaData,sizeof(WSADATA));
    if (WSAStartup(MAKEWORD(1,1),&wsaData))
    {
        TRACE(_T("初始化sock失敗\n"));
        return false;
    }
 
    m_ListenSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (m_ListenSocket == INVALID_SOCKET)
    {
        TRACE(_T("建立監聽sock失敗\n"));
        return false;
    }
    //端口綁定
    SOCKADDR_IN local;
    local.sin_addr.S_un.S_addr = htonl(INADDR_ANY);
    local.sin_family = AF_INET;
    local.sin_port = htons(nPort);
    if (bind(m_ListenSocket, (sockaddr *)&local, sizeof(SOCKADDR_IN)) == SOCKET_ERROR)
    {
        closesocket(m_ListenSocket);
        m_ListenSocket = INVALID_SOCKET;
        return false;
    }
    listen(m_ListenSocket,5);
    CWinThread* thread = AfxBeginThread(BeginAccept,(LPVOID)m_ListenSocket);//啓動線程來監聽，避免阻塞
    return true;
}
 
void NetWorkGate::stop(void)
{
    if (m_ListenSocket != INVALID_SOCKET)
    {
 
        shutdown(m_ListenSocket, SD_BOTH);
        closesocket(m_ListenSocket);
        while (m_count > 0)
        {
            Sleep(100);
        }
    }
    return;
}
//線程，用來阻塞sock，監聽並等待鏈接
UINT NetWorkGate::BeginAccept(LPVOID pParam)
{
    using namespace std;
    list<SOCKET> lst_socket ;
    while (true)
    {
        TRACE(_T("\n正在等待客戶端的接入\n"));
        sockaddr_in remote_addr;
        int addr_len = sizeof(sockaddr);
        printf("accept start\n");
        SOCKET sock = accept((SOCKET)pParam, (sockaddr *)&remote_addr, &addr_len);
        if (INVALID_SOCKET == sock)
        {
            TRACE(_T("網絡鏈接被斷開，線程將會返回。。\n"));
            list<SOCKET>::iterator i;
            for (i = lst_socket.begin(); i != lst_socket.end(); ++i)
            {
                shutdown(*i, SD_BOTH);
                closesocket(*i);
            }
            //關閉全部客戶端的鏈接
            return 0;
        } 
        else
        {
            TRACE(_T("客戶鏈接成功\n"));
            lst_socket.push_back(sock);
            m_count++;
            //在這裏可進帳號驗證，若是驗證成功就會啓動新的線程進行消息分發。
            //保存sock，以備後續進行關閉。
            AfxBeginThread(StartNewClient,(LPVOID)sock);
        }
    }
    return 0;
}
//線程的線程，每一個客戶端都會創建一個新的鏈接
UINT NetWorkGate::StartNewClient(LPVOID pParam)
{
    int iResult =0;
    SOCKET sock = (SOCKET)pParam;
    while (true)
    {
        TRACE(_T("--新的客戶端被接受，正在等待消息--\n"));
        char recvBuf[50]={0};
        iResult=recv(sock,recvBuf,50,0); 
        if ( iResult > 0 )
        {
            TCHAR szBuf[50]={0};
            swprintf_s(szBuf , _T("%s") , recvBuf);
            TRACE(_T("--收到來自客戶端的消息：%s\n"),szBuf);
            send(sock, (const char *)_T("abcdef") , 10 ,0 );
        }
        else
        {
            if ( iResult == 0 ) TRACE(_T("--網絡鏈接斷開--\n"));
            else TRACE(_T("--錯誤：%d\n"),WSAGetLastError());
            m_count--;
            return 0;
        }
    }
    return 0;
}

從C++代碼咱們能夠看出，.net的處理方式 與C++的處理方式 是同樣的。只不過.net在監聽被關閉而socket被阻時，會拋出錯誤，C++則會(INVALID_SOCKET == sock)成立。