kbengine 登录login过程

ゞ浴缸里的玫瑰 2023-06-28 11:10 19阅读 0赞

服务端部分：  
1：服务端loginapp.cpp中“void Loginapp::login(Network::Channel\* pChannel, MemoryStream& s)”被触发， 这个函数进行了一系列的检查，  
确定合法后向dbmgr发送一个登陆请求包“(\*pBundle).newMessage(DbmgrInterface::onAccountLogin);”, dbmgr也会进行一系列的检查并将登陆结果返回到loginapp。

1.  void Loginapp::login(Network::Channel\* pChannel, MemoryStream& s)
2.  \{
3.          ...
4.  ...
5.          if(loginName.size() > ACCOUNT\_NAME\_MAX\_LENGTH)
6.          \{
7.                  INFO\_MSG(fmt::format("Loginapp::login: loginName is too long, size=\{\}, limit=\{\}.\\n",
8.                          loginName.size(), ACCOUNT\_NAME\_MAX\_LENGTH));
9.                  
10.                 \_loginFailed(pChannel, loginName, SERVER\_ERR\_NAME, datas, true);
11.                 s.done();
12.                 return;
13.         \}
14.  
15.         if(password.size() > ACCOUNT\_PASSWD\_MAX\_LENGTH)
16.         \{
17.                 INFO\_MSG(fmt::format("Loginapp::login: password is too long, size=\{\}, limit=\{\}.\\n",
18.                         password.size(), ACCOUNT\_PASSWD\_MAX\_LENGTH));
19.                 
20.                 ...
21. ...
22. ...
23.  
24.  
25.         // 向dbmgr查询用户合法性
26.         Network::Bundle\* pBundle = Network::Bundle::ObjPool().createObject();
27.         (\*pBundle).newMessage(DbmgrInterface::onAccountLogin);
28.         (\*pBundle) << loginName << password;
29.         (\*pBundle).appendBlob(datas);
30.         dbmgrinfos->pChannel->send(pBundle);
31. \}

复制代码

1.1： loginapp得到dbmgr的登录合法结果后向baseappmgr发送了分配网关（baseapp）请求(registerPendingAccountToBaseapp)， 通常是负载较低的一个baseapp进程.

1.  void Loginapp::onLoginAccountQueryResultFromDbmgr(Network::Channel\* pChannel, MemoryStream& s)
2.  \{
3.          ...
4.  ...
5.  ...
6.          // 如果大于0则说明当前账号仍然存活于某个baseapp上
7.          if(componentID > 0)
8.          \{
9.                  Network::Bundle\* pBundle = Network::Bundle::ObjPool().createObject();
10.                 (\*pBundle).newMessage(BaseappmgrInterface::registerPendingAccountToBaseappAddr);
11.                 (\*pBundle) << componentID << loginName << accountName << password << entityID << dbid << flags << deadline << infos->ctype;
12.                 baseappmgrinfos->pChannel->send(pBundle);
13.                 return;
14.         \}
15.         else
16.         \{
17.                 // 注册到baseapp并且获取baseapp的地址
18.                 Network::Bundle\* pBundle = Network::Bundle::ObjPool().createObject();
19.                 (\*pBundle).newMessage(BaseappmgrInterface::registerPendingAccountToBaseapp);
20.  
21.                 (\*pBundle) << loginName;
22.                 (\*pBundle) << accountName;
23.                 (\*pBundle) << password;
24.                 (\*pBundle) << dbid;
25.                 (\*pBundle) << flags;
26.                 (\*pBundle) << deadline;
27.                 (\*pBundle) << infos->ctype;
28.                 baseappmgrinfos->pChannel->send(pBundle);
29.         \}
30. \}

复制代码

1.2：baseappmgr最终返回所分配的baseapp的ip地址等信息，loginapp将其转发给客户端(登录成功协议onLoginSuccessfully，包含baseapp的ip和端口信息）

1.  void Loginapp::onLoginAccountQueryBaseappAddrFromBaseappmgr(Network::Channel\* pChannel, std::string& loginName, 
2.                                                                                                                          std::string& accountName, std::string& addr, uint16 port)
3.  \{
4.          ...
5.  ...
6.  ...
7.   
8.          Network::Bundle\* pBundle = Network::Bundle::ObjPool().createObject();
9.          (\*pBundle).newMessage(ClientInterface::onLoginSuccessfully);
10.         uint16 fport = ntohs(port);
11.         (\*pBundle) << accountName;
12.         (\*pBundle) << addr;
13.         (\*pBundle) << fport;
14.         (\*pBundle).appendBlob(infos->datas);
15.         pClientChannel->send(pBundle);
16.  
17.         SAFE\_RELEASE(infos);
18. \}

复制代码

2: 客户端插件得到返回结果后调用KBEngineApp.cs->login\_baseapp()函数开始正式登录到baseapp。  
  
3：baseapp收到登录请求

1.  void Baseapp::loginGateway(Network::Channel\* pChannel, 
2.                                                     std::string& accountName, 
3.                                                     std::string& password)

复制代码

进行了一系列的检查，包括：账号是否已经在线，是否可以在这里登录等等。  
当检查合法后，向dbmgr发送了一个查询账号信息的请求“DbmgrInterface::queryAccount”，dbmgr将查询到的账号数据(包括属性等)返回到baseapp， Baseapp::onQueryAccountCBFromDbmgr  
当函数结果为合法时，根据配置中定义的账号实体脚本名称“g\_serverConfig.getDBMgr().dbAccountEntityScriptType”创建了Account实体， 同时还创建了一个clientMailbox，账号实体中调用clientMailbox->方法()即可与客户端通讯了。  
Account实体被创建后， 首先\_\_init\_\_被调用， 接着onEntitiesEnabled被调用， 此时实体正式可用了。  
  
账号登陆成功后， 客户端Account.cs中会调用\_\_init\_\_() -> baseCall("reqAvatarList");来请求获得角色列表，  
UI.cs中onReqAvatarList得到结果