实现一个压缩Remoting传输数据的Sink:CompressionSink （转载）

在前两讲《初探.Net Remoting服务端 Loading Remtoing配置内容的过程 》《初探.Net Remoting客户端 Loading Remtoing配置内容的过程 》中,我已经分析了Remoting 的Sink机制，接下来，就提供一个具体的范例：CompressionSink（原始SourceCode源于Advanced .Net Remoting 1StED）。 CompressionSink通过在客户端和服务端各自插入一个数据压缩-解压缩的Sink。目的是希望减少大数据量传递对网络带宽的占用，提高传输效率。下载SourceCode ,BTW,这个压缩Sink相对比较稳定，大家可以在各自的项目中放心使用。:-)

详细设计：
提供一个Assembly：　CompressionSink.dll
它包括：
客户端：
CompressionSink.CompressionClientSinkProvider类和CompressionSink.CompressionClientSink类
服务端：
CompressionSink.CompressionServerSinkProvider类和CompressionSink.CompressionServerSink类
压缩类：CompressionHelper
压缩内核：NZipLib库。

客户端的配置文件 ：

<?xml version="1.0" encoding="utf-8" ?>

<configuration>

<system.runtime.remoting>

<application>

<channels>

<channel ref="http">

<clientProviders>

<formatter ref="soap" />

<provider type="CompressionSink.CompressionClientSinkProvider, CompressionSink" />

</clientProviders>

</channel>

</channels>

<client>

<wellknown type="Service.SomeSAO, Service" url="http://localhost:5555/SomeSAO.soap" />

</client>

</application>

</system.runtime.remoting>

</configuration>

服务端的配置文件 ：

<?xml version="1.0" encoding="utf-8" ?>

<configuration>

<system.runtime.remoting>

<application>

<channels>

<channel ref="http" port="5555">

<serverProviders>

<provider type="CompressionSink.CompressionServerSinkProvider, CompressionSink" />

<formatter ref="soap"/>

</serverProviders>

</channel>

</channels>

<service>

<wellknown mode="Singleton" type="Service.SomeSAO, Service" objectUri="SomeSAO.soap" />

</service>

</application>

</system.runtime.remoting>

</configuration>

public class CompressionClientSinkProvider: IClientChannelSinkProvider
public class CompressionClientSink: BaseChannelSinkWithProperties,
2 IClientChannelSink
3public class CompressionServerSinkProvider: IServerChannelSinkProvider
2using System;
using System.Runtime.Remoting.Channels;
using System.Runtime.Remoting.Messaging;
using System.IO;

namespace CompressionSink

 

1public class CompressionHelper
2 {
3{
11{
18{
34{
40{
43{
47 break;
48 }
49 }
50 unCompressStream.Close();
51 //modify by zendy//这个设置非常重要,否则会导致后续Sink在处理该stream时失败,,在原来的源码中就是因为没有这个处理导致程序运行失败
52 outStream.Seek(0,SeekOrigin.Begin);
53 return outStream;
54 }
55 }

BTW，这个Sink还可以扩展，比如判断需要压缩Stream的大小，如果很大，就压缩，否则不压缩（可以在responseHeaders和requestHeaders添加是否 已经压缩的标记)