C++socket编程详解.doc

第1章 Visual C+网络编程概述Visual C+（后面简写为VC）网络编程是指用户使用MFC类库（微软基础类库）在VC编译器中编写程序，以实现网络应用。用户通过VC编程实现的网络软件可以在网络中不同的计算机之间互传文件、图像等信息。本章将向用户介绍基于Windows操作系统的网络编程基础知识，其开发环境是VC。在VC编译器中，使用Windows Socket进行网络程序开发是网络编程中非常重要的一部分。1.1 网络基础知识 如果用户要进行VC网络编程，则必须首先了解计算机网络通信的基本框架和工作原理。在两台或多台计算机之间进行网络通信时，其通信的双方还必须遵循相同的通信原则和数据格式。本节将向用户介绍OSI七层网络模型、TCP/IP协议以及C/S编程模型。1.1.1 OSI七层网络模型OSI网络模型是一个开放式系统互联的参考模型。通过这个参考模型，用户可以非常直观地了解网络通信的基本过程和原理。OSI参考模型如图1.1所示。图1.1 OSI七层网络模型用户从OSI网络模型可以很直观地看到，网络数据从发送方到达接收方的过程中，数据的流向以及经过的通信层和相应的通信协议。事实上在网络通信的发送端，其通信数据每到一个通信层，都会被该层协议在数据中添加一个包头数据。而在接收方恰好相反，数据通过每一层时都会被该层协议剥去相应的包头数据。用户也可以这样理解，即网络模型中的各层都是对等通信。在OSI七层网络模型中，各个网络层都具有各自的功能，如表1.1所示。表1.1 各网络层的功能协 议 层 名功 能 概 述物理硬件层表示计算机网络中的物理设备。常见的有计算机网卡等数据链路层将传输数据进行压缩与加压缩网络层将传输数据进行网络传输数据传输层进行信息的网络传输会话层建立物理网络的连接表示层将传输数据以某种格式进行表示应用层应用程序接口%注意：在表1.1中列出了OSI七层网络模型中各层的基本功能概述。用户根据这些基本的功能概述会对该网络模型有一个比较全面的认识。1.1.2 TCP/IP协议TCP/IP协议实际上是一个协议簇，其包括了很多协议。例如，FTP（文本传输协议）、SMTP（邮件传输协议）等应用层协议。TCP/IP协议的网络模型只有4层，包括数据链路层、网络层、数据传输层和应用层，如图1.2所示。图1.2 TCP/IP网络协议模型在TCP/IP网络编程模型中，各层的功能如表1.2所示。表1.2 TCP/IP网络协议各层功能协 议 层 名功 能 概 述数据链路层网卡等网络硬件设备以及驱动程序网络层IP协议等互联协议数据传输层为应用程序提供通信方法，通常为TCP、UDP协议应用层负责处理应用程序的实际用于层协议在数据传输层中，包括了TCP和UDP协议。其中，TCP协议是基于面向连接的可靠的通信协议。其具有重发机制，即当数据被破坏或者丢失时，发送方将重发该数据。而UDP协议是基于用户数据报协议，属于不可靠连接通信的协议。例如，当用户使用UDP协议发送一条消息时，并不知道该消息是否已经到达接收方，或者在传输过程中数据已经丢失。但是在即时通信中，UDP协议在对一些对时间要求较高的网络数据传输方面有着重要的 作用。1.1.3 C/S编程模型C/S编程模型是基于可靠连接的通信模型。在通信的双方必须使用各自的IP地址以及端口进行通信。否则，通信过程将无法实现。通常情况下，当用户使用C/S模型进行通信时，其通信的任意一方称为客户端，则另一方称为服务器端。服务器端等待客户端连接请求的到来，这个过程称为监听过程。通常，服务器监听功能是在特定的IP地址和端口上进行。然后，客户端向服务器发出连接请求，服务器响应该请求则连接成功。否则，客户端的连接请求失败。C/S编程模型如图1.3所示。图1.3 C/S编程模型由于客户端连接服务器时，需要使用服务器的IP地址和监听端口号才能完成连接。所以，服务器的IP地址和端口必须是固定的。在这里，向用户介绍部分协议所使用的端口号码。例如，HTTP协议（网页浏览服务）所使用的端口号为80，FTP协议（文本传输）所使用的端口号是21。%注意：用户在实际编程中，通信双方的连接以及数据通信均是基于Socket（套接字）进行的。1.2 网络编程基础网络应用程序可以使用MFC中封装的套接字类进行编程，也可以使用Windows API函数进行程序开发。相比较而言，MFC网络编程较简单一点，用户使用也非常方便。但是，使用MFC相关类编程会使用户对网络通信中的基本原理没有清晰的认识。而使用Windows API函数则恰好相反，可以使用户熟悉网络通信的基本原理。1.2.1 Sockets套接字用户在Windows中编写网络通信程序时，需要使用Windows Sockets（Windows套接字）。与Windows套接字相关的API函数称为Winsock函数。在网络通信的双方，均有各自的套接字，并且该套接字与特定的IP地址和端口号相关联。通常，套接字主要有两种类型，分别是流式套接字（SOCK_STREAM）和数据报套接字（SOCK_DGRAM）。其中，流式套接字是专门用于使用TCP协议通信的应用程序中，而数据报套接字则是专门用于使用UDP协议进行通信的应用程序中。1.2.2 网络字节顺序网络字节顺序是指TCP/IP协议中规定的数据传输使用格式，与之相对的字节顺序是主机字节顺序。网络字节顺序表示首先将数据中最重要的字节进行存储。例如，当数据0x358457使用网络字节顺序进行存储时，该值在内存中的存放顺序将是0x35、0x84、0x57。因为通信数据可能会在不同的机器之间进行传输，所以通信数据必须以相同的格式进行整理。只有经过格式处理的通信数据，才能在不同的机器之间进行传输。在Winsock中，已经提供了相关的函数处理网络字节顺序的相关问题，这些知识将在第2章中具体讲解。1.3 Windows Sockets介绍在MFC类库中，几乎封装了Windows Sockets的全部功能。在本节中，将向用户介绍两个主要的套接字相关类，分别是CAsyncSocket类和CSocket类。1.3.1 CAsyncSocket类在微软基础类库中，CAsyncSocket类封装了异步套接字的基本功能。用户使用该类进行网络数据传输的步骤如下：（1）调用构造函数创建套接字对象。（2）如果创建服务器端套接字，则调用函数Bind()绑定本地IP和端口，然后调用函数Listen()监听客户端的请求。如果请求到来，则调用函数Accept()响应该请求。如果创建客户端套接字，则直接调用函数Connect()连接服务器即可。（3）调用Send()等功能函数进行数据传输与处理。（4）关闭或销毁套接字对象。%注意：在MFC中，所有类中均有一个变量m_hWnd表示该类的实例句柄。1.3.2 CSocket类CSocket类派生于CAsyncSocket类。该类不但具有CAsyncSocket类的基本功能，还具有串行化功能。用户在实际编程中，通过将CSocket类与CSocketFile类和CArchive类一起使用，能够很好地管理数据以及发送数据。用户使用该类进行网络编程的步骤如下： （1）创建CSocket类对象。（2）如果创建服务器端套接字，则调用函数Bind()绑定本地IP和端口，然后调用函数Listen()监听客户端的请求。如果请求到来，则调用函数Accept()响应该请求。如果创建客户端套接字，则直接调用函数Connect()连接服务器即可。（3）创建与CSocket类对象相关联的CSocketFile类对象。（4）创建与CSocketFile类相关联的CArchive对象。（5）使用CArchive类对象在客户端和服务器之间进行数据传输。（6）关闭或销毁CSocket类、CSocketFile类和CArchive类的3个对象。1.4 小 结本章向用户介绍了网络编程有关的网络模型、工作原理、网络协议以及在MFC中使用相关的类进行网络程序编写步骤。用户通过本章的学习，将对网络编程的基础知识有一个大致的了解，同时也为后面的实际编程操作打下基础。如果用户在后面的编程实例中，遇到一些网络编程的基础知识疑问，可以再对本章进行复习、巩固，以便更好地理解网络编程知识。第2章 网络应用2.1 网络编程基础多媒体技术与网络技术的结合，使得网络生活变得多姿多彩。从此，网络生活很迷人；网络改变了和改变着人们原本的生活方式。姑且认为DirectShow是单机的多媒体技术，一旦融合了网络技术，DirectShow更显现了它强大的生命力。本章将着重介绍DirectShow技术在网络方面的应用。网络编程，当然要用到Windows Socket（套接字）技术。Socket相关的操作由一系列API函数来完成，比如socket、bind、listen、connect、accept、send、sendto、recv、recvfrom等。调用这些API函数有一定的先后次序，有些函数的参数还比较复杂，对于开发者来说，不是很好用。于是，微软的MFC提供了两个类：CAsyncSocket和CSocket，极大地方便了Socket功能的使用。这两个类的继承关系如图3.1。图3.1 MFC Socket类的继承关系CAsyncSocket类在较低层次上封装了Windows Socket API，并且通过内建一个（隐藏的）窗口，实现了适合Windows应用的异步机制（Windows Socket API默认情况下工作在阻塞模式，不方便直接在消息驱动的Windows程序上使用）。CSocket类从CAsyncSocket类派生，进一步简化了Socket功能的应用。不过很遗憾，正因为这两个类都内建了一个窗口，它们并不是线程安全的（thread-safe）；如果要在多线程环境下应用Socket功能，建议自行封装Socket API函数。使用Socket传输数据主要有两种方式：TCP传输和UDP传输。（OSI参考模型将网络通信分成7个层次，从低往上依次为物理层、数据链路层、网络层、传输层、会话层、表示层、应用层；TCP和UDP均是传输层的协议。）下面，就分别来介绍这两种数据传输方式。提示：本章在介绍网络通信双方的时候，会使用两组关键词：服务器-客户机和本地端-远程端。其中，服务器-客户机是根据角色来界定的；而本地端-远程端是一个相对概念，依据不同的参照物，可以分别表示不同的角色。比如以服务器为参照物，可以称服务器为本地端，称客户机为远程端；而如果以客户机为参照物，可以称客户机为本地端，称服务器为远程端。2.1.1 TCP传输TCP，Transfer Control Protocol的缩写（传输控制协议），是一种面向连接的网络传输协议。TCP协议的特点是，支持多数据流操作，提供流控和错误控制，甚至能完成对乱序到达报文的重新排序等。因此，TCP提供了可靠的应用数据传输服务。通信双方使用TCP传输的一般过程参考如图3.2。图3.2 TCP通信的一般过程本节将要实现一个TCP传输的演示程序TCPDemo，它包括服务器和客户机两个部分。它们的程序界面如图3.3。图3.3 TCP传输演示程序界面TCPDemo的演示过程如下：（1）将服务器和客户机两部分程序都运行起来（此时服务器已经启动了侦听客户机连接请求的子线程，侦听端口号为10028）。（2）在客户机程序界面上输入服务器的IP地址（如果服务器和客户机运行在同一台机器上，IP地址可以指定为）、侦听端口号（因为服务器在10028端口上侦听，这里也应该指定为10028）。（3）点击客户机程序界面上的“Connect”按钮，向服务器发送Socket连接请求。（4）服务器侦听到有客户机的连接请求后便接受它（于是在两个程序之间就建立了一条可靠的Socket连接）。然后服务器会向客户机发送两次字符串数据。（5）客户机接收到数据后，弹出两次如图3.4的消息框。图3.4 TCP传输客户机接收到数据后显示的消息框提示：TCPDemo为什么使用10028作为TCP通信的端口号？因为TCP数据包的TCP头结构中，使用了16位的域来表示一个端口号。因此，有65536个可能的端口号。不过，0-1023是周知口（众所周知的端口，比如80是超文本传输协议http的端口，25是简单邮件传输协议smtp的端口，20和21是文件传输协议ftp的端口等），比1023大的端口号通常被称为高端口号。应用程序一般使用高端口号提供自己的通信服务。TCPDemo使用10028端口是偶然的，只要比1023大就可以了。TCPDemo在具体实现时，设计了一个CTCPListener类专门用于服务器对特定TCP端口的侦听。另外，设计了一个CStreamSocket类专门用于TCP数据的传输。CStreamSocket作为基类，服务器程序从它派生出另一个类CSocketSender专门用于数据的发送，客户机程序从它派生出CSocketReceiver类专门用于数据的接收。这些类的继承结构如图3.5。图3.5 TCPDemo的类继承结构提示：关于CMsgStation和CMsgReceiver两个类的功能介绍，请读者另行参考本书的“2.4.1 一种不错的设计模式”。/ CTCPListener.h/#ifndef _H_CTCPListener_#define _H_CTCPListener_#include CMsgStation.hclass CTCPListener : public CMsgStationprotected:SOCKETmListener; / 用于侦听的SocketSOCKETmAccepted; / 用于与远程端建立连接的SocketWORDmListenPort; / 侦听端口号BOOLmIsListening; / 是否正在侦听的标记HANDLEmLsnThread; / 侦听线程public:CTCPListener();virtual CTCPListener();public:/ 设置/得到侦听的端口号void SetListenPort(WORD inPort); WORD GetListenPort(void);/ 创建/销毁用于侦听的SocketBOOL Create(void);void DeleteListener(void);/ 销毁服务器与客户机建立连接的Socketvoid DeleteAccepted(void);/ 启动/停止侦听线程BOOL StartListening(void);void StopListening(void);/ 得到服务器与客户机建立连接的Socket（用于数据传输）SOCKET GetAccepted(void);private:BOOL Accept(void); / 接受远程端的连接请求static DWORD WINAPI ListeningThrd(void *pParam); / 侦听线程执行体;#endif / _H_CTCPListener_/ / CTCPListener.cpp/#include stdafx.h#include CTCPListener.h#include Netdefs.h#ifdef _DEBUG#define new DEBUG_NEW#undef THIS_FILEstatic char THIS_FILE = _FILE_;#endif/CTCPListener:CTCPListener()/ 参数初始化mListener = INVALID_SOCKET;mAccepted = INVALID_SOCKET;/ 默认在10028端口上侦听mListenPort = 10028;mLsnThread = NULL;mIsListening = FALSE;CTCPListener:CTCPListener()/ 销毁SocketDeleteAccepted();DeleteListener();/ 停止侦听线程StopListening();/ 设置侦听端口号void CTCPListener:SetListenPort(WORD inPort)mListenPort = inPort;/ 得到侦听端口号WORD CTCPListener:GetListenPort(void)return mListenPort;/ 创建用于侦听的SocketBOOL CTCPListener:Create(void)DeleteListener(); / 销毁侦听Socketint val = 0;BOOL pass = FALSE;/ 创建一个TCP传输的SocketmListener = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);if (mListener != INVALID_SOCKET)/ 在Socket上进行参数设置BOOL sopt = TRUE;setsockopt(mListener, IPPROTO_TCP, TCP_NODELAY, (char *)&sopt, sizeof(BOOL);/ 在销毁Socket时不必等待未发送完的数据完全发送出去setsockopt(mListener, SOL_SOCKET, SO_DONTLINGER, (char *)&sopt, sizeof(BOOL);/ 绑定Socket到指定的侦听端口SOCKADDR_IN addr;memset(&addr, 0, sizeof(SOCKADDR_IN);addr.sin_family = AF_INET;addr.sin_addr.s_addr = htonl(INADDR_ANY);addr.sin_port = htons(mListenPort);val = bind(mListener, (struct sockaddr*) &addr, sizeof(addr);pass = (val != SOCKET_ERROR);if (pass)/ 将Socket置于侦听状态val = listen(mListener, SOMAXCONN);pass = (val != SOCKET_ERROR);if (!pass)DeleteListener();return pass;/ 销毁用于侦听的Socketvoid CTCPListener:DeleteListener(void)if (mListener != INVALID_SOCKET)closesocket(mListener);mListener = INVALID_SOCKET;/ 销毁服务器与客户机建立连接的Socketvoid CTCPListener:DeleteAccepted(void)if (mAccepted != INVALID_SOCKET)closesocket(mAccepted);mAccepted = INVALID_SOCKET;/ 启动侦听线程（因为用于接受连接请求的accept函数调用时会阻塞）BOOL CTCPListener:StartListening(void)/ 如果侦听Socket没有创建，则创建它if (mListener = INVALID_SOCKET)Create();if (mListener != INVALID_SOCKET)if (mIsListening)return TRUE;/ 启动侦听线程DWORD threadID = 0;mLsnThread = CreateThread(NULL, 0, ListeningThrd, this, 0, &threadID);return (mLsnThread != NULL);return FALSE;/ 停止侦听线程void CTCPListener:StopListening(void)if (mListener != INVALID_SOCKET & mIsListening)/ 销毁侦听Socket，于是accept将脱离阻塞状态DeleteListener();/ 等待侦听线程完全退出 if (mLsnThread != NULL) WaitForSingleObject(mLsnThread, INFINITE);mLsnThread = NULL;/ 接受远程端的连接请求（创建一个新的Socket用于与远程端建立一条连接）BOOL CTCPListener:Accept(void)if (mListener != INVALID_SOCKET)SOCKADDR_IN saddr;int len = sizeof(SOCKADDR_IN);/ 侦听远程端的连接请求（如果没有连接请求，这个函数将阻塞）SOCKET accepted = accept(mListener, (SOCKADDR *)&saddr, &len);if (accepted = INVALID_SOCKET)return FALSE;/ 注意：目前仅支持建立一条Socket连接！/ 在建立新的连接之前将以前的连接断开DeleteAccepted();/ 保存与远程端建立连接的SocketmAccepted = accepted;/ 在Socket上设置一些参数BOOL sopt = TRUE;setsockopt(mAccepted, IPPROTO_TCP, TCP_NODELAY, (char *)&sopt, sizeof(BOOL);setsockopt(mAccepted, SOL_SOCKET, SO_DONTLINGER, (char *)&sopt, sizeof(BOOL);return TRUE;return FALSE;/ 当与远程端连接的Socket取出之后，保存该Socket的变量置为无效/ 取出的Socket由取出者负责销毁SOCKET CTCPListener:GetAccepted(void)SOCKET ret = mAccepted;mAccepted = INVALID_SOCKET;return ret;/ 侦听线程的函数执行体DWORD WINAPI CTCPListener:ListeningThrd(void *pParam)ASSERT(pParam);/ 获得侦听对象指针CTCPListener * pListen = (CTCPListener *) pParam;pListen-mIsListening = TRUE;while (pListen-mIsListening)/ 开始侦听（如果没有远程端发送连接请求，这个函数将阻塞）if (!pListen-Accept()pListen-mIsListening = FALSE;break;else/ const long cNewSocketAccepted = 6688;/ 发送给上层观察者一个自定义消息cNewSocketAccepted，/ 表示一条Socket连接已经建立（可以用它进行数据传输了！）pListen-Broadcast(cNewSocketAccepted);return 1;/ CStreamSocket.h/#ifndef _H_CStreamSocket_#define _H_CStreamSocket_class CStreamSocketprotected:SOCKETmSocket; / 用于数据发送或接收的SocketBOOLmIsConnected; / Socket是否已经建立了连接的标记BOOLmIsReceiving; / 使用独立的线程进行数据接收HANDLEmRcvThread;BOOLmIsSending; / 使用独立的线程进行数据发送HANDLEmSndThread;public:CStreamSocket();virtual CStreamSocket();public:BOOL Attach(SOCKET inSocket); / 关联一个Socketvoid Detach(void); / 销毁Socket/ 向指定IP地址、端口号的机器发送连接请求BOOL ConnectTo(const char * inTarget, WORD inPort);BOOL IsConnected(void) return mIsConnected; ;/ 用于数据接收的控制函数BOOL StartReceiving(void);void StopReceiving(void);BOOL IsReceiving(void) return mIsReceiving; ;/ 用于数据发送的控制函数BOOL StartSending(void);void StopSending(void);BOOL IsSending(void) return mIsSending; ;protected:static DWORD WINAPI ReceivingThrd(void * pParam); / 接收线程执行体static DWORD WINAPI SendingThrd(void * pParam); / 发送线程执行体/ 接收/发送数据循环过程（虚函数，供子类定制）virtual void ReceivingLoop(void); virtual void SendingLoop(void);#endif / _H_CStreamSocket_/ / CStreamSocket.cpp/ #include stdafx.h#include CStreamSocket.h#include UNetwork.h#ifdef _DEBUG#define new DEBUG_NEW#undef THIS_FILEstatic char THIS_FILE = _FILE_;#endif/CStreamSocket:CStreamSocket()/ 参数初始化mSocket = INVALID_SOCKET;mIsConnected = FALSE;mIsReceiving = FALSE;mIsSending = FALSE;mRcvThread = NULL;mSndThread = NULL;/ 销毁Socket，停止发送/接收线程CStreamSocket:CStreamSocket()Detach();StopSending();StopReceiving();/ 关联一个Socket到本包装对象BOOL CStreamSocket:Attach(SOCKET inSocket)/ 如果已经包装了一个Socket，则返回一个错误值if (mSocket != INVALID_SOCKET)return FALSE;/ 保存Socket句柄mSocket = inSocket;mIsConnected = TRUE;return TRUE;/ 销毁Socketvoid CStreamSocket:Detach(void)if (mSocket != INVALID_SOCKET)closesocket(mSocket);mSocket = INVALID_SOCKET;mIsConnected = FALSE;/ 向指定IP地址、端口号的机器发送连接请求BOOL CStreamSocket:ConnectTo(const char * inTarget, WORD inPort)if (mIsConnected)return TRUE;/ 首先创建一个TCP传输的SocketmSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);if (mSocket != INVALID_SOCKET)/ 在成功创建的Socket上调整参数BOOL sopt = TRUE;setsockopt(mSocket, IPPROTO_TCP, TCP_NODELAY, (char *)&sopt, sizeof(BOOL);setsockopt(mSocket, SOL_SOCKET, SO_DONTLINGER, (char *)&sopt, sizeof(BOOL);/ 向服务器发送连接请求SOCKADDR_IN saddr;memset(&saddr, 0, sizeof(SOCKADDR_IN);saddr.sin_addr.S_un.S_addr = inet_addr(inTarget);saddr.sin_family = AF_INET;saddr.sin_port = htons(WORD)inPort);if (connect(mSocket, (SOCKADDR *)&saddr, sizeof(SOCKADDR_IN) != 0) / 跟踪Socket错误#ifdef _DEBUGUNetwork:DumpSocketError();#endif/ 如果连接失败，则销毁刚才创建的SocketDetach();return FALSE;mIsConnected = TRUE;return TRUE;return FALSE;/ 启动数据接收线程（因为Socket数据接收函数调用时会阻塞）BOOL CStreamSocket:StartReceiving(void)if (mSocket != INVALID_SOCKET)if (mIsReceiving)return TRUE;DWORD threadID = 0;mRcvThread = CreateThread(NULL, 0, ReceivingThrd, this, 0, &threadID);return (mRcvThread != NULL);return FALSE;/ 停止数据接收线程void CStreamSocket:StopReceiving(void)if (mIsReceiving)/ 销毁Socket，使接收函数失败或脱离阻塞Detach();/ 等待数据接收线程的完全退出if (mRcvThread != NULL) WaitForSingleObject(mRcvThread, INFINITE);mRcvThread = NULL;/ 启动数据发送线程（以提高数据发送的效率）BOOL CStreamSocket:StartSending(void)if (mSocket != INVALID_SOCKET)if (mIsSending)return TRUE;DWORD threadID = 0;mSndThread = CreateThread(NULL, 0, SendingThrd, this, 0, &threadID);return (mSndThread != NULL);return FALSE;/ 停止数据发送线程void CStreamSocket:StopSending(void)if (mIsSending)/ 销毁Socket，使发送函数失败或脱离阻塞Detach();if (mSndThread != NULL) / 等待数据发送线程的完全退出WaitForSingleObject(mSndThread, INFINITE);mSndThread = NULL;/ 数据接收线程的函数执行体DWORD WINAPI CStreamSocket:ReceivingThrd(void * pParam)CStreamSocket * pSock = (CStreamSocket *) pParam;if (pSock)pSock-mIsReceiving = TRUE;/ 执行接收循环pSock-ReceivingLoop();return 1;return 0;/ 数据发送线程的函数执行体DWORD WINAPI CStreamSocket:SendingThrd(void * pParam)CStreamSocket * pSock = (CStreamSocket *) pParam;if (pSock)pSock-mIsSending = TRUE;/ 执行发送循环pSock-SendingLoop();return 1;return 0;/ 虚函数，供子类定制实际的数据接收（循环）过程void CStreamSocket:ReceivingLoop(void)/ 虚函数，供子类定制实际的数据发送（循环）过程void CStreamSocket:SendingLoop(void)/ CSocketSender.h/#ifndef _H_CSocketSender_#define _H_CSocketSender_#include CStreamSocket.hclass CSocketSender : public CStreamSocketpublic:CSocketSender();virtual CSocketSender();protected:virtual void SendingLoop(void); / 定制数据发送过程;#endif / _H_CSocketSender_/ CSocketSender.cpp/ 服务器程序定制的数据发送过程void CSocketSender:SendingLoop(void)char buf1024; / 发送数据使用的缓存int bytes = 0;/ 定义一个字符串作为发送的数据内容char str = HQ Tech, Make Technology Easy!;/ 发送数据的总长度 = 字符串长度 + 头信息长度int len = strlen(str) + sizeof(Net_Header); / 在数据内容之前加上一个自定义头信息（用以说明数据内容的长度）Net_Header * pHeader = (Net_Header *) buf;pHeader-pack_size = strlen(str);pHeader-my_hton(); / 字节顺序转换！/ 将欲发送的数据内容和头信息整合strcpy(buf+sizeof(Net_Header), str);/ 作为演示，将上述定义的字符串数据发送两次int counter = 2;while (mIsSending)/ 使用Socket进行一次数据发送bytes = send(mSocket, buf, len, 0);if (bytes = SOCKET_ERROR)Detach();mIsSending = FALSE;break;/ 当完成两次发送后断开Socket连接，结束发送线程if (-counter = 0)Detach();mIsSending = FALSE;break;/ CSocketReceiver.h/#ifndef _H_CSocketReceiver_#define _H_CSocketReceiver_#include CStreamSocket.hclass CSocketReceiver : public CStreamSocketpublic:CSocketReceiver();virtual CSocketReceiver();protected:virtual void ReceivingLoop(void); / 定制数据接收过程;#endif / _H_CSocketReceiver_/ CSocketReceiver.cpp/ 客户机程序定制的数据接收过程void CSocketReceiver:ReceivingLoop(void)/ 接收数据使用的缓存char buf1024;int bytes = 0;Net_Header * pHeader = (Net_Header *) buf;while (mIsReceiving)/ 首先接收一个头信息（头信息内包含了随后的有效数据长度）bytes = recv(mSocket, buf, sizeof(Net_Header), 0);if (bytes = SOCKET_ERROR | bytes = 0)Detach();mIsReceiving = FALSE;break;pHeader-my_ntoh(); / 字节顺序转换！/ 继续读取后续的有效数据（即一个字符串内容）bytes = recv(mSocket, buf, pHeader-pack_size, 0);if (bytes = SOCKET_ERROR | bytes = 0)Detach();mIsReceiving = FALSE;break;bufbytes = 0