[手游新项目历程]第10天-角色登陆流程

管理容器
//References :
typedef std::map<std::string, int> clientMapT;
clientMapT clientMap;	
LogicalConnection* ClientFactoryImpl::AddLogicalConnection( LogicalConnection* pClient )
{
    std::string key(pClient->getKey());
    ScopedLock csLock(cs);
    //
    LogicalConnection* pRet = pClient;

    clientMapT::iterator it = clientMap.find(key);
    if(it!=clientMap.end())
    {
        pRet =  it->second;
    }
    else
    {
        clientMap[key] = pClient;
        nClientsCount++;
    }

    pRet->IncrementUsage();
    return pRet;
}

LogicalConnection* ClientFactoryImpl::FindLogicalConnection( const char* _key )
{
    std::string key(_key);
    //
    ScopedLock csLock(cs);

    clientMapT::iterator it = clientMap.find(key);
    if(it==clientMap.end())
        return NULL;

    LogicalConnection* pClient = it->second;

    pClient->IncrementUsage();
    return pClient;
}

	LogicalConnection* pRecipient = FindClient(request.GetArg1().c_str());
	if (pRecipient)
	{
		WebsocketDataMessage response(Routedcommunication);
		response.SetArguments(request.GetEncodedData());
		pRecipient->PushPacket(&response);
		ReturnClient(pRecipient);
	}
	
	std::map<Tint32, LogicalConnection*>	m_PlayerConnectionIdMap;	//错误的方式
	如果自己存一个连接的指针取出来发送回报错，
	
	std::map<Tint32, CLIENT_KEY>			m_PlayerConnectionIdMap;	//正确的方式	
	LogicalConnection* pRecipient = FindClient(CLIENT_KEY);
	只能存一个key的容器，通过key去自带的容器取连接来发送包

角色登陆流程

GAME_MSG_LOGIN_REQ					=		1001,					//登陆

client发送登陆包 -> webServer 产生链接ConIdid写进包->gate 

Tint32 NetGate::OnRecvHandle( t_ConnID ConnectionId,tagNetMsg *pMsg ) 消息派发

Tint32 NetClient::OnAcceptHandle( t_ConnID ConnectionId )

void GatePlayerMgr::AddPlayerConnIdMap( t_ConnID nConnId, GatePlayer* pGatePlayer )

TBool NetDBCache::PlayerRetLogin( t_ConnID ConnectionId,tagNetMsg &Msg )

void NetWorld::SendToWholeWorld(Tint32 msgID,char *buff, unsigned int buffLen , ePlayerFilter eFilter, Tint64 nFilterValue)
{
	Debug_Assert(buffLen < enMaxMsgDataBufferSize, );
	tagNetMsg msgToSend;
	memcpy(msgToSend.buff, buff, buffLen);
	msgToSend.BuffLen = buffLen;
	msgToSend.MsgID = msgID;
	SendToWholeWorld(msgToSend, eFilter, nFilterValue);
}

void NetWorld::SendToWholeWorld( tagNetMsg& msg,ePlayerFilter eFilter /*= ePlayerFilter_All*/, Tint64 nFilterValue /*= -1*/ )
{
	tagNetMsg MsgToSend;
	Stream stream(MsgToSend.buff, sizeof(MsgToSend.buff));
	stream.Write(eFilter);
	stream.Write(nFilterValue);
	stream.Write(msg);
	MsgToSend.MsgID = GAME_SERVER_MSG_BROCAST_WHOLE_WORLD;
	MsgToSend.BuffLen = stream.GetPos();
	SendSingle(MsgToSend.MsgID, MsgToSend.BuffLen, MsgToSend);
}

struct MsgLoginReq
{
	void Serialize(Stream& stream) 
	{
		unsigned short nLen = (unsigned short)m_Account.GetRealStrLen();
		stream.Write(nLen);
		stream.WriteBuffer(m_Account.GetName(),nLen);

		stream.Write(m_SerVerId);

		nLen = (unsigned short)m_Platform.GetRealStrLen();
 		stream.Write(nLen);
 		stream.WriteBuffer(m_Platform.GetName(),nLen);
	}

	bool DeSerialize(Stream& stream)
	{
		unsigned short nLen = 0;

		//玩家账号
		if (!stream.Read(nLen))
			return false;
		if(nLen >= MAX_ACCOUNT_LEN)
			return false;
		if (!stream.ReadBuffer(m_Account.GetName(), nLen))
			return false;
		//服务器id
		if (!stream.Read(m_SerVerId))
			return false;
		//平台标识
 		if (!stream.Read(nLen))
 			return false;
 		if(nLen >= MAX_PLATFORM_LEN)
 			return false;
 		if (!stream.ReadBuffer(m_Platform.GetName(), nLen))
 			return false;
		return true;
	}

	CommonAccountName m_Account;
	CommonString<255> m_Token;
	Tint32 m_SerVerId;
	CommonPlatform m_Platform;
};

TBool NetGate::PlayerLoginResService
DB_MSG_ACCOUNT_LOGIN,								//登录
DB_MSG_ACCOUNT_LOGIN_RET,							//登录返回
GAME_MSG_LOGIN_RES
void NetGate::SendToClientWithClientConnId
GAME_SERVER_MSG_DBCACHE_TO_GATE ,					//从DBCACHE发给GATE
TBool NetDBCache::PlayerRetLogin( t_ConnID ConnectionId,tagNetMsg &Msg )