155 lines
3.1 KiB
C++
155 lines
3.1 KiB
C++
|
|
|||
|
|
#include "StdAfx.h"
|
|||
|
|
|
|||
|
|
|
|||
|
|
/*
|
|||
|
|
|
|||
|
|
CSSGateManager::CSSGateManager(CSSManager *lpSSManager)
|
|||
|
|
:Inherited()
|
|||
|
|
{
|
|||
|
|
m_dwReconnectSQLTick = 0;
|
|||
|
|
m_pSSManager = lpSSManager;
|
|||
|
|
m_SQLConnection.SetMultiThread(TRUE);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
CSSGateManager::~CSSGateManager()
|
|||
|
|
{
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
BOOL CSSGateManager::ConnectSQL()
|
|||
|
|
{
|
|||
|
|
TICKCOUNT nCurrentTick = _getTickCount();
|
|||
|
|
if ( !m_SQLConnection.Connected() )
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
if ( nCurrentTick >= m_dwReconnectSQLTick )
|
|||
|
|
{
|
|||
|
|
if (NULL ==m_pSSManager) return FALSE;
|
|||
|
|
m_pSSManager->SetupSQLConnection(&m_SQLConnection);
|
|||
|
|
if ( m_SQLConnection.Connect() )
|
|||
|
|
{
|
|||
|
|
mysql_options(m_SQLConnection.GetMySql(), MYSQL_SET_CHARSET_NAME, "utf8");
|
|||
|
|
//if (m_SQLConnection.Exec("charset utf8"))
|
|||
|
|
//{
|
|||
|
|
// OutputMsg( rmError, _T("设置utf8字符编码出错！！！"));
|
|||
|
|
//}
|
|||
|
|
//else
|
|||
|
|
//{
|
|||
|
|
// m_SQLConnection.ResetQuery();
|
|||
|
|
//}
|
|||
|
|
return TRUE;
|
|||
|
|
}
|
|||
|
|
OutputMsg( rmError, "连接数据库ip=%s,port=%d失败",
|
|||
|
|
m_SQLConnection.GetServerHost(),m_SQLConnection.GetServerPort());
|
|||
|
|
|
|||
|
|
//如果连接SQL失败则将在5秒后重试
|
|||
|
|
m_dwReconnectSQLTick = _getTickCount() + 5 * 1000;
|
|||
|
|
return FALSE;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
if( nCurrentTick> m_dwDumpTime)
|
|||
|
|
{
|
|||
|
|
if(m_dwDumpTime )
|
|||
|
|
{
|
|||
|
|
if(m_dwDumpTime)
|
|||
|
|
{
|
|||
|
|
CTimeProfMgr::getSingleton().dump();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
m_dwDumpTime = nCurrentTick + 300000; //5分钟打印一次
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
return TRUE;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
VOID CSSGateManager::ResultUserSessionConfim(const int nSessionId, const BOOL boOnline)
|
|||
|
|
{
|
|||
|
|
CSSGate *pGate;
|
|||
|
|
for ( int i=0; i<ArrayCount(m_Gates); ++i )
|
|||
|
|
{
|
|||
|
|
pGate = &m_Gates[i];
|
|||
|
|
if (pGate && pGate->m_UserList.count() > 0)
|
|||
|
|
{
|
|||
|
|
if ( pGate->ResultGateUserSessionConfim(nSessionId, boOnline) )
|
|||
|
|
{
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
//打开一个session
|
|||
|
|
VOID CSSGateManager::OnResultConformOpenSession(int nSessionId, int nServerIndex)
|
|||
|
|
{
|
|||
|
|
CSSGate *pGate;
|
|||
|
|
for ( int i=0; i<ArrayCount(m_Gates); ++i )
|
|||
|
|
{
|
|||
|
|
pGate = &m_Gates[i];
|
|||
|
|
if (pGate && pGate->m_UserList.count() > 0)
|
|||
|
|
{
|
|||
|
|
if ( pGate->ResultOpenSession(nSessionId,nServerIndex) )
|
|||
|
|
{
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
VOID CSSGateManager::Initialize()
|
|||
|
|
{
|
|||
|
|
int i;
|
|||
|
|
for ( i=0; i<ArrayCount(m_Gates); ++i )
|
|||
|
|
{
|
|||
|
|
m_Gates[i].m_pSQLConnection = &m_SQLConnection;
|
|||
|
|
m_Gates[i].m_pSSManager = m_pSSManager;
|
|||
|
|
|
|||
|
|
//将网关添加到列表
|
|||
|
|
m_GateList[i] = &m_Gates[i];
|
|||
|
|
}
|
|||
|
|
m_dwDumpTime =0;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
VOID CSSGateManager::Uninitialize()
|
|||
|
|
{
|
|||
|
|
int i;
|
|||
|
|
for ( i=0; i<ArrayCount(m_GateList); ++i )
|
|||
|
|
{
|
|||
|
|
//将网关从列表移除
|
|||
|
|
m_GateList[i] = NULL;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
VOID CSSGateManager::OnResultGateUserExists(int nSessionId, const BOOL boOnline)
|
|||
|
|
{
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
VOID CSSGateManager::DispatchInternalMessage(UINT uMsg, UINT64 uParam1, UINT64 uParam2, UINT64 uParam3, UINT64 uParam4)
|
|||
|
|
{
|
|||
|
|
switch (uMsg)
|
|||
|
|
{
|
|||
|
|
case GTIM_CONFIM_SESSION_RESULT://会话服务器向网关用户投递确认会话是否在线的结果(Param1=会话ID，Param2=是否在线(0:1))
|
|||
|
|
ResultUserSessionConfim((int)uParam1, (int)uParam2);
|
|||
|
|
break;
|
|||
|
|
//确认已经打开了会
|
|||
|
|
case GTIM_CONFIRM_OPEN_SESSION:
|
|||
|
|
OnResultConformOpenSession((int)uParam1,(int)uParam2);
|
|||
|
|
break;
|
|||
|
|
default:
|
|||
|
|
Inherited::DispatchInternalMessage(uMsg, uParam1, uParam2, uParam3,uParam4);
|
|||
|
|
break;
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
VOID CSSGateManager::OnRun()
|
|||
|
|
{
|
|||
|
|
if ( Started() )
|
|||
|
|
{
|
|||
|
|
ConnectSQL();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
*/
|
|||
|
|
|