ESFramework介绍之(3)――消息处理器和处理器

系统 1480 0
无论是服务端还是客户端 ,都需要对接收到的消息进行处理,在 ESFramework 框架中,处理消息的组件称为消息处理器,所有的消息处理器都实现了接口 IDataDealer
ESFramework介绍之(3)――消息处理器和处理器工厂
1 public interface IDataDealer
2 {
3 NetMessageDealRequestMessage(NetMessagereqMsg);
4 }

DealRequestMessage 方法的签名我们可以看到,将 NetMessage 的主体(是字节流)解析为 IContract 对象是由消息处理器自己完成的。这也是很符合实际的,消息处理器一定能解析并处理它关心的消息,而框架和应用的其它部分不必关心。这里小结一下,最开始我们把消息解析的任务从框架下放到了应用,这里,我们又把这个任务继续下放给了消息处理器。这样,各个消息处理器只用解析自己关心的消息了,在此基础上,我们就可以把消息处理器做成插件( Addin )的形式,并实现插件的动态加载功能。
现在我们来看看消息处理器插件(又称“功能插件”)
ESFramework介绍之(3)――消息处理器和处理器工厂
/// <summary>
/// IFunAddin功能插件基础接口。
/// </summary>
public interface IFunAddin:IAddin,IDataDealer
{

}

IAddin 是插件的基础接口,在 企业级服务器设计与实现经验之插件系统基础篇 一文中已经作了简单介绍。
针对各种不同类型的消息(消息类型的不同体现为本条消息的 Header 中的 ServiceKey 不同),需要由不同的消息处理器来处理,管理 / 创建所有这些消息处理器的工厂,称为处理器工厂IDataDealerFactory。
public interface IDataDealerFactory
{
IDataDealerCreateDealer(
int requestType, int serverTypeKey); // serverTypeKey比如城市代号
}

IDataDealerFactory根据消息的类型,创建对应的处理器。 CreateDealer 方法中的第二个参数 serverTypeKey 暂时可不予关心。
前面我们已经提到了使用插件来实现消息处理器,那么 ESFramework 框架就可以提供一个基于插件的处理器工厂 FunAddinDealerFactory ,这个工厂的实现需要借助插件管理器 IAddinManagement ,关于插件管理器,可参见 企业级服务器设计与实现经验之插件系统基础篇 一文。 FunAddinDealerFactory 实现如下:
ESFramework介绍之(3)――消息处理器和处理器工厂
FunAddinDealerFactory
<!--<br><br>Code highlighting produced by Actipro CodeHighlighter (freeware)<br>http://www.CodeHighlighter.com/<br><br>--> 1 public class FunAddinDealerFactory:IDataDealerFactory
2 {
3 private IAddinManagementaddinManagement;
4
5 public FunAddinDealerFactory()
6 {
7 }
8
9 #region property
10 public IAddinManagementAddinManagement
11 {
12 set
13 {
14 this .addinManagement = value;
15 }
16 }
17 #endregion
18
19 #region IDataDealerFactory成员
20 public IDataDealerCreateDealer( int requestType, int serverTypeKey)
21 {
22 foreach (IAddinaddin in this .addinManagement.AddinList)
23 {
24 if ((addin.ServiceKey == requestType) && (addin.Enabled))
25 {
26 return (IDataDealer)addin;
27 }
28 }
29
30 return null ;
31 }
32
33 #endregion
34 }

上面讲述的是基于插件的处理器工厂,后面的文章中我们还会给出一个基于 Tcp 连接池的处理器工厂:)

有时,应用经常有这样的需要,对某种类型的消息或某个特定的消息进行拦截、截获,然后对其进行某种变形(如压缩、加密)等,这些功能将通过
Hook 机制实现, Hook 机制到底是如何发生作用的,请继续关注下文

ESFramework 介绍之( 4) 消息拦截器 INetMessageHook

上一篇: ESFramework介绍之(2)――网络通信消息NetMessage

转到: ESFramework 可复用的通信框架(序)

ESFramework介绍之(3)――消息处理器和处理器工厂


更多文章、技术交流、商务合作、联系博主

微信扫码或搜索:z360901061

微信扫一扫加我为好友

QQ号联系: 360901061

您的支持是博主写作最大的动力,如果您喜欢我的文章,感觉我的文章对您有帮助,请用微信扫描下面二维码支持博主2元、5元、10元、20元等您想捐的金额吧,狠狠点击下面给点支持吧,站长非常感激您!手机微信长按不能支付解决办法:请将微信支付二维码保存到相册,切换到微信,然后点击微信右上角扫一扫功能,选择支付二维码完成支付。

【本文对您有帮助就好】

您的支持是博主写作最大的动力,如果您喜欢我的文章,感觉我的文章对您有帮助,请用微信扫描上面二维码支持博主2元、5元、10元、自定义金额等您想捐的金额吧,站长会非常 感谢您的哦!!!

发表我的评论
最新评论 总共0条评论