传给发送线程的参数数据结构：
struct sparam
{
 CData* pData; 需要发送的数据的指针
 CWnd*pWnd;   接受反馈消息的窗口
 CClientSocket* pSocket; 客户端socket的指针
};

全局函数申明：
UINT RequestFriendDetail(LPVOID param);
查询所有好友的详细信息是否完全，若没有详细信息，则以一定的时间间隔，向服务器发送没有详细信息的好友的请求信息。此工作线程函数，在上线或隐身后，N秒后将开始执行，然后每隔K秒就向服务器发送请求信息，在后台处理。原则是，把每个好友详细信息取回，又不影响前台用户的操作。
UINT SendThread(LPVOID param);
在线程里发送数据的函数

§4.6服务器端的底层通讯类的设计

 为了使能及时响应用户的请求，当用户很多时，仍然能够适应要求，我把侦听与发送数据的Socket分开，并分别都建立了多个实例，
也就是说，支持多个端口的侦听，发送数据使用的是多个端口，我只对侦听端口感兴趣，对发送数据的端口不感兴趣，因为，发送端口是多少都无所谓。

 CRecvSocket和CsendSocket都是从CAsyncSocket类里继承而来，分别处理侦听请求各发送数据，在CServerSocket类里，定义了几个CRecvSocket和CSendSocket对象的实例，通过CServerSocket类对内部进行组织和管理，提供给上层的接口是CServerSocket，它隐藏了服务器底层通讯的细节及多线程发送数据的问题，提供给上一层一个统一的接口，CServerSocket类的使用，是先建立一个它的实例，再调用成员函数Create(),传入必要的参数，发送数据时，就调用其成员函数SendData，处理接受数据，在CRecvSocket类的OnReceive里处理，调用了一个名为ProcessRecvData的线程函数，用户在这个线程函数里写上具体的处理代码

算法描述：

 发送一个数据，需要等待响应信息的回来，如果在规定时间内，还没有收到确认信息，则认为发送数据丢失，将重试FailReDoTime次，如果还是没有确认信息发送回来，则返回发送失败，否则，返回发送成功。
 
 因为服务器是多线程的发送数据，有一个请求，就建立一个线程进行处理。我为每个发送socket设置一个是否忙的标志busy，当需要发送数据时，就选择一个空闲的sendsocket,设置为忙，然后发送数据，再设置回空闲，然后等待确认信息的回来。
 
 SendData函数的实现算法，通过设置一个缓冲区长度为N，然后，为每一次数据进行统计，发一次，就加1，然后把发送数据中的This=count%N，且把缓冲区中第This个成员设为0，在发送端，就要数组中的第This个成员是否为1即可，在接受到的确认信息中，取出This项，再为缓冲区中第This项设为1，这样就可以快速且可靠的判断发送数据是否得到响应回来了。

侦听类结构：
class CRecvSocket : public CAsyncSocket
{
private:
 char m_szResponseMsg[MaxResponseMsgLength];     确认消息串
 int m_szrLength;                                 确认消息串的长度
public:
 CRecvSocket();
 virtual ~CRecvSocket();
public:
 BOOL Create(int nPort);             指定端口号，建立一个侦听Socket
 virtual void OnReceive(int nErrorCode);  处理接受数据
};

发送数据的socket类结构
class CSendSocket : public CAsyncSocket
{
private:
 BYTE* pBuf; 
//指向CServerSocket的m_arBuf缓冲区，处理发送后是否收到确认信息的缓冲区
 char m_szResponseMsg[20];
 int m_szrLength;
public:
 CSendSocket(BYTE*buf);
 virtual ~CSendSocket();
 BOOL Create();                     建立一个发送的socket
 virtual void OnReceive(int nErrorCode);  处理发送数据后接受到的确认消息
};

服务器的socket类
 这个通讯类的SendData，当发送数据失败时，可以重发几次，次数可由用户来确定
class CServerSocket 
{
public: 
 void Close();
 BOOL Create(int SendSockNum,CArray<DWORD,DWORD>&aPort,int TimeOut= TimeWaitForRes);
//建立侦听Socket和发送Socket，aPort是侦听端口数组，TimeOut是设置发送超时时间
 BOOL SendData(CData* pData,int FailReDoTimes=3);  
//数据函数，这个函数适合在线程里发送数据函数，而服务器的响应都是在工人线程里完成的，所以，很适合服务器的发送数据。成功返回真，不成功返

首页 上一页 5 6 7 8 9 10 11 下一页 尾页 8/17/17

相关论文