建站
咨詢
售后
建站咨詢
新聞中心
WCF總對于文件的傳輸方式可以通過各種方法來實(shí)現(xiàn)，而且對于大文件的傳輸也能輕松的實(shí)現(xiàn)。在這里我們可以通過WCF異步上傳的方法來詳細(xì)介紹一下這方面的應(yīng)用知識，以此來加深大家對這方面的認(rèn)識程度。#t#
成都創(chuàng)新互聯(lián)公司從2013年成立，是專業(yè)互聯(lián)網(wǎng)技術(shù)服務(wù)公司，擁有項(xiàng)目成都網(wǎng)站制作、成都網(wǎng)站建設(shè)網(wǎng)站策劃，項(xiàng)目實(shí)施與項(xiàng)目整合能力。我們以讓每一個夢想脫穎而出為使命，1280元長洲做網(wǎng)站,已為上家服務(wù),為長洲各地企業(yè)和個人服務(wù),聯(lián)系電話:028-86922220
在WCF下作大文件的上傳，首先想到使用的就是Stream，這也是微軟推薦的使用方式。處理流程是：首先把文件加載到內(nèi)存中，加載完畢后傳遞數(shù)據(jù)。這種處理方式對小文件，值得推薦，比如幾K，幾十k的圖片文件，文本文件對大文件就不適用，比如10G的電影，把10G的數(shù)據(jù)加載到緩存中再傳遞，這是不可想象的。這個時候我們想到的就是斷點(diǎn)續(xù)傳。由于數(shù)據(jù)量很大。會導(dǎo)致當(dāng)前程序阻塞，所以采用異步發(fā)送的方式，以進(jìn)度條顯示出來，這也是本篇文章所要實(shí)現(xiàn)的功能. 另外，目前BasicHttpBinding, NetTcpBinding, 和NetNamedPipeBinding 支持流處理模型，其他的不支持，這也影響stream的使用。
解釋幾個重要的概念以及實(shí)現(xiàn)的方式：
1、WCF異步上傳之?dāng)帱c(diǎn)續(xù)傳：就是在上一次下載/上傳斷開的位置開始繼續(xù)下載/上傳。微軟已經(jīng)提供好了這樣的方法: BinaryWriter 這個是二進(jìn)制的寫入器，看下面：
- namespace System.IO
- {
- public class BinaryWriter : IDisposable
- {
- public virtual long Seek(int offset, SeekOrigin origin);
- //設(shè)置當(dāng)前流中的位置，***個參數(shù)表示偏移量，第二個參數(shù)表示偏移量的參考依據(jù)
- public virtual void Write(byte[] buffer); //把數(shù)據(jù)寫入Seek方法設(shè)置的位置
- }
- }
2、WCF異步上傳之異步線程：就是使用后臺程序，不用阻塞當(dāng)前線程，使用backgroundWorker組建，可以大大減少代碼的編寫量
下面的操作都是與WCF相關(guān)的部分。首先我們要定義一個數(shù)據(jù)契約用來傳遞數(shù)據(jù):
- [DataContract]
- public class FileInfo
- {
- //文件名
- [DataMember]
- public string Name { get; set; }
- //文件字節(jié)大小
- [DataMember]
- public long Length { get; set; }
- //文件的偏移量
- [DataMember]
- public long Offset { get; set; }
- //傳遞的字節(jié)數(shù)[DataMember]
- public byte[] Data { get; set; }
- //創(chuàng)建時間
- [DataMember]
- public DateTime CreateTime { get; set; }
- }
- 接著定義操作的契約：
- [ServiceContract]
- public interface IFilesLoad
- {
- [OperationContract]
- List< FileInfo> GetFilesList(); //獲得以已經(jīng)上傳的文件列表
- [OperationContract]
- FileInfo GetFiles(string fileName);
//根據(jù)文件名尋找文件是否存在，返回文件的字節(jié)長度- [OperationContract]
- FileInfo UplodaFile(FileInfo file); //上傳文件
- }
定義了契約，下面就要來實(shí)現(xiàn)契約，這里僅僅粘貼重要部分，在后面可以下載源代碼
- public Fish.DataContracts.FileInfo UplodaFile
(Fish.DataContracts.FileInfo file)- {
- string filePath = System.Configuration.ConfigurationManager.
AppSettings["filePath"] + "/" + file.Name;
//獲取文件的路徑,已經(jīng)保存的文件名- FileStream fs = new FileStream(filePath, FileMode.OpenOrCreate);
//打開文件- long offset = file.Offset; //file.Offset
文件偏移位置,表示從這個位置開始進(jìn)行后面的數(shù)據(jù)添加- BinaryWriter writer = new BinaryWriter(fs);//初始化文件寫入器
- writer.Seek((int)offset, SeekOrigin.Begin);//設(shè)置文件的寫入位置
- writer.Write(file.Data);//寫入數(shù)據(jù)
- file.Offset = fs.Length;//返回追加數(shù)據(jù)后的文件位置
- file.Data = null;
- writer.Close();
- fs.Close();
- return file;
- }
下面來進(jìn)行服務(wù)端得WCF配置
- < system.serviceModel>
- < services>
- < !-- 文件斷點(diǎn)續(xù)傳 -->
- < service behaviorConfiguration="DefaultBehavior"
name="Fish.ServiceImpl.FilesService">- < endpoint address="" binding="basicHttpBinding"
bindingConfiguration ="StreamedHTTP"
contract="Fish.ServiceInterfaces.IFilesLoad">< /endpoint>- < host>
- < baseAddresses>
- < add baseAddress="http://localhost:8080/Fish/FilesService"/>
- < /baseAddresses>
- < /host>
- < /service>
- < /services>
- < behaviors>
- < serviceBehaviors>
- < behavior name="DefaultBehavior">
- < serviceMetadata httpGetEnabled="true" />
- < serviceDebug includeExceptionDetailInFaults="true" />
- < /behavior>
- < /serviceBehaviors>
- < /behaviors>
- < bindings>
- < basicHttpBinding>
- < binding name="StreamedHTTP" maxReceivedMessageSize="2000000000000"
messageEncoding="Mtom" transferMode="Streamed">- < readerQuotas maxArrayLength="20000000"/>
- < /binding>
- < /basicHttpBinding>
- < /bindings>
- < /system.serviceModel>
這里最要的是設(shè)置maxReceivedMessageSize， messageEncoding。比較重要的是設(shè)置為Mtom，可以提高30%的效率，這是wcf特意為大文件提供的。下面看客戶端代碼:
- var fileManger = Common.ServiceBroker.FindService
< IFilesLoad>(); //創(chuàng)建WCF代理- string localPath = e.Argument as string;
- string fileName = localPath.Substring(localPath.LastIndexOf
('\\') + 1);//獲得文件本地文件地址- int maxSiz = 1024 * 100; //設(shè)置每次傳100k
- FileStream stream = System.IO.File.OpenRead(localPath);
//讀取本地文件- Fish.DataContracts.FileInfo file = fileManger.GetFiles
(fileName); //更加文件名,查詢服務(wù)中是否存在該文件- if (file == null) //表示文件不存在
- {
- file = new Fish.DataContracts.FileInfo();
- file.Offset = 0; //設(shè)置文件從開始位置進(jìn)行數(shù)據(jù)傳遞
- }
- file.Name = fileName;
- file.Length = stream.Length;
- if (file.Length == file.Offset)
//如果文件的長度等于文件的偏移量，說明文件已經(jīng)上傳完成- {
- MessageBox.Show("該文件已經(jīng)在服務(wù)器中,不用上傳！", "提示",
MessageBoxButtons.OK, MessageBoxIcon.Warning);- return;
- }
- else
- {
- while (file.Length != file.Offset)
//循環(huán)的讀取文件,上傳，直到文件的長度等于文件的偏移量- {
- file.Data = new byte[file.Length - file.Offset
< = maxSiz ? file.Length - file.Offset : maxSiz]; //設(shè)置傳遞的數(shù)據(jù)的大小- stream.Position = file.Offset; //設(shè)置本地文件數(shù)據(jù)的讀取位置
- stream.Read(file.Data, 0, file.Data.Length);//把數(shù)據(jù)寫入到file.Data中
- file = fileManger.UplodaFile(file); //上傳
- e.Result = file.Offset;
- (sender as BackgroundWorker).ReportProgress((int)
(((double)file.Offset / (double)((long)file.Length)) * 100), file.Offset);- if (this.backgroundWorker1.CancellationPending)
- return;
- }
- }
- stream.Close();
- Common.ServiceBroker.DisposeService< IFilesLoad>(fileManger); //關(guān)閉wcf
以上就是對WCF異步上傳的相關(guān)介紹。
網(wǎng)站名稱：WCF異步上傳相關(guān)技巧分享
文章出自：http://www.dlmjj.cn/article/dpcsjoo.html
