模拟服务器

开发平台：

Visual C++

ThreadFuncForMsg.cpp：源码内容

							#include "stdafx.h"
extern HWND						g_hStatusBar;
extern CWHList<CGateInfo*>		g_xGateList;
UINT WINAPI ThreadFuncForMsg(LPVOID lpParameter)
{
	_TDEFAULTMESSAGE	DefaultMsg;
	char				*pszBegin, *pszEnd;
	int					nCount;
	PLISTNODE			pListNode;
	CGateInfo*			pGateInfo;
	while (TRUE)
	{
		if (g_xGateList.GetCount())
		{
			pListNode = g_xGateList.GetHead();
			while (pListNode)
			{
				pGateInfo = g_xGateList.GetData(pListNode);
				if (pGateInfo)
				{
					nCount = pGateInfo->g_SendToGateQ.GetCount();
					if (nCount)
					{
						for (int nLoop = 0; nLoop < nCount; nLoop++)
						{
							_LPTSENDBUFF pSendBuff = (_LPTSENDBUFF)pGateInfo->g_SendToGateQ.PopQ();
							if (pSendBuff)
							{
								int nLen = memlen(pSendBuff->szData);
								if ((pszBegin = (char *)memchr(pSendBuff->szData, '#', nLen)) &&(pszEnd = (char *)memchr(pSendBuff->szData, '!', nLen)))
								{
									*pszEnd = '';
									fnDecodeMessageA(&DefaultMsg, (pszBegin + 2));	// 2 = "#?" ? = Check Code 
									switch (DefaultMsg.wIdent)
									{
										case CM_PROTOCOL:
											break;
										case CM_IDPASSWORD:
											pGateInfo->ProcLogin(pSendBuff->sock, pszBegin + DEFBLOCKSIZE + 2);
											break;
										case CM_SELECTSERVER:
											pGateInfo->ProcSelectServer(pSendBuff->sock, DefaultMsg.wParam);
											break;
										case CM_ADDNEWUSER:
											pGateInfo->ProcAddUser(pSendBuff->sock, pszBegin + DEFBLOCKSIZE + 2);
											break;
										case CM_UPDATEUSER:
											break;
										case CM_CHANGEPASSWORD:
											break;
									}
								}
								delete pSendBuff;
								pSendBuff = NULL;
							}
						}
					}
				}
				pListNode = g_xGateList.GetNext(pListNode);
			}
		}
		SleepEx(1, TRUE);	
	}
	return 0;
}

						