这两天由于公司业务的需要需要将一项服务放到互联网上采用的框架 remoting在使用上很简单功能也很强大是开发分布式应用程序的首选但remoting框架在传输数据时并没有对数据进行加密处理和身份认真所以这让我有了数据安全性的担心
但框架确实很强大强大到可以让你自定义数据传送的方式所以将安全策略加入到自定义的传送中是一个不错的选择
但是这个自定义传送方式让我研究了天时间我将所有的接口定义都打印出来将在网上找到的一篇关于Custom Channel Sinks的资料也打印了出来一句一句分析最后在今天下班的路上我突然觉得我完全理解了Custom Channel Sink的工作流程知道了如何将安全策略加入到Custom Channel Sink中
在以后几天中我会把原理写在我的blog上希望路过的朋友多多指教
原理
当你调用远程对象时你并没有直接引用它你引用的是远程对象在本地的代理代理对象在处理上很像远程对象它能够将基于栈的方法调用转换成消息将其发送给远程对象为了让消息发送给远程对象代理对象要使用到Sink Chain(可以看成是数据处理链)首先代理对象会调用第一个链节将数据传给它第一个链节获取数据后对数据做进行处理然后再将数据传递给下一个链接以此类推在处理链中有一个链节是formatter sink(格式处理链节)其功能是将消息数据转换为stream(流)之所以要在在格式链节处理数据之后再将数据传递给下一个链节进行处理是因为在这个节点消息已经不再和数据类型相关此刻的数据表现形势只是二进制字节流(我们可以对它做任何处理对吧)最后一个链节是Transports Sink它的功能是将数据发送到服务器并等待回应当它收到回应后它会将数据传递前一个链节直到最开始的那个链节将数据传递给代理对象
当数据发送到服务器端后服务器端也有一个Sink Chain它的节点与客户端上的节点一致只是顺序相反在服务器上处理数据的第一个节点是Transport Sink数据沿着Sink Chain传递到真正的远程数据处理对象
客户端代理对象 >formatter sink >transport sink
服务器端transport sink > formatter sink > 远程目标对象
在这个处理链中我们可以加入自定义的链节加入自定义链节的目的很多而我所需要的是保证数据在网络上传输的安全性在上面我们已经意识到当消息经过formatter sink处理后就以字节流的形式体现而对字节的加密处理对程序员来说是再简单不过的事情所以我要做的就是在客户端将加密处理链节加到formatter sink之后在服务器端将解密处理链节加到formatter sink之前
上面这些内容看起来很简单但要把它作出来还需要很多工作你确实可以通 框架轻松实现分布式应用程序的功能但是如果你要自定义其中的部分功能事情就不象想象的那么容易了(至少不是几个继承能够解决问题的)
开始艰难之旅
要实现自定义链节首先要实现以下几个接口
IMessageSinkIClientChannelSinkIServerChannelSinkIClientSinkProviderIServerSinkProvider
虽然我们处理的只是加密问题但是 框架中找不到一个链节处理的基类所以下面的路会比较艰难
IMessageSink
属性
NextSink获取处理链中的下一个链节
方法
AsyncProcessMessage异步处理获取的消息
SyncProcessMessage同步处理获取得消息
IClientChannelSink
属性
NextChannelSink获取客户端处理链节中的下一个链节
方法
AsyncProcessRequest在当前的处理链节中请求异步数据处理
AsyncProcessResponse在当前的处理链节中请求异步回应
GetRequestStrean返回字节流到即将被序列化的消息上
ProcessMessage从当前的处理链节中请求消息处理
IServerChannelSink
属性
NextChannelSink获取服务器端处理链节中的下一个链节
方法
AsyncProcessResponse异步处理回应消息
GetResponseStream返回流到即将被序列化的消息上
ProcessMessage从当前链节请求消息处理
在上面几个接口中最重要的是IMessageSink这个接口的同步处理与异步处理都要实现以下是伪代码
public __gc class BaseSink : IMessageSink
{
Private:
IMessageSink* nextMessageSink;
public:
//执行异步处理
IMessageCtrl* IMessageSink::AsyncProcessMessage(IMesage* msg IMessageSink* replaySink)
{
//处理发送的消息对消息的加密处理在这里进行
//创建返回的MessageSinkreplysink由replaysink来处理返回的消息该线程不必等待消息的回应
return this>nextMessageSinkAsyncProcessMessage(msg replysink);
}
//执行同步处理
IMessage* IMessageSink::SyncProcessMessage(IMessage* msg)
{
//处理发送的消息对消息的加密处理在这里进行
IMessage* resMsg = this>nextMessageSinkSyncProcessMessage(msg);//获取返回的消息线程在这里等待回应
//处理返回的消息并返回处理后的消息对消息的解密处理在这里进行
}
__property IMessageSink* IMessageSink::get_NextSink()
{
return this>nextMessageSink;
}
}
在这里万里长征终于走出了坚实的第一步了攻克了IMessageSink相信后面的那几个接口会很好搞定
作为Net框架中强大的一部分Channel Sink不可能就了了几字可以说完第二步如何走请看Custom Channel Sink征服之旅二
附如果本文有遗漏的地方请指正谢谢联系QQ
