网狐棋牌游戏平台服务器架构设计分析

男娘i 2022-03-20 01:38 326阅读 0赞

**基本设计概念和处理流程**

*调用模型*

模仿COM组件接口模式，利用面向对象思想多态性polymorphism，调用方保存着被调用方的基础接口指针(interface or sink钩子)（Pure Virtual Function），调用方直接调用接口指针内声明的纯虚方法，而此纯虚函数的具体逻辑由该接口的派生类实现。

示意图:

![image001.gif][]

*基于事件驱动的数据处理模型*

在系统功能设计中，针对网络事件SocketEvent、数据库事件DatabaseEvent、定时器事件TimerEvent……的数据处理，建立数据队列服务QueueService，为每一队列建立多个子线程QueueServiceThread处理。数据队列服务提供添加事件数据的方法AddToQueue，设置数据队列服务钩子SetQueueServiceSink，由数据队列服务钩子QueueServiceSink执行具体逻辑事件的数据处理。  
示意图:

![image002.gif][]  
再者，根据网络、数据库等特定功能，构建网络、数据库等管理服务，实现数据队列服务钩子QueueServiceSink方法，调度事件数据执行外部处理接口，外部处理接口具体由二次开发用户实现。

示意图:

![image003.gif][]

*事件数据设计*

![Event.gif][]

*软件体系结构（架构 Architecture）设计*

![image004.gif][]

*功能模块划分*

![FrameWork.gif][]

*数据队列服务QueueService模块设计*

基本设计概念

建立一个内存链表，保存事件数据，对外部提供方法（向链表添加事件数据并通知线程，同时启动多个处理线程，从数据链表里获取事件数据，执行外部钩子方法进行处理。线程事件通知采用完成端口技术。

类与接口设计

![22.jpg][]

<table> 
 <tbody> 
 <tr> 
 <td>COM接口</td> 
 <td>接口名</td> 
 <td>接口基类</td> 
 <td>接口实现类</td> 
 </tr> 
 <tr> 
 <td>A</td> 
 <td>队列引擎</td> 
 <td>IQueueServiceEngine</td> 
 <td>CQueueServiceHelper</td> 
 </tr> 
 <tr> 
 <td>B</td> 
 <td>事件服务</td> 
 <td>IEventService</td> 
 <td>CEventServiceHelper</td> 
 </tr> 
 <tr> 
 <td>C</td> 
 <td>网络引擎</td> 
 <td>ITCPSocketEngine</td> 
 <td>CTCPSocketEngineHelper</td> 
 </tr> 
 <tr> 
 <td>D</td> 
 <td>定时器引擎</td> 
 <td>ITimerEngine</td> 
 <td>CTimerEngineHelper</td> 
 </tr> 
 <tr> 
 <td>E</td> 
 <td>数据库操作</td> 
 <td>IDataBase</td> 
 <td>CDataBaseHelper</td> 
 </tr> 
 <tr> 
 <td>F</td> 
 <td>数据库引擎</td> 
 <td>IDataBaseEngine</td> 
 <td>CDataBaseEngineHelper</td> 
 </tr> 
 <tr> 
 <td>I</td> 
 <td>调度引擎</td> 
 <td>IAttemperEngine</td> 
 <td>CAttemperEngineHelper</td> 
 </tr> 
 <tr> 
 <td>G</td> 
 <td>服务引擎</td> 
 <td>IServiceEngine</td> 
 <td>CServiceEngineHelper</td> 
 </tr> 
 <tr> 
 <td>K</td> 
 <td>异步引擎</td> 
 <td>IAsynchronismEngine</td> 
 <td>CAsynchronismEngineHelper</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>自动清理参数辅助类</td> 
 <td>&nbsp;</td> 
 <td>CAutoCleanParameters</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>自动关闭记录集辅助类</td> 
 <td>&nbsp;</td> 
 <td>CAutoCloseRecord</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>断开数据库连接辅助类</td> 
 <td>&nbsp;</td> 
 <td>CAutoCloseDataBase</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
 <tr> 
 <td>内部接口</td> 
 <td>类别</td> 
 <td>接口</td> 
 <td>功能</td> 
 <td>继承</td> 
 <td>实现类</td> 
 </tr> 
 <tr> 
 <td></td> 
 <td>数据队列事件 (非组件实现)</td> 
 <td>CQueueServiceEvent (IQueueService、CThreadLock)</td> 
 <td>设置接口、发送通知事件</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td></td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>数据库错误接口</td> 
 <td>IADOError</td> 
 <td>错误类型与描述</td> 
 <td>: public IUnknownEx</td> 
 <td>CADOError</td> 
 </tr> 
 <tr> 
 <td>E</td> 
 <td>数据库连接接口</td> 
 <td>IDataBase</td> 
 <td>数据库操作类</td> 
 <td>: public IUnknownEx</td> 
 <td>CDataBase</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>数据库钩子接口</td> 
 <td>IDataBaseSink</td> 
 <td>启动关闭数据库模块、数据操作处理</td> 
 <td>: public IUnknownEx</td> 
 <td></td> 
 </tr> 
 <tr> 
 <td>F</td> 
 <td>数据库引擎接口</td> 
 <td>IDataBaseEngine</td> 
 <td>启动停止服务、注册钩子、获取接口</td> 
 <td>: public IUnknownEx</td> 
 <td>CDataBaseEngine</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 <tr> 
 <td>A</td> 
 <td>数据队列接口</td> 
 <td>IQueueService</td> 
 <td>加入数据</td> 
 <td>: public IUnknownEx</td> 
 <td>CQueueService</td> 
 </tr> 
 <tr> 
 <td></td> 
 <td>数据队列类钩子接口</td> 
 <td>IQueueServiceSink</td> 
 <td>通知回调函数</td> 
 <td>: public IUnknownEx</td> 
 <td>CTCPSocketEngine CDataBaseEngine CAttemperEngine</td> 
 </tr> 
 <tr> 
 <td>A</td> 
 <td>队列类引擎接口</td> 
 <td>IQueueServiceEngine</td> 
 <td>开始服务、停止服务、设置接口、负荷信息</td> 
 <td>: public IUnknownEx</td> 
 <td>CQueueService</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 <tr> 
 <td>B</td> 
 <td>事件服务引擎接口</td> 
 <td>IEventService</td> 
 <td>设置句柄、设置级别、事件通知</td> 
 <td>: public IUnknownEx</td> 
 <td>CEventService</td> 
 </tr> 
 <tr> 
 <td>G</td> 
 <td>服务引擎接口</td> 
 <td>IServiceEngine</td> 
 <td>服务接口、配置接口、服务查询、功能接口</td> 
 <td>: public IUnknownEx</td> 
 <td>CServiceEngine</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 <tr> 
 <td>D</td> 
 <td>定时器引擎接口</td> 
 <td>ITimerEngine</td> 
 <td>设置定时器、删除定时器</td> 
 <td>: public IUnknownEx</td> 
 <td>CTimerEngine</td> 
 </tr> 
 <tr> 
 <td>D</td> 
 <td>定时器引擎接口</td> 
 <td>ITimerEngineManager</td> 
 <td>开始服务、停止服务、设置接口</td> 
 <td>: public IUnknownEx</td> 
 <td>CTimerEngine</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 <tr> 
 <td>C</td> 
 <td>TCP SOCKET 引擎接口</td> 
 <td>ITCPSocketEngine</td> 
 <td>发送、批量发送、关闭连接、允许群发</td> 
 <td>: public IUnknownEx</td> 
 <td>CTCPSocketEngine</td> 
 </tr> 
 <tr> 
 <td>C</td> 
 <td>TCP SOCKET 引擎管理接口</td> 
 <td>ITCPSocketEngineManager</td> 
 <td>设置接口、端口、数目、启动服务、停止服务</td> 
 <td>: public IUnknownEx</td> 
 <td>CTCPSocketEngine</td> 
 </tr> 
 <tr> 
 <td>C</td> 
 <td>连接对象回调接口</td> 
 <td>IServerSocketItemSink</td> 
 <td>应答消息、读取消息、关闭消息</td> 
 <td></td> 
 <td>CTCPSocketEngine</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>调度模块钩子接口</td> 
 <td>IAttemperEngineSink</td> 
 <td>管理接口、事件接口（定时器、数据库、网络应答读取关闭）</td> 
 <td>: public IUnknownEx</td> 
 <td></td> 
 </tr> 
 <tr> 
 <td>I</td> 
 <td>调度引擎接口</td> 
 <td>IAttemperEngine</td> 
 <td>服务管理、设置钩子、设置网络、获取接口</td> 
 <td>: public IUnknownEx</td> 
 <td>CAttemperEngine</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 <tr> 
 <td>K</td> 
 <td>异步引擎接口</td> 
 <td>IAsynchronismEngine</td> 
 <td>管理接口（启动停止服务、插入请求）、功能接口（注册钩子、取消注册）</td> 
 <td>: public IUnknownEx</td> 
 <td>CAsynchronismEngine</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>异步引擎钩子接口</td> 
 <td>IAsynchronismEngineSink</td> 
 <td>启动事件、停止事件、异步请求</td> 
 <td>: public IUnknownEx</td> 
 <td></td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 <td>&nbsp;</td> 
 </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
 <tr> 
 <td>接口实现</td> 
 <td>类别</td> 
 <td>类</td> 
 <td>引用</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>网络管理类</td> 
 <td>CTCPSocketEngine</td> 
 <td>CQueueService//队列对象 CServerSocketItemPtrArray CQueueServiceEvent//通知组件</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>调度管理类</td> 
 <td>CAttemperEngine</td> 
 <td>ITCPSocketEngine//网络引擎 IAttemperEngineSink//挂接接口CQueueService//队列对象</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>数据库对象</td> 
 <td>CDataBase</td> 
 <td>_CommandPtr//命令对象 _RecordsetPtr//记录集对象 _ConnectionPtr//数据库对象</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>数据库管理类</td> 
 <td>CDataBaseEngine</td> 
 <td>CQueueService//队列对象 IDataBaseSink//通知钩子</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>事件服务类</td> 
 <td>CEventService</td> 
 <td>设置句柄-bool SetRichEditHwnd(HWND); 设置级别-void ConfigEventService(...); 事件通知-void ShowEventNotify(...);</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>定时器引擎</td> 
 <td>CTimerEngine</td> 
 <td>CTimerThread-&gt;(公共服务)</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>异步引擎接口</td> 
 <td>CAsynchronismEngine</td> 
 <td>friend class CControlWnd; friend class CMessageThread; CControlWnd//控制窗口 CThreadLock//线程同步 CDataStorage//数据存储 CMessageThread//线程组件</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>服务引擎</td> 
 <td>CServiceEngine</td> 
 <td>CTimerEngine定时器引擎 CDataBaseEngine数据库引擎 CAttemperEngine调度引擎 CTCPSocketEngine&nbsp;&nbsp;网络引擎 CAsynchronismEngine 异步引擎</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>数据队列类</td> 
 <td>CQueueService</td> 
 <td>CQueueServiceThread-&gt;(公共服务)</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>ADO 错误类</td> 
 <td>CADOError</td> 
 <td>: public IADOError</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>&nbsp;</td> 
 <td>　</td> 
 <td>&nbsp;</td> 
 </tr> 
 </tbody> 
</table>

*内部类*:

<table> 
 <tbody> 
 <tr> 
 <td>意义</td> 
 <td>类</td> 
 <td>功能</td> 
 <td>继承</td> 
 <td>引用</td> 
 </tr> 
 <tr> 
 <td>TCP SOCKET 类</td> 
 <td>CServerSocketItem</td> 
 <td>SOCK对象和操作、完成端口、加密解密等</td> 
 <td>　</td> 
 <td>　</td> 
 </tr> 
 <tr> 
 <td>数据队列事件</td> 
 <td>CQueueServiceEvent</td> 
 <td>事件通知，接口设置管理</td> 
 <td>　</td> 
 <td>代码级引用</td> 
 </tr> 
 <tr> 
 <td>窗口控制类</td> 
 <td>CControlWnd</td> 
 <td>//消息映射 OnAsynRequest//请求消息</td> 
 <td>: public CWnd</td> 
 <td>　</td> 
 </tr> 
 <tr> 
 <td>应答线程对象</td> 
 <td>CSocketAcceptThread</td> 
 <td>运行函数（WSAAccept）</td> 
 <td>: public CServiceThread</td> 
 <td>　</td> 
 </tr> 
 <tr> 
 <td>读写线程类</td> 
 <td>CServerSocketRSThread</td> 
 <td>运行函数（GetQueuedCompletionStatus） 参数CServerSocketItem *</td> 
 <td>: public CServiceThread</td> 
 <td>　</td> 
 </tr> 
 <tr> 
 <td>检测线程类</td> 
 <td>CSocketDetectThread</td> 
 <td>运行函数（非阻塞）、检测m_dwTickCount</td> 
 <td>: public CServiceThread</td> 
 <td>CTCPSocketEngine*//管理指针</td> 
 </tr> 
 <tr> 
 <td>队列线程类</td> 
 <td>CQueueServiceThread</td> 
 <td>运行函数（GetQueuedCompletionStatus） 参数CQueueService *</td> 
 <td>: public CServiceThread</td> 
 <td>　</td> 
 </tr> 
 <tr> 
 <td>消息线程</td> 
 <td>CMessageThread</td> 
 <td>运行函数（for CAsynchronismEngineSinkArray*）</td> 
 <td>: public CServiceThread</td> 
 <td>CAsynchronismEngine*//异步引擎</td> 
 </tr> 
 <tr> 
 <td>定时器线程</td> 
 <td>CTimerThread</td> 
 <td>运行函数（for CTimerItemPtr-&gt;GetCount();）</td> 
 <td>: public CServiceThread</td> 
 <td>CTimerEngine*//定时器引擎</td> 
 </tr> 
 <tr> 
 <td>　</td> 
 <td>　</td> 
 <td>　</td> 
 <td>　</td> 
 <td>　</td> 
 </tr> 
 <tr> 
 <td>数据存储类</td> 
 <td>CDataStorage</td> 
 <td>内存的管理</td> 
 <td>　</td> 
 <td>公共服务(&nbsp;dllimport class )</td> 
 </tr> 
 <tr> 
 <td>线程对象类</td> 
 <td>CServiceThread</td> 
 </tr> 
 </tbody> 
</table>

[image001.gif]: /images/20220320/aceaeb57cf234d86b6147ac3f5a20b4b.png
[image002.gif]: /images/20220320/6749907f9ce34fd09d9b5a0ef4c114a6.png
[image003.gif]: /images/20220320/037781895b714ab6b00b8cf85894dba1.png
[Event.gif]: /images/20220320/2dc4d9ca0e284b748ed943f448508bdd.png
[image004.gif]: /images/20220320/b89bf71ce7504734b5032f248168142d.png
[FrameWork.gif]: /images/20220320/0e0e9acff75e4c67ab192906f59f3784.png
[22.jpg]: /images/20220320/c8ae07acd8c54b588f16f0a3c3d28b84.png