81 lines
2.4 KiB
C++
81 lines
2.4 KiB
C++
#ifndef _CROSS_CLIENT_H_
|
||
#define _CROSS_CLIENT_H_
|
||
/*****************************************************************
|
||
Copyright (c) 2021, 上海漫方网络科技有限公司
|
||
All rights reserved
|
||
|
||
创建日期： 2021年04月28日 14时01分
|
||
文件名称： CrossClient.h
|
||
说 明： 数据引擎连接到跨服服务器的客户端类
|
||
|
||
当前版本： 1.00
|
||
作 者：
|
||
概 述： 数据引擎连接到跨服服务器的客户端类
|
||
|
||
*****************************************************************/
|
||
using namespace wylib::sync::lock;
|
||
|
||
class CCrossServerManager;
|
||
class CCrossServer;
|
||
|
||
using namespace jxSrvDef;
|
||
|
||
class CCrossClient
|
||
: public CCustomJXServerClientSocket,
|
||
public CCrossDataHandle
|
||
{
|
||
friend class CCrossServer;
|
||
public:
|
||
typedef CCustomJXServerClientSocket Inherited;
|
||
typedef CCrossDataHandle InHandle;
|
||
protected:
|
||
//VOID ProcessRecvBuffers(PDATABUFFER pDataBuffer);
|
||
VOID DispatchRecvMsg(CDataPacketReader & reader);
|
||
//实现虚接口
|
||
VOID OnDispatchRecvPacket(const jxSrvDef::INTERSRVCMD nCmd, CDataPacketReader &inPacket);
|
||
bool OnValidateRegData(const jxSrvDef::PSERVER_REGDATA pRegData) ;
|
||
virtual void OnRegDataValidated();
|
||
|
||
protected:
|
||
VOID OnDisconnected();
|
||
VOID OnError(INT errorCode);
|
||
//覆盖父类例行执行的函数
|
||
VOID OnRun();
|
||
//由SessionServer调用的例行执行函数
|
||
inline VOID Run(){ SingleRun(); }
|
||
|
||
protected:
|
||
|
||
//重写收 发包的函数
|
||
virtual CDataPacket& AllocDataPacket(const jxSrvDef::INTERSRVCMD nCmd)
|
||
{
|
||
return Inherited::allocProtoPacket(nCmd);
|
||
}
|
||
|
||
virtual void FlushDataPacket(CDataPacket &packet)
|
||
{
|
||
return Inherited::flushProtoPacket(packet);
|
||
}
|
||
|
||
|
||
public:
|
||
CCrossClient(){}
|
||
~CCrossClient(){}
|
||
//反馈是否可以跨平台的消息给逻辑服
|
||
void OnSendReqCommonPlatformResult(CDataPacketReader &inPacket);
|
||
|
||
private:
|
||
int nCrossSrvId;//跨服id
|
||
TICKCOUNT m_dwDisconnectedTick;//断开连接的时间
|
||
|
||
static const size_t MaxSSDataSize = 4096;//向会话服务器发送的单个数据包大小的最大值
|
||
typedef VOID (CCrossClient::*OnHandleSockPacket)(CDataPacketReader &packet);
|
||
static const size_t MaxForwardLogicDataSize = 40960; // 最大数据包为40k
|
||
//大型SQL查询语句缓冲长度
|
||
static const SIZE_T dwHugeSQLBufferSize = 1024 * 1024 * 2;
|
||
};
|
||
|
||
|
||
#endif
|
||
|