【文章內(nèi)容簡(jiǎn)介】 ind()和 connect()不需要協(xié)議作為參數(shù)。 Accept()函數(shù)的原型聲明如下： SOCKET PASCAL FAR accept(SOCKET s,struct sockaddr FAR* addr,int FAR*addrlen)。 該函數(shù)也有 3 個(gè)參數(shù)，其中參數(shù) s 為本地套接字句柄，在用做 accept()函數(shù)調(diào)用的參數(shù)前應(yīng)該先調(diào)用 listen()。 參數(shù) addr 是指向客戶方套接字地址結(jié)構(gòu)的指針，用來(lái)接收連接實(shí)體的地址。Addr 的確切格式由套接字創(chuàng)建時(shí)建立的地址簇決定。 參數(shù) addlen 為客戶方套接字地址的長(zhǎng)度（字節(jié)數(shù)）。 如果調(diào)用成功， accept()函數(shù)返回一個(gè) SOCKET 類型的值，表示接收到的套接字的句柄；否則，返回 INVALID_SOCKET。 Accept()用于面向連接的服務(wù)。參數(shù) addr 和 addrlen 存 放客戶方的地址信息。調(diào)用前，參數(shù) addr 指向一個(gè)初值為空的地址結(jié)構(gòu)，而 addrlen 的初始值為0；調(diào)用 accepet()函數(shù)后，服務(wù)器等待從編號(hào)為 s 的套接字上接受客戶連接的請(qǐng)求，而連接請(qǐng)求是由客戶方的 connect()調(diào)用發(fā)出的。當(dāng)有連接請(qǐng)求到達(dá)時(shí)，accept()調(diào)用將請(qǐng)求連接隊(duì)列上的第一個(gè)客戶方套接字地址及長(zhǎng)度放入 addr 和addrlen,并創(chuàng)建一個(gè)與 s有相同性質(zhì)的新套接字號(hào)。新的套接字可用于處理服務(wù)器并發(fā)請(qǐng)求。 Socket()， bind(),connect(),accept()這 4 個(gè)套接字系統(tǒng)調(diào)用可 以完成一個(gè)完整五元通信（協(xié)議，本地主機(jī)地址和端口號(hào)，目的地址和端口號(hào)）相關(guān)的建立。 Socket()指定五元組中的協(xié)議元，它的用法與是否為客戶機(jī)或服務(wù)器，是否面向連接無(wú)關(guān)。 Bind()指定五元中的本地二元，即本地主機(jī)地址和端口號(hào)，其用法與是否面向連接有關(guān)；在服務(wù)器方無(wú)論是否面向連接，均要調(diào)用 bind()。在客 第 9 頁(yè) 共 26頁(yè) 戶方，若采用面向連接，則可以不調(diào)用 bind()，而通過(guò) connect()自動(dòng)完成。若采用無(wú)連接，客戶方必須使用 bind ()以獲得一個(gè)唯一的地址。 監(jiān)聽連接 建立連接之后，服務(wù)端套接字要調(diào)用 listen()函數(shù)，此調(diào)用用于面向連接服務(wù)器，表明它愿意接收連接。 Listen()需在 accept()之前調(diào)用， listen ()函數(shù)的原型聲明如下： int PASCAL FAR listen(SOCKET s, int backlog)。 該函數(shù)共有兩個(gè)參數(shù)，其中參數(shù) s標(biāo)識(shí)一個(gè)本地已建立但尚未連接的套接字句柄，服務(wù)器愿意從它上面接受請(qǐng)求。 參數(shù) backlog 表示請(qǐng)求連接隊(duì)列的最大長(zhǎng)度，用于限制排隊(duì)請(qǐng)求的個(gè)數(shù)。目前允許的最大值為 5。 如果調(diào)用成功， listen()函數(shù)返回零；否則，返回 SOCKET_ERROR。 Listen()在執(zhí)行調(diào)用過(guò)程中可為沒(méi)有調(diào)用過(guò) bind()的套接字 s 完成所必需的連接，并建立長(zhǎng)度為 backlog 的請(qǐng)求連接隊(duì)列。 調(diào)用 listen()是服務(wù)器接收一個(gè)連接請(qǐng)求的 4 個(gè)步驟中的第 3 步。它在調(diào)用 socket()，分配一個(gè)流套接字且調(diào)用 bind()給 s 賦予一個(gè)名字之后調(diào)用，而且一定要在 accept()之前調(diào)用。 關(guān)閉套接字 closesocket()關(guān)閉套接字 s，并釋放分配給該套接字的資源；如果 s 涉及一個(gè)打開的 TCP 連接。則該連接被釋放。 Closesocket()函數(shù)的原型聲明如 下： BOOL PASCAL FAR closesocket(socker s)。 該函數(shù)只有一個(gè)參數(shù) s，它指待關(guān)閉的套接字句柄。 如果調(diào)用成功， closesoker()返回零；否則，返回 SOCKET_ERROR。 按鍵事件處理 數(shù)據(jù)傳輸 當(dāng)一個(gè)連接建立好以后，就可以傳輸數(shù)據(jù)了，常用的函數(shù)調(diào)用有 send()和recv()。 Send()調(diào)用用于在參數(shù) s 指定的已連接的數(shù)據(jù)報(bào)或流套接字上發(fā)送輸出數(shù)據(jù)，其原型聲明如下： Int PASCAL FAR send(SOCKET s,const char FAR *buf,int len,int flags)。 該函數(shù)也有 4 個(gè)參數(shù)，其中參數(shù) s為已連接的套接字句柄。 參數(shù) buf 指向接收輸入數(shù)據(jù)緩沖區(qū)的指針，其長(zhǎng)度由 len 指定。 參數(shù) flags 指定傳輸控制方式，如是否接收帶外數(shù)據(jù)等。 如果調(diào)用成功， recv()函數(shù)返回總共接收的字節(jié)數(shù)；如果連接被關(guān)閉，返回 第 10 頁(yè) 共 26頁(yè) 零。否則，返回 SOCKET ERROR。 為了從套接字中接受數(shù)據(jù)，可以使用 recv()函數(shù)。其函數(shù)原型聲明如下： int recv (SOCKET s, char FAR * buf , int len,int falgs): recv()函數(shù)有 4個(gè)參數(shù)，其中參數(shù) s 指套接字句柄。 參數(shù) buf 和 len 分別指將要接收數(shù)據(jù)的緩沖區(qū)及緩沖區(qū)長(zhǎng)度。 參數(shù) flags 可被設(shè)置成 MSGOOB，用來(lái)接收帶外數(shù)據(jù)，或設(shè)置成 MSGPEEK用來(lái)向緩沖區(qū)填入收到的數(shù)據(jù)，而且仍按照數(shù)據(jù)的輸入順序進(jìn)行填充。 對(duì)套接字來(lái)說(shuō)，如果數(shù)據(jù)是按輸入的隊(duì)列接收過(guò)來(lái)的， recv()函數(shù)將返回讀入數(shù)據(jù)的字節(jié)數(shù)，否則， recv()將返回 SOCKET— ERROR。 模擬按鍵 函數(shù) keybd_event()綜合一個(gè)按鍵事件，系統(tǒng)用這個(gè)事件產(chǎn) 生 WM_KEYUP 或WM_KEYDOWN 消息 .在 WindowsNT 下 ,該函數(shù)被 SendInput()所代替 .函數(shù)keybd_event()的原型如下 : VOID keybd_event(BYTE bVk,BYTE bScan,DWORD dwFlags,DWORD dwExtraInfo)。 函數(shù) keybd_event()有 4個(gè)參數(shù) ,其中參數(shù) bVk 指所按鍵的虛擬鍵值 .取值范圍在 1 至 254 之間。常見的特殊鍵值有：Tab(9),Shift(16),Ctrl(17),Alt(18),CapsLock(20),Esc(27), Win(91,92),NumLock(144)及 ScrollLock(145)等 . 參數(shù) bScan 指所按鍵的掃描碼。 參數(shù) dwFlags 指函數(shù)操作標(biāo)志位集合，應(yīng)用程序可以檢測(cè)這個(gè)值。它可以取以下值。 KEYEVENTF_EXTENDEDKEY:如果指定該值，則鍵盤掃描碼加一個(gè)前綴（ 224）。 KEYEVENTF_KEYUP：如果指定該值，則鍵釋放，否則，鍵一直被按下。 參數(shù) dwExtralnfo 指向一個(gè)附加的與鍵值有關(guān)聯(lián)的 32位值。 由于篇幅有限，這里只列出了部分重要代碼。 服 務(wù)器端套接字的創(chuàng)建，綁定，連接： char chName[256]。 sockaddr_in addr。 hostent* pEnt = NULL。 int addrlen = 0, nRet = 0。 nRet = ::gethostname(chName, 256)。 if(nRet == 0) 第 11 頁(yè) 共 26頁(yè) { m_sckServer = socket(AF_INET, SOCK_STREAM, 0)。 if(m_sckServer != INVALID_SOCKET) { pEnt = ::gethostbyname(chName)。 if(pEnt) { = AF_INET。 = htons(m_uPort)。 = INADDR_ANY。 nRet = ::bind(m_sckServer, (sockaddr*)amp。addr, sizeof(addr))。 if(nRet != SOCKET_ERROR) { nRet = ::listen(m_sckServer, SOMAXCONN)。 if(nRet != SOCKET_ERROR) { addrlen = sizeof(addr)。 TRACE(_T(開始了服務(wù)，等待客戶 ......\n))。 m_sckClient[0] = ::accept(m_sckServer, (sockaddr*)amp。addr, amp。addrlen)。 if(m_sckClient[0] != INVALID_SOCKET) { //為了同步 ::PL_SendSocketData(m_sckClient[0], NULL, 0, PL_TEMP, MSG_OOB)。 } m_sckClient[1] = ::accept(m_sckServer, (sockaddr*)amp。addr, amp。addrlen)。 if(m_sckClient[0] != INVALID_SOCKET amp。amp。 m_sckClient[1] != INVALID_SOCKET) TRACE(_T(客戶連接上了 .......\n))。 服務(wù)器端關(guān)閉套接字： BOOL CSocketThread::ExitServer() { 第 12 頁(yè) 共 26頁(yè) TRACE(_T(退 出服務(wù)，重新等待連接 ......\n))。 if(g_pSendDIBThread != NULL) { ::TerminateThread(g_pSendDIBThreadm_hThread, 0)。 ::WaitForSingleObject(g_pSendDIBThreadm_hThread, INFINITE)。 g_pSendDIBThread = NULL。 } if(g_pWaitCommandThread != NULL) { ::TerminateThread(g_pWaitCommandThreadm_hThread, 0)。 ::WaitForSingleObject(g_pWaitCommandThreadm_hThread, INFINITE)。 g_pWaitCommandThread = NULL。 } if(m_sckClient[0] != INVALID_SOCKET) { ::closesocket(m_sckClient[0])。 } if(m_sckClient[1] != INVALID_SOCKET) { ::closesocket(m_sckClient[1])。 } if(m_sckServer != INVALID_SOCKET) { ::closesocket(m_sckServer)。 } m_sckClient[0] = INVALID_SOCKET。 m_sckClient[1] = INVALID_SOCKET。 m_sckServer = INVALID_SOCKET。 return TRUE。 } 服務(wù)器端接收客戶端發(fā)送的指令： 第 13 頁(yè) 共 26頁(yè) int WINAPI PL_ReadSocketData(SOCKET s, BYTE *chData, int nLen, BYTE *chFlag, UINT uFlag) { int nRet = INVALID_SOCKET。 if(s != INVALID_SOCKET) { nRet = ::recv(s, (char *)chData, nLen, uFlag)。 if(nRet 0) { if(chFlag != NULL) { *chFlag = chData[0]。 } } } return nRet。 } 服務(wù)器端處理指令： int CSocketThread::Run() { g_pSendInfoThread=AfxBeginThread(SendInfoThread,NULL,THREAD_PRIORITY_IDLE)。 while(1) { if(CreateServer()) { BYTE *chData = new BYTE[PL_SOCKET_MAXBYTES+1]。 while(1) { ZeroMemory(chData, PL_SOCKET_MAXBYTES+1)。 Int nRet=::PL_ReadSocketData(m_sckClient[0], chData, PL_SOCKET_MAXBYTES, NULL)。 if(nRet != SOCKET_ERROR) 第 14 頁(yè) 共 26頁(yè) { // 處理命令 nRet = DoReceive(chData, nRet)。 } else { TRACE(_T(接收數(shù)據(jù)錯(cuò)誤，客戶已經(jīng)斷開了 ......\n))。