知识大全 Custom Channel Sinks被我征服了

Posted 2022-07-18 消息

篇首语：道德可以弥补能力的不足，能力却难以掩盖道德的缺陷。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 Custom Channel Sinks被我征服了相关的知识，希望对你有一定的参考价值。

Custom Channel Sinks被我征服了 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

　　这两天由于公司业务的需要需要将一项服务放到互联网上采用的框架 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之前
　　上面这些内容看起来很简单但要把它作出来还需要很多工作你确实可以通框架轻松实现分布式应用程序的功能但是如果你要自定义其中的部分功能事情就不象想象的那么容易了(至少不是几个继承能够解决问题的)

　　开始艰难之旅

　　要实现自定义链节首先要实现以下几个接口 IMessageSink IClientChannelSink IServerChannelSink IClientSinkProvider IServerSinkProvider虽然我们处理的只是加密问题但是框架中找不到一个链节处理的基类所以下面的路会比较艰难
　　IMessageSink     属性         NextSink 获取处理链中的下一个链节    方法         AsyncProcessMessage 异步处理获取的消息        SyncProcessMessage 同步处理获取得消息
　　IClientChannelSink     属性         NextChannelSink 获取客户端处理链节中的下一个链节    方法         AsyncProcessRequest 在当前的处理链节中请求异步数据处理        AsyncProcessResponse 在当前的处理链节中请求异步回应        GetRequestStrean 返回字节流到即将被序列化的消息上        ProcessMessage 从当前的处理链节中请求消息处理
　　IServerChannelSink     属性         NextChannelSink 获取服务器端处理链节中的下一个链节    方法         AsyncProcessResponse 异步处理回应消息        GetResponseStream 返回流到即将被序列化的消息上        ProcessMessage 从当前链节请求消息处理
　　在上面几个接口中最重要的是IMessageSink 这个接口的同步处理与异步处理都要实现以下是伪代码 public __gc class BaseSink : IMessageSinkPrivate:    IMessageSink* nextMessageSink;public://执行异步处理IMessageCtrl* IMessageSink::AsyncProcessMessage(IMesage* msg IMessageSink* replaySink)    //处理发送的消息对消息的加密处理在这里进行    //创建返回的MessageSink replysink 由replaysink 来处理返回的消息该线程不必等待消息的回应    return this >nextMessageSink AsyncProcessMessage(msg replysink );//执行同步处理IMessage* IMessageSink::SyncProcessMessage(IMessage* msg)    //处理发送的消息对消息的加密处理在这里进行    IMessage* resMsg = this >nextMessageSink SyncProcessMessage(msg);//获取返回的消息线程在这里等待回应    //处理返回的消息并返回处理后的消息对消息的解密处理在这里进行__property IMessageSink* IMessageSink::get_NextSink()    return this >nextMessageSink;
　　在这里万里长征终于走出了坚实的第一步了攻克了IMessageSink 相信后面的那几个接口会很好搞定
　　作为 Net框架中强大的一部分 Channel Sink不可能就了了几字可以说完第二步如何走请看Custom Channel Sink征服之旅二

cha138/Article/program/net/201311/11395