登录模块加载中...
会员投稿 投稿指南 今天是:
打印本页 | 关闭窗口 | 双击滚屏 您的位置首页>>网页制作学习园地>>NET教程>>Asp.Net开发>>.NET可复用TCP通信层之消息分派器组件
.NET可复用TCP通信层之消息分派器组件
来源:不详 ‖ 作者:佚名 ‖ 点击: ‖ 时间:13-12-20 11:49:06 ‖ 【 】‖ 我要投稿
主要讲到了Tcp通信层中的核心组件――Tcp组件的实现,Tcp组件是整个通信层的消息驱动源,甚至,可以将Tcp组件看作是我们整个服务器系统的消息驱动源,消息处理过程从这里引发。类似的消息驱动源还有发布的WebService接口、Remoting接口等。今天我们需要关注的是Tcp通信层中的“中央”组件――消息分派器组件ITcpReqStreamDispatcher,大家已经从前文的组件关系图中看到了消息分派器的大致位置和作用了,它是Tcp通信组件和消息处理器之间的“桥梁”。我们再对前文描述的通信层组件之间关系的一段话回顾一下:
  “当网络(Tcp)组件从某个Tcp连接上接收到一个请求时,会将请求转发给消息分派器,消息分派器通过IDataStreamHelper组件获取请求消息的类型,然后根据此类型要求处理器工厂创建对应类型的请求处理器,请求处理器处理请求并返回结果。接下来再由网络组件把结果返回给终端用户。在消息分派器进行请求消息分派之前,可能涉及一系列的操作,像消息加密/解密、消息分裂/重组、消息验证等。”
  上面的描述中已经体现出了消息分派器的主要职责,在理解了消息分派器职责的基础上,我们可以进一步来看看消息分派器的定义和实现了。  
  二.消息分派器组件
  1.消息分派器组件接口的定义
  消息分派器的接口很简单:
    public interface ITcpReqStreamDispatcher : IReqestStreamDispatcher 
    {        
        ArrayList DealRequestMessage(RequestData requestData ,out byte[] leftData ,ref RequestValidation validation) ;//同步回复
        bool      DealRequestMessage(RequestData requestData , NetworkStream userStream ,out byte[] leftData) ; //异步回复        
    }
  这个接口只有两个方法,第二个方法用于异步发送回复(即绕开Tcp组件发送回复),该方法的核心部分可以由第一个方法实现,我们把注意力放在第一个方法上,而Tcp组件与消息分派器进行交互的也正是第一个方法。我先解释一下这个方法的几个参数的含义:
  RequestData是对请求消息的封装:
    //从网络接收到的原始数据的封装
    public class RequestData
    {
        public int  ConnectID = 0 ;
        public bool IsFirstMsg = false ; //标志是否为连接建立后的第一条消息
        public byte[] Buff     = null ; //接收数据缓冲区 ,可能其头部包含上次未处理完的数据
        public int ValidCount  = 0 ; //缓冲区中有效字节的个数 >= 本次接收的字节数        
    }
  前面已经提到过,ConnectID用于标志每一个Tcp连接,IsFirstMsg用于表明是否为tcp连接建立后的第一个消息,因为我们可能需要对第一个消
|<< << < 1 2 3 4 5 6 7 8 9 > >> >>|
加入收藏:  加入收藏夹  | 发送给好友:  发送给好友
责任编辑:admin
  • 上一篇:网页弹出窗口应用总结
  • 下一篇:无
  • 相关文章列表
    请文明参与讨论,禁止漫骂攻击。  
    网友评论