化零为整WCF(8) - 消息处理(使用流数据传输文件)

素颜马尾好姑娘i 2022-02-04 14:51 128阅读 0赞

[\[索引页\]][Link 1]  
[\[源码下载\]][Link 2]

作者： [webabcd][]  
  
  
介绍  
WCF(Windows Communication Foundation) - 消息处理：使用流数据传输文件，减少内存开销。  
  
  
示例  
1、服务  
IStreamed.cs

![InBlock.gif][] using System;  
![InBlock.gif][] using System.Collections.Generic;  
![InBlock.gif][] using System.Linq;  
![InBlock.gif][] using System.Text;  
![InBlock.gif][]  
![InBlock.gif][] using System.ServiceModel;  
![InBlock.gif][] using System.IO;  
![InBlock.gif][]  
![InBlock.gif][] namespace WCF.ServiceLib.Message  
![InBlock.gif][]\{  
![InBlock.gif][] /// <summary>   
![InBlock.gif][] /// 消息契约（定义与 SOAP 消息相对应的强类型类）   
![InBlock.gif][] /// </summary>   
![InBlock.gif][] \[MessageContract\]  
![InBlock.gif][] public class FileWrapper  
![InBlock.gif][] \{  
![InBlock.gif][] /// <summary>   
![InBlock.gif][] /// 指定数据成员为 SOAP 消息头   
![InBlock.gif][] /// </summary>   
![InBlock.gif][] \[MessageHeader\]  
![InBlock.gif][] public string FilePath;  
![InBlock.gif][]  
![InBlock.gif][] /// <summary>   
![InBlock.gif][] /// 指定将成员序列化为 SOAP 正文中的元素   
![InBlock.gif][] /// </summary>   
![InBlock.gif][] \[MessageBodyMember\]  
![InBlock.gif][] public Stream FileData;  
![InBlock.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][] /// <summary>   
![InBlock.gif][] /// IStreamed接口   
![InBlock.gif][] /// </summary>   
![InBlock.gif][] \[ServiceContract\]  
![InBlock.gif][] public interface IStreamed  
![InBlock.gif][] \{  
![InBlock.gif][] /// <summary>   
![InBlock.gif][] /// 上传文件   
![InBlock.gif][] /// </summary>   
![InBlock.gif][] /// <remarks>  
![InBlock.gif][] /// 1、支持数据流传输的绑定有：BasicHttpBinding、NetTcpBinding 和 NetNamedPipeBinding   
![InBlock.gif][] /// 2、流数据类型必须是可序列化的 Stream 或 MemoryStream   
![InBlock.gif][] // /3、传递时消息体(Message Body)中不能包含其他数据，即参数中只能有一个System.ServiceModel.MessageBodyMember   
![InBlock.gif][] /// </remarks>   
![InBlock.gif][] /// <param name="fileWrapper">WCF.ServiceLib.Message.FileWrapper</param>   
![InBlock.gif][] \[OperationContract\]  
![InBlock.gif][] void UploadFile(FileWrapper fileWrapper);  
![InBlock.gif][] \}  
![InBlock.gif][]\}

Streamed.cs

![InBlock.gif][] using System;  
![InBlock.gif][] using System.Collections.Generic;  
![InBlock.gif][] using System.Linq;  
![InBlock.gif][] using System.Text;  
![InBlock.gif][]  
![InBlock.gif][] using System.ServiceModel;  
![InBlock.gif][] using System.IO;  
![InBlock.gif][]  
![InBlock.gif][] namespace WCF.ServiceLib.Message  
![InBlock.gif][]\{  
![InBlock.gif][] /// <summary>   
![InBlock.gif][] /// IStreamed类   
![InBlock.gif][] /// </summary>   
![InBlock.gif][] public class Streamed : IStreamed  
![InBlock.gif][] \{  
![InBlock.gif][] /// <summary>   
![InBlock.gif][] /// 上传文件   
![InBlock.gif][] /// </summary>   
![InBlock.gif][] /// <param name="fileWrapper">WCF.ServiceLib.Message.FileWrapper</param>   
![InBlock.gif][] public void UploadFile(FileWrapper fileWrapper)  
![InBlock.gif][] \{  
![InBlock.gif][] var sourceStream = fileWrapper.FileData;  
![InBlock.gif][]  
![InBlock.gif][] var targetStream = new FileStream(fileWrapper.FilePath,  
![InBlock.gif][] FileMode.Create,  
![InBlock.gif][] FileAccess.Write,  
![InBlock.gif][] FileShare.None);  
![InBlock.gif][]  
![InBlock.gif][] var buffer = new byte\[4096\];  
![InBlock.gif][] var count = 0;  
![InBlock.gif][]  
![InBlock.gif][] while ((count = sourceStream.Read(buffer, 0, buffer.Length)) > 0)  
![InBlock.gif][] \{  
![InBlock.gif][] targetStream.Write(buffer, 0, count);  
![InBlock.gif][] \}  
![InBlock.gif][]  
![InBlock.gif][] targetStream.Close();  
![InBlock.gif][] sourceStream.Close();  
![InBlock.gif][] \}  
![InBlock.gif][] \}  
![InBlock.gif][]\}

2、宿主  
Streamed.cs

![InBlock.gif][] using (ServiceHost host = new ServiceHost( typeof(WCF.ServiceLib.Message.Streamed)))  
![InBlock.gif][]\{  
![InBlock.gif][] host.Open();  
![InBlock.gif][]  
![InBlock.gif][] Console.WriteLine( "服务已启动(WCF.ServiceLib.Message.Streamed)");  
![InBlock.gif][] Console.WriteLine( "按<ENTER>停止服务");  
![InBlock.gif][] Console.ReadLine();  
![InBlock.gif][]  
![InBlock.gif][]\}

App.config

<?xml version="1.0" encoding="utf-8" ?>  
<configuration>  
<system.serviceModel>  
<services>  
  
  
<service name="WCF.ServiceLib.Message.Streamed" behaviorConfiguration="MessageBehavior">  
  
  
  
  
<endpoint address="Message/Streamed" binding="netTcpBinding" contract="WCF.ServiceLib.Message.IStreamed" bindingConfiguration="StreamedBindingConfiguration" />  
<endpoint address="mex" binding="mexHttpBinding" contract="IMetadataExchange" />  
<host>  
<baseAddresses>  
<add baseAddress="http://localhost:12345/Message/Streamed/"/>  
<add baseAddress="net.tcp://localhost:54321/"/>  
</baseAddresses>  
</host>  
</service>  
</services>  
<behaviors>  
<serviceBehaviors>  
<behavior name="MessageBehavior">  
  
<serviceMetadata httpGetEnabled="true" />  
<serviceDebug includeExceptionDetailInFaults="true"/>  
</behavior>  
</serviceBehaviors>  
</behaviors>  
<bindings>  
<netTcpBinding>  
  
  
  
<binding name="StreamedBindingConfiguration" transferMode="Streamed" maxReceivedMessageSize="1073741824" receiveTimeout="00:10:00" />  
</netTcpBinding>  
</bindings>  
</system.serviceModel>  
</configuration>

3、客户端  
Streamed.cs

![InBlock.gif][] using System;  
![InBlock.gif][] using System.Collections.Generic;  
![InBlock.gif][] using System.Linq;  
![InBlock.gif][] using System.Text;  
![InBlock.gif][]  
![InBlock.gif][] using System.Windows.Forms;  
![InBlock.gif][] using System.ServiceModel;  
![InBlock.gif][] using System.IO;  
![InBlock.gif][]  
![InBlock.gif][] namespace Client2.Message  
![InBlock.gif][]\{  
![InBlock.gif][] /// <summary>   
![InBlock.gif][] /// 演示Message.Streamed的类   
![InBlock.gif][] /// </summary>   
![InBlock.gif][] public class Streamed  
![InBlock.gif][] \{  
![InBlock.gif][] /// <summary>   
![InBlock.gif][] /// 流数据上传文件   
![InBlock.gif][] /// </summary>   
![InBlock.gif][] /// <param name="source">源文件地址</param>   
![InBlock.gif][] /// <param name="destination">目标路径</param>   
![InBlock.gif][] public void HelloStreamed( string source, string destination)  
![InBlock.gif][] \{  
![InBlock.gif][] try  
![InBlock.gif][] \{  
![InBlock.gif][] var proxy = new MessageSvc.Streamed.StreamedClient();  
![InBlock.gif][]  
![InBlock.gif][] var sr = new System.IO.FileStream(  
![InBlock.gif][] source, System.IO.FileMode.Open);  
![InBlock.gif][]  
![InBlock.gif][] proxy.UploadFile(destination + Path.GetFileName(source), sr);  
![InBlock.gif][]  
![InBlock.gif][] sr.Close();  
![InBlock.gif][] proxy.Close();  
![InBlock.gif][]  
![InBlock.gif][] MessageBox.Show( "上传成功");  
![InBlock.gif][] \}  
![InBlock.gif][] catch (Exception ex)  
![InBlock.gif][] \{  
![InBlock.gif][] MessageBox.Show(ex.ToString());  
![InBlock.gif][] \}  
![InBlock.gif][] \}  
![InBlock.gif][] \}  
![InBlock.gif][]\}

App.config

<?xml version="1.0" encoding="utf-8" ?>  
<configuration>  
<system.serviceModel>  
<client>  
  
  
  
<endpoint address="net.tcp://localhost:54321/Message/Streamed" binding="netTcpBinding" contract="MessageSvc.Streamed.IStreamed" bindingConfiguration="StreamedBindingConfiguration" />  
</client>  
<bindings>  
<netTcpBinding>  
  
  
<binding name="StreamedBindingConfiguration" transferMode="Streamed" sendTimeout="00:10:00" />  
</netTcpBinding>  
</bindings>  
</system.serviceModel>  
</configuration>

运行结果：  
上传文件后提示上传成功  
  
  
OK  
[\[源码下载\]][Link 2]

本文转自webabcd 51CTO博客，原文链接： http://blog.51cto.com/webabcd/344131 ，如需转载请自行联系原作者

[Link 1]: http://webabcd.blog.51cto.com/1787395/343999
[Link 2]: http://down.51cto.com/data/100781
[webabcd]: http://webabcd.blog.51cto.com/
[InBlock.gif]: /images/20220204/5a6315abc05143e19c08a49e4b0b830d.png