68 lines
1.8 KiB
C++
68 lines
1.8 KiB
C++
|
||
#include "StdAfx.h"
|
||
|
||
CDBSessionClient::CDBSessionClient(CDBServer *lpDBServer)
|
||
{
|
||
m_pDBServer = lpDBServer;
|
||
}
|
||
|
||
CDBSessionClient::~CDBSessionClient()
|
||
{
|
||
}
|
||
|
||
SERVERTYPE CDBSessionClient::getLocalServerType()
|
||
{
|
||
return DBServer;
|
||
}
|
||
|
||
int CDBSessionClient::getLocalServerIndex()
|
||
{
|
||
return m_pDBServer->getServerIndex();
|
||
}
|
||
LPCSTR CDBSessionClient::getLocalServerName()
|
||
{
|
||
return m_pDBServer->getServerName();
|
||
}
|
||
|
||
CCustomGlobalSession* CDBSessionClient::CreateSession()
|
||
{
|
||
return Inherited::CreateSession();
|
||
}
|
||
|
||
VOID CDBSessionClient::DestroySession(CCustomGlobalSession* pSession)
|
||
{
|
||
Inherited::DestroySession(pSession);
|
||
}
|
||
|
||
VOID CDBSessionClient::OnOpenSession(CCustomGlobalSession* pSession, BOOL boIsNewSession)
|
||
{
|
||
|
||
//收到打开session的包的时候，向session服务器发一个包，回复一下，session依据这个回复告诉客户端登陆
|
||
//通过这个确认的流程，保证登陆服务器的时候，session的数据是到位的
|
||
//只有自己的数据服务器才会回复，其他的不需要回复
|
||
if( m_pDBServer->getGameReady(pSession->nServerIndex) )
|
||
{
|
||
CDataPacket &data = allocProtoPacket(jxInterSrvComm::SessionServerProto::cConformOpenSession); //分配一个 网络包
|
||
data << (int)pSession->nSessionId ;
|
||
data << (int)pSession->nServerIndex;
|
||
flushProtoPacket(data);
|
||
}
|
||
}
|
||
|
||
VOID CDBSessionClient::OnCloseSession(int nSessionId)
|
||
{
|
||
//会话被关闭的同时需要向网关发送按全局会话ID关闭连接的消息
|
||
m_pDBServer->PostCloseGateUserBySessionId(nSessionId);
|
||
}
|
||
|
||
VOID CDBSessionClient::OnUpdateSessionState(CCustomGlobalSession* pSession, jxSrvDef::GSSTATE oldState, jxSrvDef::GSSTATE newState)
|
||
{
|
||
}
|
||
|
||
VOID CDBSessionClient::OnQuerySessionExists(INT_PTR nSessionId)
|
||
{
|
||
//异步的通过会话ID查询网关用户，网关对此消息的返回将在内部消息分派函数中处理
|
||
m_pDBServer->PostQueryUserExistsBySessionId((int)nSessionId);
|
||
}
|
||
|