121 lines
3.3 KiB
C++
121 lines
3.3 KiB
C++
#ifndef _SESSION_HANDLE_H_
|
||
#define _SESSION_HANDLE_H_
|
||
/*****************************************************************
|
||
Copyright (c) 2021, 上海漫方网络科技有限公司
|
||
All rights reserved
|
||
|
||
创建日期： 2021年04月28日 14时01分
|
||
文件名称： CrossDataHandle.h
|
||
说 明： 跨服引擎分发消息
|
||
|
||
当前版本： 1.00
|
||
作 者：
|
||
概 述： 跨服引擎分发消息类
|
||
|
||
*****************************************************************/
|
||
using namespace wylib::sync::lock;
|
||
|
||
class CCrossServerManager;
|
||
class CCrossServer;
|
||
|
||
class ISessionRequestHost
|
||
{
|
||
public:
|
||
/*
|
||
* Comments: 分配数据包
|
||
* Param const jxSrvDef::INTERSRVCMD nCmd:
|
||
* @Return CDataPacket&:
|
||
* @Remark:
|
||
*/
|
||
virtual CDataPacket& AllocDataPacket(const jxSrvDef::INTERSRVCMD nCmd) = 0;
|
||
|
||
/*
|
||
* Comments: 刷新数据包到发送队列
|
||
* Param CDataPacket &packet
|
||
* @Return void:
|
||
* @Remark:
|
||
*/
|
||
virtual void FlushDataPacket(CDataPacket &packet) = 0;
|
||
|
||
|
||
};
|
||
|
||
using namespace jxSrvDef;
|
||
class CCrossDataHandle :public ISessionRequestHost
|
||
{
|
||
friend class CCrossServer;
|
||
protected:
|
||
//VOID ProcessRecvBuffers(PDATABUFFER pDataBuffer);
|
||
VOID DispatchRecvMsg(CDataPacketReader & reader);
|
||
|
||
//VOID SendKeepAlive();
|
||
|
||
//实现虚接口
|
||
VOID OnPacket(const jxSrvDef::INTERSRVCMD nCmd, CDataPacketReader &inPacket);
|
||
public:
|
||
CCrossDataHandle( );
|
||
~CCrossDataHandle();
|
||
|
||
void SetParam(CCrossServer *pSessionSrv, bool isSessonConnect );
|
||
|
||
//获取服务器的id
|
||
inline int GetServerId()
|
||
{
|
||
return m_nSelfServerId;
|
||
}
|
||
|
||
/*
|
||
* Comments: 处理来自逻辑服务器的请求传送到目标服务器消息
|
||
* Param CatchDefaultPacket:
|
||
* Param & inPacket:
|
||
* @Return VOID:
|
||
* @Remark:
|
||
*/
|
||
VOID CatchRequestTransmit(CDataPacketReader &inPacket) {};
|
||
|
||
/*
|
||
* Comments: 收到战区的数据
|
||
* Param CDataPacketReader & inPacket:
|
||
* @Return VOID:
|
||
* @Remark:
|
||
*/
|
||
VOID CatchGroupMessage(CDataPacketReader &inPacket) {};
|
||
|
||
|
||
// VOID BroadcastMessage2Logic(CDataPacketReader &inPacket);
|
||
|
||
VOID BroadcastMessage2Logic(const INT_PTR nServerIndex, LPCSTR sMsg, const size_t dwSize);
|
||
/*
|
||
* Comments: 保存跨服排行榜
|
||
* Param CDataPacketReader & inPacket:
|
||
* @Return VOID:
|
||
* @Remark:
|
||
*/
|
||
VOID CatchSaveCsRank(CDataPacketReader &inPacket) {};
|
||
|
||
/*
|
||
* Comments: 获取跨服排行榜
|
||
* Param CDataPacketReader & inPacket:
|
||
* @Return VOID:
|
||
* @Remark:
|
||
*/
|
||
VOID CatchLoadCsRank(CDataPacketReader &inPacket) {};
|
||
|
||
public:
|
||
|
||
static const size_t MaxSSDataSize = 4096;//向会话服务器发送的单个数据包大小的最大值
|
||
static const size_t MaxForwardLogicDataSize = 40960; // 最大数据包为40k
|
||
char *m_pForwardDataBuff; // 公共逻辑服务器SessionClient用于转发公共服务器消息的Buff，长度固定MaxForwardLogicDataSize
|
||
|
||
private:
|
||
int m_nSelfServerId; //自身的服务器ID,用于数据转发
|
||
CCrossServer* m_pSSServer; //所属会话服务器
|
||
TICKCOUNT m_dwDisconnectedTick;//断开连接的时间
|
||
char m_sTrServerIndex[24] ; //格式化的服务器的index，用于连接的时候快速计算
|
||
bool m_bIsCrossSession; //是否是跨服的会话传输的client，跨服的会话有些东西要特殊处理下
|
||
};
|
||
|
||
|
||
#endif
|
||
|