• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            S.l.e!ep.¢%

            像打了激速一樣,以四倍的速度運轉(zhuǎn),開心的工作
            簡單、開放、平等的公司文化;尊重個性、自由與個人價值;
            posts - 1098, comments - 335, trackbacks - 0, articles - 1
              C++博客 :: 首頁 :: 新隨筆 :: 聯(lián)系 :: 聚合  :: 管理
            TCP實現(xiàn)P2P通信、TCP穿越NAT的方法、TCP打洞
            2007-12-17 18:00

            下載源代碼

            Internet的迅速發(fā)展以及IPv4 地址數(shù)量的限制使得網(wǎng)絡(luò)地址翻譯(NAT,Network Address Trans2lation)設(shè)備得到廣泛應(yīng)用。NAT設(shè)備允許處于同一NAT后的多臺主機共享一個公網(wǎng)(本文將處于同一NAT后的網(wǎng)絡(luò)稱為私網(wǎng),處于NAT前的網(wǎng)絡(luò)稱為公網(wǎng)) IP 地址。一個私網(wǎng)IP 地址通過NAT設(shè)備與公網(wǎng)的其他主機通信。公網(wǎng)和私網(wǎng)IP地址域,如下圖所示:

            廣域網(wǎng)與私網(wǎng)示意圖

            一般來說都是由私網(wǎng)內(nèi)主機(例如上圖中“電腦A-01”)主動發(fā)起連接,數(shù)據(jù)包經(jīng)過NAT地址轉(zhuǎn)換后送給公網(wǎng)上的服務(wù)器(例如上圖中的“Server”),連接建立以后可雙向傳送數(shù)據(jù),NAT設(shè)備允許私網(wǎng)內(nèi)主機主動向公網(wǎng)內(nèi)主機發(fā)送數(shù)據(jù),但卻禁止反方向的主動傳遞,但在一些特殊的場合需要不同私網(wǎng)內(nèi)的主機進行互聯(lián)(例如P2P軟件、網(wǎng)絡(luò)會議、視頻傳輸?shù)龋?,TCP穿越NAT的問題必須解決。網(wǎng)上關(guān)于UDP穿越NAT的文章很多,而且還有配套源代碼,但是我個人認為UDP數(shù)據(jù)雖然速度快,但是沒有保障,而且NAT為UDP準備的臨時端口號有生命周期的限制,使用起來不夠方便,在需要保證傳輸質(zhì)量的應(yīng)用上TCP連接還是首選(例如:文件傳輸)。
            網(wǎng)上也有不少關(guān)于TCP穿越NAT(即TCP打洞)的介紹文章,但不幸我還沒找到相關(guān)的源代碼可以參考,我利用空余時間寫了一個可以實現(xiàn)TCP穿越NAT,讓不同的私網(wǎng)內(nèi)主機建立直接的TCP通信的源代碼。

            這里需要介紹一下NAT的類型:
            NAT設(shè)備的類型對于TCP穿越NAT,有著十分重要的影響,根據(jù)端口映射方式,NAT可分為如下4類,前3種NAT類型可統(tǒng)稱為cone類型。
            (1)全克隆( Full Cone) : NAT把所有來自相同內(nèi)部IP地址和端口的請求映射到相同的外部IP地址和端口。任何一個外部主機均可通過該映射發(fā)送IP包到該內(nèi)部主機。
            (2)限制性克隆(Restricted Cone) : NAT把所有來自相同內(nèi)部IP地址和端口的請求映射到相同的外部IP地址和端口。但是,只有當內(nèi)部主機先給IP地址為X的外部主機發(fā)送IP包,該外部主機才能向該內(nèi)部主機發(fā)送IP包。
            (3)端口限制性克隆( Port Restricted Cone) :端口限制性克隆與限制性克隆類似,只是多了端口號的限制,即只有內(nèi)部主機先向IP地址為X,端口號為P的外部主機發(fā)送1個IP包,該外部主機才能夠把源端口號為P的IP包發(fā)送給該內(nèi)部主機。
            (4)對稱式NAT ( Symmetric NAT) :這種類型的NAT與上述3種類型的不同,在于當同一內(nèi)部主機使用相同的端口與不同地址的外部主機進行通信時, NAT對該內(nèi)部主機的映射會有所不同。對稱式NAT不保證所有會話中的私有地址和公開IP之間綁定的一致性。相反,它為每個新的會話分配一個新的端口號。

            我們先假設(shè)一下:有一個服務(wù)器S在公網(wǎng)上有一個IP,兩個私網(wǎng)分別由NAT-A和NAT-B連接到公網(wǎng),NAT-A后面有一臺客戶端A,NAT-B后面有一臺客戶端B,現(xiàn)在,我們需要借助S將A和B建立直接的TCP連接,即由B向A打一個洞,讓A可以沿這個洞直接連接到B主機,就好像NAT-B不存在一樣。
            實現(xiàn)過程如下(請參照源代碼):
            1、 S啟動兩個網(wǎng)絡(luò)偵聽,一個叫【主連接】偵聽,一個叫【協(xié)助打洞】的偵聽。
            2、 A和B分別與S的【主連接】保持聯(lián)系。
            3、 當A需要和B建立直接的TCP連接時,首先連接S的【協(xié)助打洞】端口,并發(fā)送協(xié)助連接申請。同時在該端口號上啟動偵聽。注意由于要在相同的網(wǎng)絡(luò)終端上綁定到不同的套接字上,所以必須為這些套接字設(shè)置 SO_REUSEADDR 屬性(即允許重用),否則偵聽會失敗。
            4、 S的【協(xié)助打洞】連接收到A的申請后通過【主連接】通知B,并將A經(jīng)過NAT-A轉(zhuǎn)換后的公網(wǎng)IP地址和端口等信息告訴B。
            5、 B收到S的連接通知后首先與S的【協(xié)助打洞】端口連接,隨便發(fā)送一些數(shù)據(jù)后立即斷開,這樣做的目的是讓S能知道B經(jīng)過NAT-B轉(zhuǎn)換后的公網(wǎng)IP和端口號。
            6、 B嘗試與A的經(jīng)過NAT-A轉(zhuǎn)換后的公網(wǎng)IP地址和端口進行connect,根據(jù)不同的路由器會有不同的結(jié)果,有些路由器在這個操作就能建立連接(例如我用的TPLink R402),大多數(shù)路由器對于不請自到的SYN請求包直接丟棄而導致connect失敗,但NAT-A會紀錄此次連接的源地址和端口號,為接下來真正的連接做好了準備,這就是所謂的打洞,即B向A打了一個洞,下次A就能直接連接到B剛才使用的端口號了。
            7、 客戶端B打洞的同時在相同的端口上啟動偵聽。B在一切準備就緒以后通過與S的【主連接】回復消息“我已經(jīng)準備好”,S在收到以后將B經(jīng)過NAT-B轉(zhuǎn)換后的公網(wǎng)IP和端口號告訴給A。
            8、 A收到S回復的B的公網(wǎng)IP和端口號等信息以后,開始連接到B公網(wǎng)IP和端口號,由于在步驟6中B曾經(jīng)嘗試連接過A的公網(wǎng)IP地址和端口,NAT-A紀錄了此次連接的信息,所以當A主動連接B時,NAT-B會認為是合法的SYN數(shù)據(jù),并允許通過,從而直接的TCP連接建立起來了。

            整個實現(xiàn)過程靠文字恐怕很難講清楚,再加上我的語言表達能力很差(高考語文才考75分,總分150分,慚愧),所以只好用代碼來說明問題了。

            服務(wù)器地址和端口號定義#define SRV_TCP_MAIN_PORT  4000
            服務(wù)器主連接的端口號#define SRV_TCP_HOLE_PORT  8000
            服務(wù)器響應(yīng)客戶端打洞申請的端口號

            這兩個端口是固定的,服務(wù)器S啟動時就開始偵聽這兩個端口了。

            將新客戶端登錄信息發(fā)送給所有已登錄的客戶端,但不發(fā)送給自己//BOOL SendNewUserLoginNotifyToAll ( LPCTSTR lpszClientIP, UINT nClientPort, DWORD dwID ){ ASSERT ( lpszClientIP && nClientPort > 0 ); g_CSFor_PtrAry_SockClient.Lock(); for ( int i=0; i<g_PtrAry_SockClient.GetSize(); i++ ) {  CSockClient *pSockClient = (CSockClient*)g_PtrAry_SockClient.GetAt(i);  if ( pSockClient && pSockClient->m_bMainConn && pSockClient->m_dwID > 0 && pSockClient->m_dwID != dwID )  {   if ( !pSockClient->SendNewUserLoginNotify ( lpszClientIP, nClientPort, dwID ) )   {    g_CSFor_PtrAry_SockClient.Unlock();    return FALSE;   }  } } g_CSFor_PtrAry_SockClient.Unlock (); return TRUE;}

            當有新的客戶端連接到服務(wù)器時,服務(wù)器負責將該客戶端的信息(IP地址、端口號)發(fā)送給其他客戶端。

            //// 執(zhí)行者:客戶端A// 有新客戶端B登錄了,我(客戶端A)連接服務(wù)器端口 SRV_TCP_HOLE_PORT ,申請與客戶端B建立直接的TCP連接//BOOL Handle_NewUserLogin ( CSocket &MainSock, t_NewUserLoginPkt *pNewUserLoginPkt ){ printf ( "New user ( %s:%u:%u ) login server\n", pNewUserLoginPkt->szClientIP,  pNewUserLoginPkt->nClientPort, pNewUserLoginPkt->dwID ); BOOL bRet = FALSE; DWORD dwThreadID = 0; t_ReqConnClientPkt ReqConnClientPkt; CSocket Sock; CString csSocketAddress; char szRecvBuffer[NET_BUFFER_SIZE] = {0}; int nRecvBytes = 0; // 創(chuàng)建打洞Socket,連接服務(wù)器協(xié)助打洞的端口號 SRV_TCP_HOLE_PORT try {  if ( !Sock.Socket () )  {   printf ( "Create socket failed : %s\n", hwFormatMessage(GetLastError()) );   goto finished;  }  UINT nOptValue = 1;  if ( !Sock.SetSockOpt ( SO_REUSEADDR, &nOptValue , sizeof(UINT) ) )  {   printf ( "SetSockOpt socket failed : %s\n", hwFormatMessage(GetLastError()) );   goto finished;  }  if ( !Sock.Bind ( 0 ) )  {   printf ( "Bind socket failed : %s\n", hwFormatMessage(GetLastError()) );   goto finished;  }  if ( !Sock.Connect ( g_pServerAddess, SRV_TCP_HOLE_PORT ) )  {   printf ( "Connect to [%s:%d] failed : %s\n", g_pServerAddess,     SRV_TCP_HOLE_PORT, hwFormatMessage(GetLastError()) );   goto finished;  } } catch ( CException e ) {  char szError[255] = {0};  e.GetErrorMessage( szError, sizeof(szError) );  printf ( "Exception occur, %s\n", szError );  goto finished; } g_pSock_MakeHole = &Sock; ASSERT ( g_nHolePort == 0 ); VERIFY ( Sock.GetSockName ( csSocketAddress, g_nHolePort ) ); // 創(chuàng)建一個線程來偵聽端口 g_nHolePort 的連接請求 dwThreadID = 0; g_hThread_Listen = ::CreateThread ( NULL, 0, ::ThreadProc_Listen, LPVOID(NULL), 0, &dwThreadID ); if (!HANDLE_IS_VALID(g_hThread_Listen) ) return FALSE; Sleep ( 3000 ); // 我(客戶端A)向服務(wù)器協(xié)助打洞的端口號 SRV_TCP_HOLE_PORT 發(fā)送申請,希望與新登錄的客戶端B建立連接 // 服務(wù)器會將我的打洞用的外部IP和端口號告訴客戶端B ASSERT ( g_WelcomePkt.dwID > 0 ); ReqConnClientPkt.dwInviterID = g_WelcomePkt.dwID; ReqConnClientPkt.dwInvitedID = pNewUserLoginPkt->dwID; if ( Sock.Send ( &ReqConnClientPkt, sizeof(t_ReqConnClientPkt) ) != sizeof(t_ReqConnClientPkt) )  goto finished; // 等待服務(wù)器回應(yīng),將客戶端B的外部IP地址和端口號告訴我(客戶端A) nRecvBytes = Sock.Receive ( szRecvBuffer, sizeof(szRecvBuffer) ); if ( nRecvBytes > 0 ) {  ASSERT ( nRecvBytes == sizeof(t_SrvReqDirectConnectPkt) );  PACKET_TYPE *pePacketType = (PACKET_TYPE*)szRecvBuffer;  ASSERT ( pePacketType && *pePacketType == PACKET_TYPE_TCP_DIRECT_CONNECT );  Sleep ( 1000 );  Handle_SrvReqDirectConnect ( (t_SrvReqDirectConnectPkt*)szRecvBuffer );  printf ( "Handle_SrvReqDirectConnect end\n" ); } // 對方斷開連接了 else {  goto finished; }  bRet = TRUE;finished: g_pSock_MakeHole = NULL; return bRet;}

            這里假設(shè)客戶端A先啟動,當客戶端B啟動后客戶端A將收到服務(wù)器S的新客戶端登錄的通知,并得到客戶端B的公網(wǎng)IP和端口,客戶端A啟動線程連接S的【協(xié)助打洞】端口(本地端口號可以用GetSocketName()函數(shù)取得,假設(shè)為M),請求S協(xié)助TCP打洞,然后啟動線程偵聽該本地端口(前面假設(shè)的M)上的連接請求,然后等待服務(wù)器的回應(yīng)。

            //// 客戶端A請求我(服務(wù)器)協(xié)助連接客戶端B,這個包應(yīng)該在打洞Socket中收到//BOOL CSockClient::Handle_ReqConnClientPkt(t_ReqConnClientPkt *pReqConnClientPkt){ ASSERT ( !m_bMainConn ); CSockClient *pSockClient_B = FindSocketClient ( pReqConnClientPkt->dwInvitedID ); if ( !pSockClient_B ) return FALSE; printf ( "%s:%u:%u invite %s:%u:%u connection\n", m_csPeerAddress, m_nPeerPort, m_dwID,  pSockClient_B->m_csPeerAddress, pSockClient_B->m_nPeerPort, pSockClient_B->m_dwID ); // 客戶端A想要和客戶端B建立直接的TCP連接,服務(wù)器負責將A的外部IP和端口號告訴給B t_SrvReqMakeHolePkt SrvReqMakeHolePkt; SrvReqMakeHolePkt.dwInviterID = pReqConnClientPkt->dwInviterID; SrvReqMakeHolePkt.dwInviterHoleID = m_dwID; SrvReqMakeHolePkt.dwInvitedID = pReqConnClientPkt->dwInvitedID; STRNCPY_CS ( SrvReqMakeHolePkt.szClientHoleIP, m_csPeerAddress ); SrvReqMakeHolePkt.nClientHolePort = m_nPeerPort; if ( pSockClient_B->SendChunk ( &SrvReqMakeHolePkt, sizeof(t_SrvReqMakeHolePkt), 0 ) != sizeof(t_SrvReqMakeHolePkt) )  return FALSE; // 等待客戶端B打洞完成,完成以后通知客戶端A直接連接客戶端外部IP和端口號 if ( !HANDLE_IS_VALID(m_hEvtWaitClientBHole) )  return FALSE; if ( WaitForSingleObject ( m_hEvtWaitClientBHole, 6000*1000 ) == WAIT_OBJECT_0 ) {  if ( SendChunk ( &m_SrvReqDirectConnectPkt, sizeof(t_SrvReqDirectConnectPkt), 0 )     == sizeof(t_SrvReqDirectConnectPkt) )   return TRUE; } return FALSE;}

            服務(wù)器S收到客戶端A的協(xié)助打洞請求后通知客戶端B,要求客戶端B向客戶端A打洞,即讓客戶端B嘗試與客戶端A的公網(wǎng)IP和端口進行connect。

            //// 執(zhí)行者:客戶端B// 處理服務(wù)器要我(客戶端B)向另外一個客戶端(A)打洞,打洞操作在線程中進行。// 先連接服務(wù)器協(xié)助打洞的端口號 SRV_TCP_HOLE_PORT ,通過服務(wù)器告訴客戶端A我(客戶端B)的外部IP地址和端口號,然后啟動線程進行打洞,// 客戶端A在收到這些信息以后會發(fā)起對我(客戶端B)的外部IP地址和端口號的連接(這個連接在客戶端B打洞完成以后進行,所以// 客戶端B的NAT不會丟棄這個SYN包,從而連接能建立)//BOOL Handle_SrvReqMakeHole ( CSocket &MainSock, t_SrvReqMakeHolePkt *pSrvReqMakeHolePkt ){ ASSERT ( pSrvReqMakeHolePkt ); // 創(chuàng)建Socket,連接服務(wù)器協(xié)助打洞的端口號 SRV_TCP_HOLE_PORT,連接建立以后發(fā)送一個斷開連接的請求給服務(wù)器,然后連接斷開 // 這里連接的目的是讓服務(wù)器知道我(客戶端B)的外部IP地址和端口號,以通知客戶端A CSocket Sock; try {  if ( !Sock.Create () )  {   printf ( "Create socket failed : %s\n", hwFormatMessage(GetLastError()) );   return FALSE;  }  if ( !Sock.Connect ( g_pServerAddess, SRV_TCP_HOLE_PORT ) )  {   printf ( "Connect to [%s:%d] failed : %s\n", g_pServerAddess,     SRV_TCP_HOLE_PORT, hwFormatMessage(GetLastError()) );   return FALSE;  } } catch ( CException e ) {  char szError[255] = {0};  e.GetErrorMessage( szError, sizeof(szError) );  printf ( "Exception occur, %s\n", szError );  return FALSE; } CString csSocketAddress; ASSERT ( g_nHolePort == 0 ); VERIFY ( Sock.GetSockName ( csSocketAddress, g_nHolePort ) ); // 連接服務(wù)器協(xié)助打洞的端口號 SRV_TCP_HOLE_PORT,發(fā)送一個斷開連接的請求,然后將連接斷開,服務(wù)器在收到這個包的時候也會將 // 連接斷開 t_ReqSrvDisconnectPkt ReqSrvDisconnectPkt; ReqSrvDisconnectPkt.dwInviterID = pSrvReqMakeHolePkt->dwInvitedID; ReqSrvDisconnectPkt.dwInviterHoleID = pSrvReqMakeHolePkt->dwInviterHoleID; ReqSrvDisconnectPkt.dwInvitedID = pSrvReqMakeHolePkt->dwInvitedID; ASSERT ( ReqSrvDisconnectPkt.dwInvitedID == g_WelcomePkt.dwID ); if ( Sock.Send ( &ReqSrvDisconnectPkt, sizeof(t_ReqSrvDisconnectPkt) ) != sizeof(t_ReqSrvDisconnectPkt) )  return FALSE; Sleep ( 100 ); Sock.Close (); // 創(chuàng)建一個線程來向客戶端A的外部IP地址、端口號打洞 t_SrvReqMakeHolePkt *pSrvReqMakeHolePkt_New = new t_SrvReqMakeHolePkt; if ( !pSrvReqMakeHolePkt_New ) return FALSE; memcpy ( pSrvReqMakeHolePkt_New, pSrvReqMakeHolePkt, sizeof(t_SrvReqMakeHolePkt) ); DWORD dwThreadID = 0; g_hThread_MakeHole = ::CreateThread ( NULL, 0, ::ThreadProc_MakeHole,   LPVOID(pSrvReqMakeHolePkt_New), 0, &dwThreadID ); if (!HANDLE_IS_VALID(g_hThread_MakeHole) ) return FALSE; // 創(chuàng)建一個線程來偵聽端口 g_nHolePort 的連接請求 dwThreadID = 0; g_hThread_Listen = ::CreateThread ( NULL, 0, ::ThreadProc_Listen, LPVOID(NULL), 0, &dwThreadID ); if (!HANDLE_IS_VALID(g_hThread_Listen) ) return FALSE; // 等待打洞和偵聽完成 HANDLE hEvtAry[] = { g_hEvt_ListenFinished, g_hEvt_MakeHoleFinished }; if ( ::WaitForMultipleObjects ( LENGTH(hEvtAry), hEvtAry, TRUE, 30*1000 ) == WAIT_TIMEOUT )  return FALSE; t_HoleListenReadyPkt HoleListenReadyPkt; HoleListenReadyPkt.dwInvitedID = pSrvReqMakeHolePkt->dwInvitedID; HoleListenReadyPkt.dwInviterHoleID = pSrvReqMakeHolePkt->dwInviterHoleID; HoleListenReadyPkt.dwInvitedID = pSrvReqMakeHolePkt->dwInvitedID; if ( MainSock.Send ( &HoleListenReadyPkt, sizeof(t_HoleListenReadyPkt) ) != sizeof(t_HoleListenReadyPkt) ) {  printf ( "Send HoleListenReadyPkt to %s:%u failed : %s\n",   g_WelcomePkt.szClientIP, g_WelcomePkt.nClientPort,   hwFormatMessage(GetLastError()) );  return FALSE; }  return TRUE;}

            客戶端B收到服務(wù)器S的打洞通知后,先連接S的【協(xié)助打洞】端口號(本地端口號可以用GetSocketName()函數(shù)取得,假設(shè)為X),啟動線程嘗試連接客戶端A的公網(wǎng)IP和端口號,根據(jù)路由器不同,連接情況各異,如果運氣好直接連接就成功了,即使連接失敗,但打洞便完成了。同時還要啟動線程在相同的端口(即與S的【協(xié)助打洞】端口號建立連接的本地端口號X)上偵聽到來的連接,等待客戶端A直接連接該端口號。

            //// 執(zhí)行者:客戶端A// 服務(wù)器要求主動端(客戶端A)直接連接被動端(客戶端B)的外部IP和端口號//BOOL Handle_SrvReqDirectConnect ( t_SrvReqDirectConnectPkt *pSrvReqDirectConnectPkt ){ ASSERT ( pSrvReqDirectConnectPkt ); printf ( "You can connect direct to ( IP:%s  PORT:%d  ID:%u )\n", pSrvReqDirectConnectPkt->szInvitedIP,  pSrvReqDirectConnectPkt->nInvitedPort, pSrvReqDirectConnectPkt->dwInvitedID ); // 直接與客戶端B建立TCP連接,如果連接成功說明TCP打洞已經(jīng)成功了。 CSocket Sock; try {  if ( !Sock.Socket () )  {   printf ( "Create socket failed : %s\n", hwFormatMessage(GetLastError()) );   return FALSE;  }  UINT nOptValue = 1;  if ( !Sock.SetSockOpt ( SO_REUSEADDR, &nOptValue , sizeof(UINT) ) )  {   printf ( "SetSockOpt socket failed : %s\n", hwFormatMessage(GetLastError()) );   return FALSE;  }  if ( !Sock.Bind ( g_nHolePort ) )  {   printf ( "Bind socket failed : %s\n", hwFormatMessage(GetLastError()) );   return FALSE;  }  for ( int ii=0; ii<100; ii++ )  {   if ( WaitForSingleObject ( g_hEvt_ConnectOK, 0 ) == WAIT_OBJECT_0 )    break;   DWORD dwArg = 1;   if ( !Sock.IOCtl ( FIONBIO, &dwArg ) )   {    printf ( "IOCtl failed : %s\n", hwFormatMessage(GetLastError()) );   }   if ( !Sock.Connect ( pSrvReqDirectConnectPkt->szInvitedIP, pSrvReqDirectConnectPkt->nInvitedPort ) )   {    printf ( "Connect to [%s:%d] failed : %s\n",      pSrvReqDirectConnectPkt->szInvitedIP,      pSrvReqDirectConnectPkt->nInvitedPort,      hwFormatMessage(GetLastError()) );     Sleep (100);   }   else break;  }  if ( WaitForSingleObject ( g_hEvt_ConnectOK, 0 ) != WAIT_OBJECT_0 )  {   if ( HANDLE_IS_VALID ( g_hEvt_ConnectOK ) ) SetEvent ( g_hEvt_ConnectOK );   printf ( "Connect to [%s:%d] successfully !!!\n",    pSrvReqDirectConnectPkt->szInvitedIP, pSrvReqDirectConnectPkt->nInvitedPort );      // 接收測試數(shù)據(jù)   printf ( "Receiving data ...\n" );   char szRecvBuffer[NET_BUFFER_SIZE] = {0};   int nRecvBytes = 0;   for ( int i=0; i<1000; i++ )   {    nRecvBytes = Sock.Receive ( szRecvBuffer, sizeof(szRecvBuffer) );    if ( nRecvBytes > 0 )    {     printf ( "-->>> Received Data : %s\n", szRecvBuffer );     memset ( szRecvBuffer, 0, sizeof(szRecvBuffer) );     SLEEP_BREAK ( 1 );    }    else    {     SLEEP_BREAK ( 300 );    }   }  } } catch ( CException e ) {  char szError[255] = {0};  e.GetErrorMessage( szError, sizeof(szError) );  printf ( "Exception occur, %s\n", szError );  return FALSE; } return TRUE;}

            在客戶端B打洞和偵聽準備好以后,服務(wù)器S回復客戶端A,客戶端A便直接與客戶端B的公網(wǎng)IP和端口進行連接,收發(fā)數(shù)據(jù)可以正常進行,為了測試是否真正地直接TCP連接,在數(shù)據(jù)收發(fā)過程中可以將服務(wù)器S強行終止,看是否數(shù)據(jù)收發(fā)還正常進行著。

            程序執(zhí)行步驟和方法:

            1. 要準備好環(huán)境,如果要真實測試的話需要用2個連到公網(wǎng)上的局域網(wǎng),1臺具有公網(wǎng)地址的電腦(為了協(xié)助我測試,小曹、小妞可費了不少心,我還霸占了他們家的電腦,在此表示感謝)。如果不是這樣的環(huán)境,程序執(zhí)行可能會不正常,因為我暫時未做相同局域網(wǎng)的處理。
            2. 在具有公網(wǎng)地址的電腦上執(zhí)行“TcpHoleSrv.exe”程序,假設(shè)這臺電腦的公網(wǎng)IP地址是“129.208.12.38”。
            3. 在局域網(wǎng)A中的一臺電腦上執(zhí)行“TcpHoleClt-A.exe 129.208.12.38”
            4. 在局域網(wǎng)B中的一臺電腦上執(zhí)行“TcpHoleClt-B.exe 129.208.12.38”

            程序執(zhí)行成功后的界面:客戶端出現(xiàn)“Send Data”或者“Received Data”表示穿越NAT的TCP連接已經(jīng)建立起來,數(shù)據(jù)收發(fā)已經(jīng)OK。



            服務(wù)器S


            客戶端A


            客戶端B

            本代碼在Windows XP、一個天威局域網(wǎng)、一個電信局域網(wǎng)、一個電話撥號網(wǎng)絡(luò)中測試通過。
            由于時間和水平的關(guān)系,代碼和文章寫得都不咋的,但愿能起到拋磚引玉的作用。代碼部分只是實現(xiàn)了不同局域網(wǎng)之間的客戶端相互連接的問題,至于相同局域網(wǎng)內(nèi)的主機或者其中一臺客戶端本身就具有公網(wǎng)IP的問題這里暫時未做考慮(因為那些處理實在太簡單了,比較一下掩碼或者公網(wǎng)IP就能判斷出來的);另外程序的防錯性代碼重用性也做得不好,只是實現(xiàn)了功能,我想



            Trackback: http://tb.blog.csdn.net/TrackBack.aspx?PostId=1750938

            国内精品久久久久久久涩爱| 久久精品国产色蜜蜜麻豆| 国产成人久久精品一区二区三区 | 欧美精品丝袜久久久中文字幕 | 亚洲精品无码久久久久| 久久w5ww成w人免费| 97超级碰碰碰碰久久久久| 久久国产欧美日韩精品免费| 伊人久久精品无码二区麻豆| 亚洲AV无码一区东京热久久| 久久99国产精品久久99果冻传媒| 久久99精品久久久久久不卡| 亚洲精品无码久久千人斩| 国内精品久久久久久久涩爱| 久久久久亚洲精品天堂| 久久亚洲电影| 久久精品国产精品亚洲精品| 久久夜色精品国产噜噜亚洲a| 国产人久久人人人人爽| 国产精品久久久久a影院| 亚洲精品高清久久| 欧美噜噜久久久XXX| 久久一本综合| 久久九九久精品国产| 天天爽天天狠久久久综合麻豆| 久久久久四虎国产精品| 国产精品禁18久久久夂久| 亚洲中文字幕无码久久精品1| 精品水蜜桃久久久久久久| 久久久婷婷五月亚洲97号色| 亚洲精品美女久久久久99小说| 91精品国产综合久久香蕉| 97r久久精品国产99国产精| 人妻少妇久久中文字幕| 亚洲∧v久久久无码精品| 久久免费视频1| 久久久不卡国产精品一区二区| 国产精品久久久久久久午夜片| 欧美精品一本久久男人的天堂| 国产精品18久久久久久vr| 99久久精品国内|