WCF是一個(gè)使用了托管代碼建立的統(tǒng)一框架。它的應(yīng)用可以幫助開(kāi)發(fā)者創(chuàng)建一個(gè)安全性高，可依賴性的解決方案。那么今天，我們將會(huì)在這里為大家詳細(xì)介紹一下其中WCF消息處理的相關(guān)概念。

使用托管代碼建立和運(yùn)行面向服務(wù)（Service Oriented）應(yīng)用程序的統(tǒng)一框架

WCF消息處理：使用流數(shù)據(jù)傳輸文件，減少內(nèi)存開(kāi)銷(xiāo)。

示例

1、WCF消息處理之服務(wù)

IStreamed.cs  
using System;  
using System.Collections.Generic;  
using System.Linq;  
using System.Text;  
using System.ServiceModel;  
using System.IO;  
namespace WCF.ServiceLib.Message  
{  
/**//// < summary> 
/// 消息契約（定義與 SOAP 消息相對(duì)應(yīng)的強(qiáng)類型類）  
/// < /summary> 
[MessageContract]  
public class FileWrapper  
{  
/**//// < summary> 
/// 指定數(shù)據(jù)成員為 SOAP 消息頭  
/// < /summary> 
[MessageHeader]  
public string FilePath;  
/**//// < summary> 
/// 指定將成員序列化為 SOAP 正文中的元素  
/// < /summary> 
[MessageBodyMember]  
public Stream FileData;  
}  
/**//// < summary> 
/// IStreamed接口  
/// < /summary> 
[ServiceContract]  
public interface IStreamed  
{  
/**//// < summary> 
/// 上傳文件  
/// < /summary> 
/// < remarks> 
/// 1、支持?jǐn)?shù)據(jù)流傳輸?shù)慕壎ㄓ校築asicHttpBinding、NetTcpBinding 
和 NetNamedPipeBinding  
/// 2、流數(shù)據(jù)類型必須是可序列化的 Stream 或 MemoryStream  
// /3、傳遞時(shí)消息體(Message Body)中不能包含其他數(shù)據(jù)，即參數(shù)中只能有一個(gè)
System.ServiceModel.MessageBodyMember  
/**//// < /remarks> 
/// < param name="fileWrapper">WCF.ServiceLib.Message.FileWrapper< /param> 
[OperationContract]  
void UploadFile(FileWrapper fileWrapper);  
}  
}  
Streamed.cs  
using System;  
using System.Collections.Generic;  
using System.Linq;  
using System.Text;  
using System.ServiceModel;  
using System.IO;  
namespace WCF.ServiceLib.Message  
{  
/**//// < summary> 
/// IStreamed類  
/// < /summary> 
public class Streamed : IStreamed  
{  
/**//// < summary> 
/// 上傳文件  
/// < /summary> 
/// < param name="fileWrapper">WCF.ServiceLib.Message.
FileWrapper< /param> 
public void UploadFile(FileWrapper fileWrapper)  
{  
var sourceStream = fileWrapper.FileData;  
var targetStream = new FileStream(fileWrapper.FilePath,  
FileMode.Create,  
FileAccess.Write,  
FileShare.None);  
var buffer = new byte[4096];  
var count = 0;  
while ((count = sourceStream.Read(buffer, 0, buffer.Length)) > 0)  
{  
targetStream.Write(buffer, 0, count);  
}  
targetStream.Close();  
sourceStream.Close();  
}  
}  
} 

#p#

2、WCF消息處理之宿主

Streamed.cs  
using (ServiceHost host = new ServiceHost(typeof
(WCF.ServiceLib.Message.Streamed)))  
{  
host.Open();  
Console.WriteLine("服務(wù)已啟動(dòng)(WCF.ServiceLib.Message.Streamed)");  
Console.WriteLine("按< ENTER>停止服務(wù)");  
Console.ReadLine();  
}  
App.config  
< ?xml version="1.0" encoding="utf-8" ?> 
< configuration> 
< system.serviceModel> 
< services> 
< !--name - 提供服務(wù)的類名--> 
< !--behaviorConfiguration - 指定相關(guān)的行為配置--> 
< service name="WCF.ServiceLib.Message.Streamed" 
behaviorConfiguration="MessageBehavior"> 
< !--address - 服務(wù)地址--> 
< !--binding - 通信方式--> 
< !--contract - 服務(wù)契約--> 
< !--bindingConfiguration - 指定相關(guān)的綁定配置--> 
< 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"> 
< !--httpGetEnabled - 使用get方式提供服務(wù)--> 
< serviceMetadata httpGetEnabled="true" /> 
< serviceDebug includeExceptionDetailInFaults="true"/> 
< /behavior> 
< /serviceBehaviors> 
< /behaviors> 
< bindings> 
< netTcpBinding> 
< !--transferMode - 指示通道是使用流處理模式還是緩沖模式來(lái)傳輸請(qǐng)求和響應(yīng)消息--> 
< !--maxReceivedMessageSize - 
在采用此綁定配置的通道上可接收的***消息大小（單位：字節(jié)）--> 
< !--receiveTimeout - 在傳輸引發(fā)異常之前可用于完成讀取操作的時(shí)間間隔--> 
< binding name="StreamedBindingConfiguration" transferMode="Streamed" 
maxReceivedMessageSize="1073741824" receiveTimeout="00:10:00" /> 
< /netTcpBinding> 
< /bindings> 
< /system.serviceModel> 
< /configuration> 

3、WCF消息處理之客戶端

Streamed.cs  
using System;  
using System.Collections.Generic;  
using System.Linq;  
using System.Text;  
using System.Windows.Forms;  
using System.ServiceModel;  
using System.IO;  
namespace Client2.Message  
{  
/**//// < summary> 
/// 演示Message.Streamed的類  
/// < /summary> 
public class Streamed  
{  
/**//// < summary> 
/// 流數(shù)據(jù)上傳文件  
/// < /summary> 
/// < param name="source">源文件地址< /param> 
/// < param name="destination">目標(biāo)路徑< /param> 
public void HelloStreamed(string source, string destination)  
{  
try  
{  
var proxy = new MessageSvc.Streamed.StreamedClient();  
var sr = new System.IO.FileStream(  
source, System.IO.FileMode.Open);  
proxy.UploadFile(destination + Path.GetFileName(source), sr);  
sr.Close();  
proxy.Close();  
MessageBox.Show("上傳成功");  
}  
catch (Exception ex)  
{  
MessageBox.Show(ex.ToString());  
}  
}  
}  
}  
App.config  
< ?xml version="1.0" encoding="utf-8" ?> 
< configuration> 
< system.serviceModel> 
< client> 
< !--address - 服務(wù)地址--> 
< !--binding - 通信方式--> 
< !--contract - 服務(wù)契約--> 
< endpoint address="net.tcp://localhost:54321/Message/Streamed" 
binding="netTcpBinding" contract="MessageSvc.Streamed.IStreamed" 
bindingConfiguration="StreamedBindingConfiguration" /> 
< /client> 
< bindings> 
< netTcpBinding> 
< !--transferMode - 指示通道是使用流處理模式還是緩沖模式來(lái)傳輸請(qǐng)求和響應(yīng)消息--> 
< !--sendTimeout - 在傳輸引發(fā)異常之前可用于完成寫(xiě)入操作的時(shí)間間隔--> 
< binding name="StreamedBindingConfiguration" 
transferMode="Streamed" sendTimeout="00:10:00" /> 
< /netTcpBinding> 
< /bindings> 
< /system.serviceModel> 
< /configuration> 

 以上就是對(duì)WCF消息處理的相關(guān)概念介紹。

【編輯推薦】

1. 六步驟完成WCF開(kāi)發(fā)
2. WCF附加屬性技巧掌握
3. 學(xué)習(xí)WCF綁定經(jīng)驗(yàn)分享
4. WCF效率提高技巧講解
5. WCF自承載實(shí)踐心得分享