2．消息分派器组件基本元素的实现
正如在实现Tcp组件之前需要构建一些基本元素，在实现消息分派器之前也是如此，用于支持消息分派器实现的基本元素包括：IDataStreamHelper、消息分裂器、消息处理器工厂、ITcpStreamDispatcherHook等。
（1）IDataStreamHelper消息分裂器
IDataStreamHelper，前文中已经提到，IDataStreamHelper用于从请求/回复消息中提取消息的“元数据”，并提供一些辅助方法，每个特定的应用，它们对IDataStreamHelper的实现可能是不一样的。IDataStreamHelper接口定义如下：
/// ＜summary＞
/// IDataStreamHelper 通信协议的面向流辅助设施。
/// ＜/summary＞
public interface IDataStreamHelper :IStringEncoder
{
int MaxRecieveBuffSize{get ;} //接收缓冲区的大小
int MessageHeaderLength{get ;} //消息头的长度
int OffsetOfLengthField{get ;} //表示消息长度的字段在消息头中的偏移
IDataStreamHeader ParseMessageHeader(byte[] data ,int offset) ; //解析消息头
LengthTypeInHeader LengthTypeInHeader{get ;}
byte[] GetRespondWhenFailure(byte[] reqData ,ServiceFailureType failType) ; //根据服务失败类型获取失败回复消息
byte[] GetRespondWhenFailure(byte[] reqData ,string errorMsg) ;
}
/// ＜summary＞
/// StringEncoder 限定字符串编码格式
/// ＜/summary＞
public interface IStringEncoder
{
string GetStrFromStream(byte[] stream ,int offset ,int len) ;
byte[] GetBytesFromStr(string ss) ;
}
/// ＜summary＞
/// ServiceFailureType 服务失败类型
/// ＜/summary＞
public enum ServiceFailureType
{
InvalidMessge ,ParseFailure ,HandleFailure ,ServiceStopped ,ServiceIsNotExit ,ServerIsBusy
}
IDataStreamHeader即是我们所说的消息的“元数据”，如其名所示，它也是消息的“消息头”。请让我补充说明一下，依照我的经验，消息由消息头Header和消息主体Body组成，消息头用于存放消息的“元数据”等信息，而消息主体用于存放与特定请求相关的数据。消息头的长度固定，比如都是64字节或都是128字节。请求消息和回复消息公用相同格式的消息头。我们来看看消息头接口IDataStreamHeader的定义：
public interface IDataStreamHeader
{
int MessageLength {get ;set ;} //本消息长度
int TypeKey {get ;set ;} //请求的目录类型
int ServiceKey {get ;set ;} //请求类型
int ServiceItemIndex{get ;set ;} //请求细分索引
int RandomNum {get ;set ;} //用于将回复与请求一一对应起来
int Result {get ;set ;} //服务结果
string UserID {get ;set ;} //发出请求的用户编号
byte[] ToDataStream() ; //将消息头转化为流，流的长度位消息头的长度
void ToDataStream(byte[] buff ,int offset);
}
需要解释一下TypeKey、ServiceKey、ServiceItemIndex，我们实际上将服务类型分为三级，可以举个不太恰当的例子让大家有个感性的认识。比如，生活中的衣、食、住、行可以作为不同的TypeKey，而“衣”中的春装、冬装可作为ServiceKey，而“春装”中的T恤、夹克可作为ServiceItemIndex。对于服务的类型，你可以根据自己的意愿分成任意层级，但据我的经验，通常情况下，三层已经够用了。
（2）消息分裂器
前面已经多次提到消息分裂器MessageSplitter，它用于将接收缓冲区中的数据分裂成一个个完整的消息，并且把余下的非完整数据返回，其接口定义如下：
public interface IMessageSplitter
{
void Initialize(int maxBuffSize ,int headerLen ,int offSetLenField ,LengthTypeInHeader lenType) ;
ArrayList SplitRequestMsgs(byte[] buff ,int validCount , out byte[] leftData) ;//ArrayList 中每条记录都是是byte[]，表示一个完整的请求
}
//消息头中的长度是body长度还是总长度
