rewrite p2xpprotocol module

app write p2xp code

Author: xengine-qyt

XEngine_Source/XEngine_P2XPComponents/XEngine_P2XPPeer/P2XPPeer_Define.h

@@ -24,7 +24,6 @@ typedef struct tag_P2XP_Timer_Information
 //一个节点信息
 typedef struct tag_NetEngine_P2XPPeer_Info
 {
-    XENGINE_PROTOCOL_USERAUTH st_AuthUser;                                //用户登录信息
     XENGINE_P2XPPEER_PROTOCOL st_PeerAddr;                                //P2P通信的时候使用的地址（客户方使用）
     P2XP_TIMER_INFOMATION st_PeerTimer;                                   //节点时间信息
     BOOL bIsLogin;

XEngine_Source/XEngine_P2XPComponents/XEngine_P2XPPeer/P2XPPeer_Manage/P2XPPeer_Manage.cpp

@@ -49,7 +49,7 @@ BOOL CNetEngine_P2XPPeerManage::P2XPPeer_Manage_Add(XENGINE_P2XP_PEERINFO st_Pee
     stl_MapIterator = stl_MapPeerAddr.begin();
     for (;stl_MapIterator != stl_MapPeerAddr.end();stl_MapIterator++)
     {
-        if (0 == _tcsncmp(stl_MapIterator->second->st_AuthUser.tszUserName, st_PeerInfo.st_AuthUser.tszUserName, _tcslen(stl_MapIterator->second->st_AuthUser.tszUserName)))
+        if (0 == _tcsncmp(stl_MapIterator->second->st_PeerAddr.tszUserName, st_PeerInfo.st_PeerAddr.tszUserName, _tcslen(stl_MapIterator->second->st_PeerAddr.tszUserName)))
         {
             PeerManage_IsErrorOccur = TRUE;
             PeerManage_dwErrorCode = ERROR_XENGINE_P2XP_PEER_MANAGE_ADD_ISEXIST;
@@ -157,7 +157,7 @@ BOOL CNetEngine_P2XPPeerManage::P2XPPeer_Manage_GetUser(LPCTSTR lpszUser, XENGIN
     unordered_map<tstring, LPNETENGINE_P2XP_PEERINFO>::const_iterator stl_MapIterator = stl_MapPeerAddr.begin();
     for (;stl_MapIterator != stl_MapPeerAddr.end();stl_MapIterator++)
     {
-        if (0 == _tcsncmp(lpszUser,stl_MapIterator->second->st_AuthUser.tszUserName,_tcslen(lpszUser)))
+        if (0 == _tcsncmp(lpszUser,stl_MapIterator->second->st_PeerAddr.tszUserName,_tcslen(lpszUser)))
         {
             bIsFound = TRUE;
             break;

XEngine_Source/XEngine_P2XPComponents/XEngine_P2XPProtocol/P2XPProtocol_Define.h

@@ -15,221 +15,186 @@
 //////////////////////////////////////////////////////////////////////////
 extern "C" DWORD P2XPProtocol_GetLastError(int *pInt_ErrorCode = NULL);
 /************************************************************************/
-/*                        服务协议导出                                  */
+/*                        解析协议导出                                  */
 /************************************************************************/
 /********************************************************************
-函数名称：P2XPProtocol_ServiceMsg_ResponseJson
-函数功能：处理一个相应包,用于告诉请求端请求的内容成功还是失败!
- 参数.一：pSt_ProtocolHdr
+函数名称：P2XPProtocol_Parse_Login
+函数功能：登录解析函数
+ 参数.一：lpszMsgBuffer
   In/Out：In
-  类型：数据结构指针
-  可空：N
-  意思：要处理的协议头
- 参数.二：pSt_ProtocolP2xp
-  In/Out：In
-  类型：数据结构指针
-  可空：N
-  意思：要数据的P2XP协议
- 参数.三：ptszMsgBuffer
-  In/Out：Out
-  类型：字符指针
-  可空：N
-  意思：输出组号包的数据
- 参数.四：pInt_Len
-  In/Out：Out
-  类型：整数型指针
+  类型：常量字符指针
   可空：N
-  意思：输出组号包的数据大小
- 参数.五：nCode
+  意思：输入要解析的缓冲区
+ 参数.二：nMsgLen
   In/Out：In
   类型：整数型
-  可空：Y
-  意思：输入要返回的状态码，默认为0 成功
- 参数.六：lpszCodeMsg
+  可空：N
+  意思：输入缓冲区大小
+ 参数.三：pSt_P2XPPeer
   In/Out：In
-  类型：常量字符指针
-  可空：Y
-  意思：输入状态码意思，可以为NULL
+  类型：数据结构指针
+  可空：N
+  意思：输出解析后的节点信息
 返回值
   类型：逻辑型
   意思：是否成功
 备注：
 *********************************************************************/
-extern "C" BOOL P2XPProtocol_ServiceMsg_ResponseJson(XENGINE_PROTOCOLHDR *pSt_ProtocolHdr, CHAR *ptszMsgBuffer, int *pInt_Len, int nCode = 0, LPCSTR lpszCodeMsg = NULL);
+extern "C" BOOL P2XPProtocol_Parse_Login(LPCTSTR lpszMsgBuffer, int nMsgLen, XENGINE_P2XPPEER_PROTOCOL* pSt_P2XPPeer);
 /********************************************************************
-函数名称：P2XPProtocol_ServiceMsg_ResponseLan
-函数功能：响应同步局域网地址列表
- 参数.一：pSt_ProtocolHdr
+函数名称：P2XPProtocol_Parse_List
+函数功能：解析列表请求
+ 参数.一：lpszMsgBuffer
   In/Out：In
-  类型：数据结构指针
-  可空：N
-  意思：请求的协议头
- 参数.二：pppSt_ListClients
-  In/Out：In
-  类型：三级指针
+  类型：常量字符指针
   可空：N
-  意思：输入局域网地址信息列表
- 参数.三：nListCount
+  意思：输入要解析的缓冲区
+ 参数.二：nMsgLen
   In/Out：In
   类型：整数型
   可空：N
-  意思：局域网地址列表个数
- 参数.四：ptszMsgBuffer
+  意思：输入缓冲区大小
+ 参数.三：ptszPubAddr
   In/Out：Out
   类型：字符指针
   可空：N
-  意思：导出封装好的缓冲区
- 参数.五：pInt_Len
-  In/Out：In/Out
-  类型：整数型指针
+  意思：输出公有地址
+ 参数.四：ptszPriAddr
+  In/Out：Out
+  类型：字符指针
   可空：N
-  意思：输入你的缓冲区大小,输出缓冲区真实大小
+  意思：输出私有地址
 返回值
   类型：逻辑型
   意思：是否成功
 备注：
 *********************************************************************/
-extern "C" BOOL P2XPProtocol_ServiceMsg_ResponseLan(XENGINE_PROTOCOLHDR * pSt_ProtocolHdr, XENGINE_P2XPPEER_PROTOCOL * **pppSt_ListClients, int nListCount, CHAR * ptszMsgBuffer, int* pInt_Len);
+extern "C" BOOL P2XPProtocol_Parse_List(LPCTSTR lpszMsgBuffer, int nMsgLen, TCHAR* ptszPubAddr, TCHAR* ptszPriAddr);
 /********************************************************************
-函数名称：P2XPProtocol_ServiceMsg_ResponseQueryUser
-函数功能：响应用户查询用户信息的请求协议封包函数
- 参数.一：pSt_ProtocolHdr
+函数名称：P2XPProtocol_Parse_List
+函数功能：解析列表请求
+ 参数.一：lpszMsgBuffer
   In/Out：In
-  类型：数据结构指针
+  类型：常量字符指针
   可空：N
-  意思：请求的协议头
- 参数.二：pSt_PeerInfo
+  意思：输入要解析的缓冲区
+ 参数.二：nMsgLen
   In/Out：In
-  类型：数据结构指针
+  类型：整数型
   可空：N
-  意思：输入获取到的用户信息
- 参数.三：ptszMsgBuffer
+  意思：输入缓冲区大小
+ 参数.三：ptszUserName
   In/Out：Out
   类型：字符指针
   可空：N
-  意思：导出封装好的缓冲区
- 参数.四：pInt_Len
-  In/Out：In/Out
-  类型：整数型指针
-  可空：N
-  意思：输入你的缓冲区大小,输出缓冲区真实大小
+  意思：输出查询的用户名
 返回值
   类型：逻辑型
   意思：是否成功
 备注：
 *********************************************************************/
-extern "C" BOOL P2XPProtocol_ServiceMsg_ResponseQueryUser(XENGINE_PROTOCOLHDR *pSt_ProtocolHdr, XENGINE_P2XPPEER_PROTOCOL *pSt_PeerInfo, CHAR *ptszMsgBuffer, int *pInt_Len);
-/************************************************************************/
-/*                        用户协议导出                                  */
-/************************************************************************/
+extern "C" BOOL P2XPProtocol_Parse_User(LPCTSTR lpszMsgBuffer, int nMsgLen, TCHAR* ptszUserName);
 /********************************************************************
-函数名称：P2XPProtocol_UserMsg_RequestLogin
-函数功能：构造一个请求登录数据包
- 参数.一：pSt_ClientInfo
+函数名称：P2XPProtocol_Parse_Connect
+函数功能：请求连接到指定地址
+ 参数.一：lpszMsgBuffer
   In/Out：In
-  类型：数据结构指针
+  类型：常量字符指针
   可空：N
-  意思：输入你构造的客户端信息
- 参数.二：pSt_UserLogin
+  意思：输入要解析的缓冲区
+ 参数.二：nMsgLen
   In/Out：In
-  类型：数据结构指针
-  可空：N
-  意思：输入你构造的客户端用户信息
- 参数.三：ptszMsgBuffer
-  In/Out：Out
-  类型：字符指针
+  类型：整数型
   可空：N
-  意思：导出组好包的数据
- 参数.四：pInt_Len
+  意思：输入缓冲区大小
+ 参数.三：pSt_P2XPPeer
   In/Out：In
-  类型：整数型指针
+  类型：数据结构指针
   可空：N
-  意思：导出组好包的数据长度
- 参数.五：wPacketSerial
-  In/Out：In
-  类型：无符号短整数型
-  可空：Y
-  意思：设置这个包的序列,可以不设置,服务器返回的包序列也是这个
+  意思：输出解析后的节点信息
 返回值
   类型：逻辑型
-  意思：是否成功构造
+  意思：是否成功
 备注：
 *********************************************************************/
-extern "C" BOOL P2XPProtocol_UserMsg_RequestLogin(XENGINE_P2XPPEER_PROTOCOL *pSt_ClientInfo, XENGINE_PROTOCOL_USERAUTH *pSt_UserLogin, CHAR *ptszMsgBuffer, int *pInt_Len, WORD wPacketSerial = 0);
+extern "C" BOOL P2XPProtocol_Parse_Connect(LPCTSTR lpszMsgBuffer, int nMsgLen, XENGINE_P2XPIO_PROTOCOL* pSt_IOProtocol);
+/************************************************************************/
+/*                        打包协议导出                                  */
+/************************************************************************/
 /********************************************************************
-函数名称：P2XPProtocol_UserMsg_RequestConnect
-函数功能：请求连接到一个网络服务
- 参数.一：pSt_ClientIONet
+函数名称：P2XPProtocol_Parse_Login
+函数功能：登录解析函数
+ 参数.一：lpszMsgBuffer
   In/Out：In
-  类型：数据结构指针
-  可空：N
-  意思：输入你构造的P2XP网络IO结构
- 参数.二：ptszMsgBuffer
-  In/Out：Out
-  类型：字符指针
+  类型：常量字符指针
   可空：N
-  意思：导出组好包的数据
- 参数.三：pInt_Len
+  意思：输入要解析的缓冲区
+ 参数.二：nMsgLen
   In/Out：In
-  类型：整数型指针
+  类型：整数型
   可空：N
-  意思：导出组好包的数据长度
- 参数.四：wPacketSerial
+  意思：输入缓冲区大小
+ 参数.三：pSt_P2XPPeer
   In/Out：In
-  类型：无符号短整数型
-  可空：Y
-  意思：设置这个包的序列,可以不设置,服务器返回的包序列也是这个
+  类型：数据结构指针
+  可空：N
+  意思：输出解析后的节点信息
 返回值
   类型：逻辑型
-  意思：是否成功构造
+  意思：是否成功
 备注：
 *********************************************************************/
-extern "C" BOOL P2XPProtocol_UserMsg_RequestConnect(XENGINE_P2XPIO_PROTOCOL *pSt_ClientIONet, CHAR *ptszMsgBuffer, int *pInt_Len, WORD wPacketSerial = 0);
+extern "C" BOOL P2XPProtocol_Packet_Common(TCHAR* ptszMsgBuffer, int* pInt_MsgLen, int nCode = 0, LPCTSTR lpszMsgBuffer = NULL);
 /********************************************************************
-函数名称：P2XPProtocol_UserMsg_RequestLan
-函数功能：请求同步局域网列表封装函数
- 参数.一：ptszMsgBuffer
+函数名称：P2XPProtocol_Packet_Lan
+函数功能：响应同步局域网地址列表
+ 参数.一：pppSt_ListClients
+  In/Out：In
+  类型：三级指针
+  可空：N
+  意思：输入局域网地址信息列表
+ 参数.二：nListCount
+  In/Out：In
+  类型：整数型
+  可空：N
+  意思：局域网地址列表个数
+ 参数.三：ptszMsgBuffer
   In/Out：Out
   类型：字符指针
   可空：N
-  意思：导出封装好的数据包
- 参数.二：pInt_Len
-  In/Out：Out
-  类型：整数型
+  意思：导出封装好的缓冲区
+ 参数.四：pInt_Len
+  In/Out：In/Out
+  类型：整数型指针
   可空：N
-  意思：导出数据包长度
- 参数.二：bWlan
-  In/Out：In
-  类型：逻辑型
-  可空：Y
-  意思：请求公网下地址列表还是局域网下地址列表,默认局域网
- 参数.二：wPacketSerial
-  In/Out：In
-  类型：无符号短整数型
-  可空：Y
-  意思：输入这个封包的序列号
+  意思：输入你的缓冲区大小,输出缓冲区真实大小
 返回值
   类型：逻辑型
   意思：是否成功
 备注：
 *********************************************************************/
-extern "C" BOOL P2XPProtocol_UserMsg_RequestLan(CHAR *ptszMsgBuffer, int *pInt_Len, BOOL bWlan = FALSE, WORD wPacketSerial = 0);
+extern "C" BOOL P2XPProtocol_Packet_Lan(XENGINE_P2XPPEER_PROTOCOL*** pppSt_ListClients, int nListCount, TCHAR* ptszMsgBuffer, int* pInt_Len);
 /********************************************************************
-函数名称：P2XPProtocol_UserMsg_RequestHeartBeat
-函数功能：封装一个心跳请求的包
- 参数.一：ptszMsgBuffer
+函数名称：P2XPProtocol_Packet_User
+函数功能：响应用户查询用户信息的请求协议封包函数
+ 参数.一：pSt_PeerInfo
+  In/Out：In
+  类型：数据结构指针
+  可空：N
+  意思：输入获取到的用户信息
+ 参数.二：ptszMsgBuffer
   In/Out：Out
   类型：字符指针
   可空：N
   意思：导出封装好的缓冲区
- 参数.二：pInt_Len
-  In/Out：Out
+ 参数.三：pInt_Len
+  In/Out：In/Out
   类型：整数型指针
   可空：N
-  意思：导出缓冲区长度
+  意思：输入你的缓冲区大小,输出缓冲区真实大小
 返回值
   类型：逻辑型
   意思：是否成功
 备注：
 *********************************************************************/
-extern "C" BOOL P2XPProtocol_UserMsg_RequestHeartBeat(CHAR *ptszMsgBuffer, int *pInt_Len);
+extern "C" BOOL P2XPProtocol_Packet_User(XENGINE_P2XPPEER_PROTOCOL* pSt_PeerInfo, TCHAR* ptszMsgBuffer, int* pInt_Len);

XEngine_Source/XEngine_P2XPComponents/XEngine_P2XPProtocol/P2XPProtocol_Error.h

@@ -10,17 +10,5 @@
 //	Purpose:	P2XP协议构造分析器错误码导出
 //	History:
 *********************************************************************/
-/************************************************************************/
-/*                  用户协议错误表                                      */
-/************************************************************************/
-#define ERROR_NETENGINE_P2XP_PROTOCOL_USERMSG_REQUESTLOGIN_PARAMENT 0xB0F1010 //参数错误
-#define ERROR_NETENGINE_P2XP_PROTOCOL_USERMSG_REQUESTHB_PARAMENT 0xB0F1020    //参数错误
-#define ERROR_NETENGINE_P2XP_PROTOCOL_USERMSG_REQUESTIONET_PARAMENT 0xB0F1030 //参数错误
-#define ERROR_NETENGINE_P2XP_PROTOCOL_USERMSG_REQUESTLIST_PARAMENT 0xB0F1040
-/************************************************************************/
-/*                  服务协议错误表                                      */
-/************************************************************************/
-#define ERROR_NETENGINE_P2XP_PROTOCOL_SVRMSG_RESPONSEJSON_PARAMENT 0xB0F2000  //参数错误
-#define ERROR_NETENGINE_P2XP_PROTOCOL_SVRMSG_RESPONSELAN_PARAMENT 0xB0F2010   //参数错误
-#define ERROR_NETENGINE_P2XP_PROTOCOL_SVRMSG_RESPONSELAN_LEN 0xB0F2011        //提供的缓冲区大小不够
-#define ERROR_NETENGINE_P2XP_PROTOCOL_SVRMSG_REPQUERYUSER_PARAMENT 0xB0F2020  //参数错误
+#define ERROR_XENGINE_P2XP_PROTOCOL_PARAMENT 0xB0F1001
+#define ERROR_XENGINE_P2XP_PROTOCOL_PARSE 0xB0F1002