這篇文章主要介紹了分享WCF文件傳輸實現方法---WCFFileTransfer,需要的朋友可以參考下

前幾天分享了分享了WCF聊天程序--WCFChat ，本文和大家一起分享利用WCF實現文件的傳輸。

程序運行效果：

接收文件端：

發送文件端：連接WCF服務，選擇要傳輸的文件

文件傳輸成功：

我們會在保存文件的默認路徑：C:/Documents and Settings/Administrator/桌面，下看到傳輸的文件:

代碼分析：

這里就不一一的闡述每一句代碼的作用了，感興趣的朋友可以下載，文后會有下載鏈接。說下值得注意的地方：

前兩天有人在百度知道中問能不能把WCF中的契約單獨封裝到一個類庫中，當時感覺多此一舉，無意中看到把接口單獨分出去，有個很好的應用，就是利用通道實現客戶端代理。

ITransfer.cs

1. using System; 
2. using System.Collections.Generic; 
3. using System.Linq; 
4. using System.Text; 
5. using System.ServiceModel; 
6. using System.Runtime.Serialization; 
7. using System.Threading; 
8. using System.IO; 
9.  
10. namespace FileInterface 
11. { 
12. [ServiceContract] 
13. public interface ITransfer 
14. { 
15. [OperationContract(Action = "UploadFile")] 
16. void TransferFile(FileTransferMessage request);//文件傳輸 
17. } 
18.  
19.  
20. [MessageContract] 
21. public class FileTransferMessage 
22. { 
23. [MessageHeader(MustUnderstand = true)] 
24. public string SavePath;//文件保存路徑 
25.  
26. [MessageHeader(MustUnderstand = true)] 
27. public string FileName;//文件名稱 
28.  
29. [MessageBodyMember(Order = 1)] 
30. public Stream FileData;//文件傳輸時間 
31. } 
32. } 

利用通道創建客戶端代理：

1. if (_proxy == null) 
2. { 
3. try 
4. { 
5. NetTcpBinding binding = new NetTcpBinding(); 
6. binding.TransferMode = TransferMode.Streamed; 
7. binding.SendTimeout = new TimeSpan(0, 30, 0); 
8. //利用通道創建客戶端代理 
9. _proxy = ChannelFactory<ITransfer>.CreateChannel(binding, new EndpointAddress(CBSerURL.Text)); 
10. IContextChannel obj = _proxy as IContextChannel; 
11. //string s = obj.SessionId; 
12.  
13. } 
14. catch (Exception ex) 
15. { 
16. MessageBox.Show(ex.Message); 
17. return; 
18. } 

這樣，既不用添加服務引用，也不需要生成代理。

文件傳輸的函數不是很難，代碼如下：

1. public void TransferFile(FileTransferMessage request) 
2. { 
3. string logInfo; 
4.  
5. Program.Get_ILog().Log(logInfo = string.Format("開始接收文件,name={0}", request.FileName));//填寫日志 
6. //文件信息 
7. string uploadFolder = AppValue.GetParam()._saveDir; 
8. string savaPath = request.SavePath; 
9. string fileName = request.FileName; 
10. Stream sourceStream = request.FileData; 
11. FileStream targetStream = null; 
12. //判斷文件是否可讀 
13. if (!sourceStream.CanRead) 
14. { 
15. throw new Exception("數據流不可讀!"); 
16. } 
17. if (savaPath == null) savaPath = @"文件傳輸/"; 
18. if (!savaPath.EndsWith("//")) savaPath += "//"; 
19. if (!uploadFolder.EndsWith("//")) uploadFolder += "//"; 
20.  
21. uploadFolder = uploadFolder + savaPath; 
22. //創建保存文件夾 
23. if (!Directory.Exists(uploadFolder)) 
24. { 
25. Directory.CreateDirectory(uploadFolder); 
26. } 
27.  
28. int fileSize = 0; 
29. string filePath = Path.Combine(uploadFolder, fileName);//Combine合并兩個路徑 
30. try 
31. { 
32. //文件流傳輸 
33. using (targetStream = new FileStream(filePath, FileMode.Create, FileAccess.Write, FileShare.None)) 
34. { 
35. //定義文件緩沖區 
36. const int bufferLen = 4096; 
37. byte[] buffer = new byte[bufferLen]; 
38. int count = 0; 
39.  
40. while ((count = sourceStream.Read(buffer, 0, bufferLen)) > 0) 
41. { 
42. targetStream.Write(buffer, 0, count); 
43. fileSize += count; 
44. } 
45. targetStream.Close(); 
46. sourceStream.Close(); 
47. } 
48. } 
49. catch (Exception ex) 
50. { 
51. Program.Get_ILog().Log(logInfo + ex.Message); 
52. } 
53.  
54. Program.Get_ILog().Log(string.Format("接收文件完畢 name={0},filesize={1}", 
55. request.FileName, fileSize)); 
56. } 

其他的代碼感興趣的朋友下載來研究吧!