VC++下实现Socket编程方法.doc

VC+下实现Socket编程方法利用Socket编程是一类典型的网络通信程序，特别是在实时性要求比较高的项目中，Winsock编程方法是非常实用的。下面介绍在VC 6.0环境下开发Winsock程序的方法。这里并没有直接应用MFC 提供的CSocket类，这是因为考虑到对于类而言，其成员函数调用必然是完全阻塞方式的，因此只能用于人工线程中。基于这种思想，可以在CObject类基础上派生一个套接字类，其使用方式为阻塞方式，虽然增加了使用的条件，但可以保证其正常工作，而不会出现不加控制地使用CSocket对象带来的冲突现象。下面首先将具体介绍有关的套接字类的定义，新创建的套接字功能主要通过调用CSocket的相关操作实现。1 套接字类CBlockingSocket首先需要定义此套接字类，在类中设置了一个属性变量：SOCKET m_hSocket; m_hSocket 表示套接字的句柄。另外还构造了一组方法，其功能与CSocket类是对应的，下面以创建、监听、连接建立和消息的接收和发送为例，介绍其实现方法，。l 创建创建套接字即要求创建相应的连接，缺省类型为面向连接的流，具体实现为： void CBlockingSocket:Create(int nType)ASSERT(m_hSocket = NULL);if(m_hSocket = socket(AF_INET, nType, 0) = INVALID_SOCKET) throw new CBlockingSocketException(创建套接字);l 监听Listen函数完成监听连接的任务，在实现时要求最多有10个连接请求排队，这在一般的应用中是完全足够的。void CBlockingSocket:Listen()ASSERT(m_hSocket != NULL);if(listen(m_hSocket, 10) = SOCKET_ERROR) throw new CBlockingSocketException(Listen);l 建立连接连接的实际建立可以由Connect实现，同样地，缺省的建立方式为面向连接的流。void CBlockingSocket:Create(int nType )ASSERT(m_hSocket = NULL);if(m_hSocket = socket(AF_INET, nType, 0) = INVALID_SOCKET) throw new CBlockingSocketException(创建套接字);l 发送消息Send函数的作用是将数据块按一个消息发送，参数pch即为发送的消息，nSize为消息长度，nSecs可以限制操作时间。如果客户方取消读操作，则返回值将小于指定消息长度。int CBlockingSocket:Send(const char* pch, const int nSize, const int nSecs)ASSERT(m_hSocket != NULL);FD_SET fd = 1, m_hSocket;TIMEVAL tv = nSecs, 0;if(select(0, NULL, &fd, NULL, &tv) = 0) throw new CBlockingSocketException(发送超时);if(int nBytesSent = send(m_hSocket, pch, nSize, 0) = SOCKET_ERROR) throw new CBlockingSocketException(发送);return nBytesSent;此外，如果数据块比较大，可以将数据块分成多个消息发送，此工作由函数Write完成。具体实现时将通过循环调用Send函数来实现部分消息发送，通过对局部量nBytesThisTime 和nBytesSent的维护，保证整个数据块的正常发送。int CBlockingSocket:Write(const char* pch, const int nSize, const int nSecs)int nBytesSent = 0，nBytesThisTime;const char* pch1 = pch;do nBytesThisTime = Send(pch1, nSize - nBytesSent, nSecs);nBytesSent += nBytesThisTime;pch1 += nBytesThisTime; while(nBytesSent Delete();下面，再来看线程函数ServerThreadProc是如何处理客户请求的：UINT ServerThreadProc(LPVOID pParam)CSockAddr saClient;CBlockingSocket sConnect;try if(!g_sListen.Accept(sConnect, saClient) g_bListening = FALSE;return 0;g_nConnection+;AfxBeginThread(ServerThreadProc, pParam, THREAD_PRIORITY_NORMAL);DoRequest(pParam, sConnect, saClient);sConnect.Close();/ 析构函数不能关闭它catch(CBlockingSocketException* pe) LogBlockingSocketException(pParam, 服务器:, pe);pe-Delete();return 0; 如果g_sListen调用Accept失败，说明视或应用程序关闭了连接的套接字，此时将调整当前状态，在具体处理客户请求之前，为了不影响继续接收其它客户的请求，可以再创建新的线程，即构造多线程，每个线程处理自已的具体事务。具体处理工作由DoRequest函数完成，由于析构函数不能关闭临时建立的套接字，所以在处理完之后，需要主动关闭。DoRequest的工作包括在服务器应用视中显示相应的提示语句，这是通过向其发送消息完成的，另外还将显示客户发送的信息，信息由套接字的Receive（）函数获得，同样通过向窗口发送消息完成，这里的消息发送窗口由参数pParam确定。最后，调用套接字的.Send()函数向客户端发送一条简短的确认信息。void DoRequest(LPVOID pParam, CBlockingSocket& sockCon, LPCSOCKADDR psa)char inbuff500，text1200;wsprintf(text1, 建立连接rn);:SendMessage(HWND) pParam, EM_SETSEL, (WPARAM) 500, 65535);:SendMessage(HWND) pParam, EM_REPLACESEL, (WPARAM) 0, (LPARAM) text1); tryint len=sockCon.Receive(inbuff,500,20);inbufflen=0;:SendMessage(HWND) pParam, EM_SETSEL, (WPARAM) 500, 65535); :SendMessage(HWND)pParam,EM_REPLACESEL,(WPARAM)0,(LPARAM)inbuff);sockCon.Send(ok!rnBye!,9,5);catch(CBlockingSocketException* pe) LogBlockingSocketException(pParam, 服务器:, pe);pe-Delete();5 客户端应用程序在客户端应用程序中同样使用了前面介绍的套接字类CBlockingSocket，Winsock地址类CSockAddr和套接字异常类CBlockingSocketException。这里将主要介绍客户如何建立与服务器的连接，如何向服务器发送消息，以及如何接收和处理服务器返回的消息。为了实现与服务器的连接，需要在菜单上增加一个连接项，资源标识为ID_BEGIN_LINK，消息映射设置为ON_COMMAND(ID_BEGIN_LINK, OnBeginLink)，下面再来分析消息处理函数OnBeginLink的实现：void CTestclientsockView:OnBeginLink() CBlockingSocket sClient;char inbuff200;try CSockAddr saClient(146.127.35.70,5858);sClient.Create();sClient.Connect(saClient);sClient.Send(hello ,你好！n,5,5);int len=sClient.Receive(inbuff,200,20);inbufflen=0;SendMessage(EM_SETSEL, (WPARAM) 500, 65535);SendMessage(EM_REPLACESEL, (WPARAM) 0, (LPARAM) inbuff);sClient.Close();catch(CBlockingSocketException* e) sClient.Cleanup();LogBlockingSocketException(GetSafeHwnd(), VIEW:, e);e-Delete();首先需要建立与服务器的连接，这里创建了一个地址对象saClient，在创建时提供了两个参数，其中“146.127.35.70”为服务器的IP地址，另外将端口号设置为5858，即与服务器应用程序保持一致。接下来创建一个客户端的套接字对象，并通过调用函数Connect建立与服务器的连接。连接建立后，可以向服务器发送信息了，这里用套接字的函数Send()发送了一条简短的欢迎信息，同时调用Receive（）函数接收服务器返回的信息。最后向视发送显示消息，将服务器所返回的确认信息显示在主窗口中。这里还需要说明的是，如果在连接或通信过程中出现异常，无论是客户应用程序还是服务器应用程序都将做出相应的响应。具体的处理工作由函数LogBlockingSocketException实现，这里的参数pParam 为拥有目的窗口的 HWND ，这是由另一个线程提供的。void LogBlockingSocketException(LPVOID pParam, char* pch, CBlockingSocketException* pe)CString strGmt = CTime:GetCurrentTime().FormatGmt(%m/%d/%y %H:%M:%S GMT);char text1200, text250;pe-GetErrorMessage(text2, 49);wsprintf(text1, WINSOCK 错误-%s %s - %srn, pch, text2, (const char*) strGmt);:SendMessage(HWND) pParam, EM_SETSEL, (WPARAM) 65534, 65535);:SendMessage(HWND) pParam, EM_REPLACESEL, (WPARAM) 0, (LPARAM) text1);通过调用套