【正文】 _info_base* GetInfo()。 void SetInfo(group_info_base amp。gInfo)。 CGroupamp。 operator=(CGroupamp。 group)。 void SetHasMsg(BOOL bHasMsg)。 BOOL IsHasMsg()。 virtual ~CGroup()。 private: group_info_base m_info。 BOOL m_bHasMsg。}。3．服務(wù)器部分（1）CSql類，封裝了服務(wù)器對(duì)數(shù)據(jù)庫(kù)操作class CSql {public: CNASocket *m_pSocket。public: CSql()。 void GetGroupInfomation(UINT32 group_id, group_info_base* pGroupInfo)。 int CreateDatabaseTable()。 int Execute(void* pInfo, int type, void* pOtherInfo = NULL)。 int StoreToOfflineTable(send_offline_back amp。info)。 int SetMemberRelationship(UINT32 s_usr_id, UINT32 uid)。 int SetGroupRelationship(UINT32 group_id, UINT32 uid)。 UINT32 GetTotal()。 UINT32 GetGroupTotal()。 UINT16 GetFriendsNum(UINT32 usr_id)。 UINT32 GetGroupAdminID(UINT32 group_id)。 int GetGroupList(UINT32 usr_id, CListCGroupInfo, CGroupInfoamp。* pGroupInfoList)。 void GetMemberIDList(UINT32 usr_id, CListUINT32, UINT32* g_usridList)。 void GetOfflineInfo(UINT32 usr_id)。 void GetGroupMem(UINT32 group_id, CListCMemberInfo, CMemberInfoamp。* pMemberInfoList)。 void GetUsrInfomation(UINT32 usr_id, usr_info* pUsrInfo)。 UINT16 GetGroupsNum(UINT32 usr_id)。 virtual ~CSql()。protected: UINT16 GetGroupMemNum(UINT32 group_id)。 int CreateGroup(create_group_info* pInfo)。 int ConfirmAccount(login_info* pInfo)。 int RegisteAccount(register_info* pInfo)。 int SetMemberInfo(set_info* pInfo)。 int SearchFriends(search_friends_info* pInfo, usr_info* pUsrInfo)。 int SearchGroup(search_group_info *pInfo, group_info_base* pGroupInfo)。 UINT32 UpdateTotalMemberNum(CString str_sql)。 void GetUsrInfo(_RecordsetPtr pRecordset, usr_info* pUsrInfo)。 int GetFriendsList(UINT32 *pUsr_id, CListCMemberInfo, CMemberInfoamp。* pMemberInfoList)。 int GetTotalNum(int type)。 void GetGroupInfo(_RecordsetPtr pRecordset, group_info_base *pGroup_info)。private: CAdoDB m_Ado。 UINT32 m_nTotal。 UINT32 m_nGroupTotal。 _CommandPtr m_pCommand。 _ConnectionPtr m_pConnection。}。（2）CNASocket類，用于接受客戶端的命令請(qǐng)求class CNASocket : public CAsyncSocket{// Attributespublic: CWnd* m_pWnd。 UINT32 m_onlineMemNum。 UINT32 m_recvNum。 UINT32 m_sendNum。 // Operationspublic: CNASocket()。 virtual ~CNASocket()。// Overridespublic: // ClassWizard generated virtual function overrides //{{AFX_VIRTUAL(CNASocket) public: virtual void OnReceive(int nErrorCode)。 virtual void OnSend(int nErrorCode)。 //}}AFX_VIRTUAL // Generated message map functions //{{AFX_MSG(CNASocket) // NOTE the ClassWizard will add and remove member functions here. //}}AFX_MSG int SendToClient(CPacketamp。 packet)。 int ResolvePacket(CPacketamp。 packet)。 int get_usr_id(UINT16 nPort, CString sSockAddr)。 void NotifyMember(UINT32 usr_id, CMember* pMember, int type)。 void StoreOffline(UINT32 s_usr_id, UINT32 uid, UINT32 group_id, int type, CString sReserved_info)。 void UpdateWnd(int list_type, int msg_type, CString sSockAddr, UINT16 nPort)。 void SendOfflineInfo(UINT32 usr_id, UINT nPort, CString sSockAddr)。 POSITION IsOnline(UINT32 usr_id)。// NAplementationprotected: //以下是各種命令請(qǐng)求的處理線程函數(shù) static DWORD WINAPI RegisterThread(LPVOID pParam)。 static DWORD WINAPI LoginThread(LPVOID pParam)。 static DWORD WINAPI SetInfoThread(LPVOID pParam)。 static DWORD WINAPI StatusChange(LPVOID pParam)。 static DWORD WINAPI HeartBeat(LPVOID pParam)。 static DWORD WINAPI SearchFriends(LPVOID pParam)。 static DWORD WINAPI AddFriends(LPVOID pParam)。 static DWORD WINAPI DelFriends(LPVOID pParam)。 static DWORD WINAPI GetFriendsList(LPVOID pParam)。 static DWORD WINAPI GetOnlineInfo(LPVOID pParam)。 static DWORD WINAPI CreateGroup(LPVOID pParam)。 static DWORD WINAPI JoinGroup(LPVOID pParam)。 static DWORD WINAPI SearchGroup(LPVOID pParam)。 static DWORD WINAPI Logout(LPVOID pParam)。 static DWORD WINAPI ProcessLeaveMsg(LPVOID pParam)。 static DWORD WINAPI SendGroupMsg(LPVOID pParam)。 static DWORD WINAPI GetGroupList(LPVOID pParam)。 static DWORD WINAPI GetGroupMemList(LPVOID pParam)。 static DWORD WINAPI GetGroupMemOnlineInfo(LPVOID pParam)。 static DWORD WINAPI UdpHolingThread(LPVOID pParam)。}。（3）CGlobalData類，用于封裝服務(wù)器所用到的全局?jǐn)?shù)據(jù)和函數(shù)class CGlobalData {public: CGlobalData()。 BOOL GetOnlineInfo(UINT32 usr_id, usr_info_online* pOnlineInfo)。 virtual ~CGlobalData()。public: CSql g_sql。 UINT g_nCurTcpRecvThreadLoginInfo。 UINT g_nCurTcpRecvThreadGroupMem。 HANDLE g_hSemaphoreLoginInfo。 HANDLE g_hSemaphoreGroupMem。 CRITICAL_SECTION g_memberOnlineListCs。 CRITICAL_SECTION g_tcpLoginInfoCs。 CRITICAL_SECTION g_tcpGroupMemCs。 CRITICAL_SECTION g_cs。 CRITICAL_SECTION g_cs_1。 CListTCPSOCKETINFO, TCPSOCKETINFOamp。 g_tcpSocketLoginInfoList。 CListTCPSOCKETINFO, TCPSOCKETINFOamp。 g_tcpSocketGroupMemList。 CListCMemberInfo, CMemberInfoamp。 g_memberInfoList。 //在線會(huì)員信息 CListCMember, CMemberamp。 g_memberOnlineList。 //會(huì)員在線信息 }。（4）CMemberInfo類，用于存放會(huì)員信息class CMemberInfo {public: CMemberInfo()。 CMemberInfo(CMemberInfoamp。 mem_info)。 virtual ~CMemberInfo()。 void SetInfo(usr_info info)。 usr_infoamp。 GetInfo()。private: usr_info m_info。}。（5）CGroupInfo，用于存放群信息class CGroupInfo {public: CGroupInfo()。 CGroupInfo(CGroupInfoamp。 info)。public: group_info_baseamp。 GetInfo()。 void SetInfo(group_info_baseamp。 group_info)。 virtual ~CGroupInfo()。private: group_info_base m_info。}。第 46 頁(yè) 共 45頁(yè)