1 using System;
2 using System.Collections.Generic;
3 using System.Text;
4 using System.IO;
5 using System.Net;
6 using System.Globalization;
7 using System.IO.Compression;
8 using ICSharpCode.SharpZipLib.Zip;
9 using ICSharpCode.SharpZipLib.GZip;
10 using ICSharpCode.SharpZipLib.Tar;
11
12 namespace ClassProject.FTP
13 {
14 class FtpWeb
15 {
16 string ftpServerIP;
17 string ftpRemotePath;
18 string ftpUserID;
19 string ftpPassword;
20 string ftpURI;
21 /// <summary>
22 /// 连接FTP
23 /// </summary>
24 /// <param name="FtpServerIP">FTP连接地址</param>
25 /// <param name="FtpRemotePath">指定FTP连接成功后的当前目录, 如果不指定即默认为根目录</param>
26 /// <param name="FtpUserID">用户名</param>
27 /// <param name="FtpPassword">密码</param>
28 public FtpWeb(string FtpServerIP, string FtpRemotePath, string FtpUserID, string FtpPassword)
29 {
30 ftpServerIP = FtpServerIP;
31 ftpRemotePath = FtpRemotePath;
32 ftpUserID = FtpUserID;
33 ftpPassword = FtpPassword;
34 ftpURI = "ftp://" + ftpServerIP + "/";
35 }
36 //测试用例--已成功
37 //static void Main()
38 //{
39 // FtpWeb fw = new FtpWeb(@"xxxxxx/FTPFile", @"C:\Users\Administrator\Desktop\dic\", "user", "password");
40 // string[] a = fw.NEWGetFileList(@"FTPFile");
41 // string path = @"C:\Users\Administrator\Desktop\新建文件夹";
42 // string X = "START:";
43 // for (int i = 0; i < a.Length; i++)
44 // {
45 // fw.Download(path, a[i].ToString(),'Active');
46 // fw.Delete(a[i].ToString());
47 // X += a[i] + "、";
48 // }
49 // Console.WriteLine("x");
50 // Console.ReadLine();
51 //}
52 //上传文件
53 public string UploadFile(string[] filePaths)
54 {
55 StringBuilder sb = new StringBuilder();
56 if (filePaths != null && filePaths.Length > 0)
57 {
58 foreach (var file in filePaths)
59 {
60 sb.Append(Upload(file, "Active"));
61 }
62 }
63 return sb.ToString();
64 }
65 /// <summary>
66 /// 上传文件
67 /// </summary>
68 /// <param name="filename"></param>
69 public string Upload(string filename,string type)
70 {
71 FileInfo fileInf = new FileInfo(filename);
72 if (!fileInf.Exists)
73 {
74 return filename + " 不存在!\n";
75 }
76 string uri = ftpURI + fileInf.Name;
77 FtpWebRequest reqFTP;
78 reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));
79 reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
80 reqFTP.KeepAlive = false;
81 reqFTP.Method = WebRequestMethods.Ftp.UploadFile;
82 reqFTP.UseBinary = true;
83 if (type=="Active")
84 {
85 reqFTP.UsePassive = false; //选择主动
86 }
87 else
88 {
89 reqFTP.UsePassive = true; //选择被动模式
90 }
91
92 //Entering Passive Mode
93 reqFTP.ContentLength = fileInf.Length;
94 int buffLength = 2048;
95 byte[] buff = new byte[buffLength];
96 int contentLen;
97 FileStream fs = fileInf.OpenRead();
98 try
99 {
100 Stream strm = reqFTP.GetRequestStream();
101 contentLen = fs.Read(buff, 0, buffLength);
102 while (contentLen != 0)
103 {
104 strm.Write(buff, 0, contentLen);
105 contentLen = fs.Read(buff, 0, buffLength);
106 }
107 strm.Close();
108 fs.Close();
109 }
110 catch (Exception ex)
111 {
112 return "同步 " + filename + "时连接不上服务器!\n";
113 //Insert_Standard_ErrorLog.Insert("FtpWeb", "Upload Error --> " + ex.Message);
114 }
115 return "";
116 }
117 /// <summary>
118 /// 下载
119 /// </summary>
120 /// <param name="filePath"></param>
121 /// <param name="fileName"></param>
122 public void Download(string filePath, string fileName, string type)
123 {
124 FtpWebRequest reqFTP;
125 try
126 {
127 FileStream outputStream = new FileStream(filePath + "\\" + fileName, FileMode.Create);
128 reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI + fileName));
129 reqFTP.Method = WebRequestMethods.Ftp.DownloadFile;
130 reqFTP.UseBinary = true;
131 if (type == "Active")
132 {
133 reqFTP.UsePassive = false; //选择主动
134 }
135 else
136 {
137 reqFTP.UsePassive = true; //选择被动模式
138 }
139 reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
140 FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
141 Stream ftpStream = response.GetResponseStream();
142 long cl = response.ContentLength;
143 int bufferSize = 2048;
144 int readCount;
145 byte[] buffer = new byte[bufferSize];
146 readCount = ftpStream.Read(buffer, 0, bufferSize);
147 while (readCount > 0)
148 {
149 outputStream.Write(buffer, 0, readCount);
150 readCount = ftpStream.Read(buffer, 0, bufferSize);
151 }
152 ftpStream.Close();
153 outputStream.Close();
154 response.Close();
155 }
156 catch (Exception ex)
157 {
158 // Insert_Standard_ErrorLog.Insert("FtpWeb", "Download Error --> " + ex.Message);
159 }
160 }
161 /// <summary>
162 /// 删除文件
163 /// </summary>
164 /// <param name="fileName"></param>
165 public void Delete(string fileName, string type)
166 {
167 try
168 {
169 string uri = ftpURI + fileName;
170 FtpWebRequest reqFTP;
171 reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(uri));
172 reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
173 reqFTP.KeepAlive = false;
174 if (type == "Active")
175 {
176 reqFTP.UsePassive = false; //选择主动
177 }
178 else
179 {
180 reqFTP.UsePassive = true; //选择被动模式
181 }
182 reqFTP.Method = WebRequestMethods.Ftp.DeleteFile;
183 string result = String.Empty;
184 FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
185 long size = response.ContentLength;
186 Stream datastream = response.GetResponseStream();
187 StreamReader sr = new StreamReader(datastream);
188 result = sr.ReadToEnd();
189 sr.Close();
190 datastream.Close();
191 response.Close();
192 }
193 catch (Exception ex)
194 {
195 //Insert_Standard_ErrorLog.Insert("FtpWeb", "Delete Error --> " + ex.Message + " 文件名:" + fileName);
196 }
197 }
198
199 /// <summary>
200 /// 删除文件
201 /// </summary>
202 /// <param name="srcPath">文件的路径</param>
203 public void DelectDir(string srcPath)
204 {
205 try
206 {
207 DirectoryInfo dir = new DirectoryInfo(srcPath);
208 FileSystemInfo[] fileinfo = dir.GetFileSystemInfos(); //返回目录中所有文件和子目录
209 foreach (FileSystemInfo i in fileinfo)
210 {
211 if (i is DirectoryInfo) //判断是否文件夹
212 {
213 DirectoryInfo subdir = new DirectoryInfo(i.FullName);
214 subdir.Delete(true); //删除子目录和文件
215 }
216 else
217 {
218 File.Delete(i.FullName); //删除指定文件
219 }
220 }
221 }
222 catch (Exception e)
223 {
224 throw;
225 }
226 }
227
228 /// <summary>
229 /// 获取当前目录下明细(包含文件和文件夹)
230 /// </summary>
231 /// <returns></returns>
232 public string[] GetFilesDetailList()
233 {
234 string[] downloadFiles;
235 try
236 {
237 StringBuilder result = new StringBuilder();
238 FtpWebRequest ftp;
239 ftp = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI));
240 ftp.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
241 ftp.Method = WebRequestMethods.Ftp.ListDirectoryDetails;
242 WebResponse response = ftp.GetResponse();
243 StreamReader reader = new StreamReader(response.GetResponseStream());
244 string line = reader.ReadLine();
245 line = reader.ReadLine();
246 line = reader.ReadLine();
247 while (line != null)
248 {
249 result.Append(line);
250 result.Append("\n");
251 line = reader.ReadLine();
252 }
253 result.Remove(result.ToString().LastIndexOf("\n"), 1);
254 reader.Close();
255 response.Close();
256 return result.ToString().Split('\n');
257 }
258 catch (Exception ex)
259 {
260 downloadFiles = null;
261 //Insert_Standard_ErrorLog.Insert("FtpWeb", "GetFilesDetailList Error --> " + ex.Message);
262 return downloadFiles;
263 }
264 }
265 /// <summary>
266 /// 获取当前目录下文件列表(仅文件)
267 /// </summary>
268 /// <returns></returns>
269 public string[] GetFileList(string mask, string type)
270 {
271 string[] downloadFiles;
272 StringBuilder result = new StringBuilder();
273 FtpWebRequest reqFTP;
274 try
275 {
276 reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI));
277 reqFTP.UseBinary = true;
278 if (type == "Active")
279 {
280 reqFTP.UsePassive = false; //选择主动
281 }
282 else
283 {
284 reqFTP.UsePassive = true; //选择被动模式
285 }
286 reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
287 reqFTP.Method = WebRequestMethods.Ftp.ListDirectory;
288 WebResponse response = reqFTP.GetResponse();
289 StreamReader reader = new StreamReader(response.GetResponseStream());
290 string line = reader.ReadLine();
291 while (line != null)
292 {
293 if (mask.Trim() != string.Empty && mask.Trim() != "*.*")
294 {
295 string mask_ = mask.Substring(0, mask.IndexOf("*"));
296 if (line.Substring(0, mask_.Length) == mask_)
297 {
298 result.Append(line);
299 result.Append("\n");
300 }
301 }
302 else
303 {
304 result.Append(line);
305 result.Append("\n");
306 }
307 line = reader.ReadLine();
308 }
309 result.Remove(result.ToString().LastIndexOf('\n'), 1);
310 reader.Close();
311 response.Close();
312 return result.ToString().Split('\n');
313 }
314 catch (Exception ex)
315 {
316 downloadFiles = null;
317 if (ex.Message.Trim() != "远程服务器返回错误: (550) 文件不可用(例如，未找到文件，无法访问文件)。")
318 {
319 //Insert_Standard_ErrorLog.Insert("FtpWeb", "GetFileList Error --> " + ex.Message.ToString());
320 }
321 return downloadFiles;
322 }
323 }
324 /// <summary>
325 /// 获取当前目录下文件列表(仅文件)
326 /// </summary>
327 /// <returns></returns>
328 public string[] NEWGetFileList(string mask,string type)
329 {
330 string[] downloadFiles;
331 StringBuilder result = new StringBuilder();
332 FtpWebRequest reqFTP;
333 try
334 {
335 reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI));
336 reqFTP.UseBinary = true;
337 if (type == "Active")
338 {
339 reqFTP.UsePassive = false; //选择主动
340 }
341 else
342 {
343 reqFTP.UsePassive = true; //选择被动模式
344 }
345 reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
346 reqFTP.Method = WebRequestMethods.Ftp.ListDirectory;
347 WebResponse response = reqFTP.GetResponse();
348 StreamReader reader = new StreamReader(response.GetResponseStream());
349 string line = reader.ReadLine();
350 while (line != null)
351 {
352 if (mask.Trim() != string.Empty && mask.Trim() != "*.*")
353 {
354 result.Append(line);
355 result.Append("\n");
356 }
357 line = reader.ReadLine();
358 }
359 result.Remove(result.ToString().LastIndexOf('\n'), 1);
360 reader.Close();
361 response.Close();
362 return result.ToString().Split('\n');
363 }
364 catch (Exception ex)
365 {
366 downloadFiles = null;
367 if (ex.Message.Trim() != "远程服务器返回错误: (550) 文件不可用(例如，未找到文件，无法访问文件)。")
368 {
369 //Insert_Standard_ErrorLog.Insert("FtpWeb", "GetFileList Error --> " + ex.Message.ToString());
370 }
371 return downloadFiles;
372 }
373 }
374 /// <summary>
375 /// 获取当前目录下所有的文件夹列表(仅文件夹)
376 /// </summary>
377 /// <returns></returns>
378 public string[] GetDirectoryList()
379 {
380 string[] drectory = GetFilesDetailList();
381 string m = string.Empty;
382 foreach (string str in drectory)
383 {
384 if (str.Trim().Substring(0, 1).ToUpper() == "D")
385 {
386 m += str.Substring(54).Trim() + "\n";
387 }
388 }
389 char[] n = new char[] { '\n' };
390 return m.Split(n);
391 }
392 /// <summary>
393 /// 判断当前目录下指定的子目录是否存在
394 /// </summary>
395 /// <param name="RemoteDirectoryName">指定的目录名</param>
396 public bool DirectoryExist(string RemoteDirectoryName)
397 {
398 string[] dirList = GetDirectoryList();
399 foreach (string str in dirList)
400 {
401 if (str.Trim() == RemoteDirectoryName.Trim())
402 {
403 return true;
404 }
405 }
406 return false;
407 }
408 /// <summary>
409 /// 判断当前目录下指定的文件是否存在
410 /// </summary>
411 /// <param name="RemoteFileName">远程文件名</param>
412 public bool FileExist(string RemoteFileName)
413 {
414 string[] fileList = GetFileList("*.*", "Active");
415 foreach (string str in fileList)
416 {
417 if (str.Trim() == RemoteFileName.Trim())
418 {
419 return true;
420 }
421 }
422 return false;
423 }
424 /// <summary>
425 /// 创建文件夹
426 /// </summary>
427 /// <param name="dirName"></param>
428 public void MakeDir(string dirName)
429 {
430 FtpWebRequest reqFTP;
431 try
432 {
433 // dirName = name of the directory to create.
434 reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI + dirName));
435 reqFTP.Method = WebRequestMethods.Ftp.MakeDirectory;
436 reqFTP.UseBinary = true;
437 reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
438 FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
439 Stream ftpStream = response.GetResponseStream();
440 ftpStream.Close();
441 response.Close();
442 }
443 catch (Exception ex)
444 {
445 //Insert_Standard_ErrorLog.Insert("FtpWeb", "MakeDir Error --> " + ex.Message);
446 }
447 }
448 /// <summary>
449 /// 创建文件
450 /// </summary>
451 /// <param name="dirName"></param>
452 /// <param name="interfaceLocation"></param>
453 /// <param name="fileName"></param>
454 public string SavaProcess(string fileName, string dirName,string FilePath)
455 {
456
457 //判断路径是否存在
458 if (!System.IO.Directory.Exists(FilePath))
459 {
460 System.IO.Directory.CreateDirectory(FilePath);
461 }
462 //不存在就创建
463 FilePath = FilePath + "//" + fileName ;
464 //文件覆盖方式添加内容
465 System.IO.StreamWriter file = new System.IO.StreamWriter(FilePath, false);
466 //保存数据到文件
467 file.Write(dirName);
468 //关闭文件
469 file.Close();
470 //释放对象
471 file.Dispose();
472 return FilePath;
473 }
474 /// <summary>
475 /// 获取指定文件大小
476 /// </summary>
477 /// <param name="filename"></param>
478 /// <returns></returns>
479 public long GetFileSize(string filename)
480 {
481 FtpWebRequest reqFTP;
482 long fileSize = 0;
483 try
484 {
485 reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI + filename));
486 reqFTP.Method = WebRequestMethods.Ftp.GetFileSize;
487 reqFTP.UseBinary = true;
488 reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
489 FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
490 Stream ftpStream = response.GetResponseStream();
491 fileSize = response.ContentLength;
492 ftpStream.Close();
493 response.Close();
494 }
495 catch (Exception ex)
496 {
497 //Insert_Standard_ErrorLog.Insert("FtpWeb", "GetFileSize Error --> " + ex.Message);
498 }
499 return fileSize;
500 }
501 /// <summary>
502 /// 改名
503 /// </summary>
504 /// <param name="currentFilename"></param>
505 /// <param name="newFilename"></param>
506 public void ReName(string currentFilename, string newFilename)
507 {
508 FtpWebRequest reqFTP;
509 try
510 {
511 reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(ftpURI + currentFilename));
512 reqFTP.Method = WebRequestMethods.Ftp.Rename;
513 reqFTP.RenameTo = newFilename;
514 reqFTP.UseBinary = true;
515 reqFTP.Credentials = new NetworkCredential(ftpUserID, ftpPassword);
516 FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
517 Stream ftpStream = response.GetResponseStream();
518 ftpStream.Close();
519 response.Close();
520 }
521 catch (Exception ex)
522 {
523 //Insert_Standard_ErrorLog.Insert("FtpWeb", "ReName Error --> " + ex.Message);
524 }
525 }
526 /// <summary>
527 /// 移动文件
528 /// </summary>
529 /// <param name="currentFilename"></param>
530 /// <param name="newFilename"></param>
531 public void MovieFile(string currentFilename, string newDirectory)
532 {
533 ReName(currentFilename, newDirectory);
534 }
535 /// <summary>
536 /// 将数据写入文本文件中
537 /// </summary>
538 /// <param name="Filename"></param>
539 /// <param name="FileDate"></param>
540 public void WriteFile(string Filename, string FileDate)
541 {
542 //传入文本文件的名称，并将数据写入到文本文件中。
543 FileStream fs = new FileStream(Filename, FileMode.OpenOrCreate, FileAccess.ReadWrite);
544 StreamWriter sw = new StreamWriter(fs); // 创建写入流
545 sw.WriteLine(FileDate); // 写入数据
546 sw.Close(); //关闭文件
547 Console.WriteLine("OK");
548 Console.ReadKey();
549
550 }
551
552 /// <summary>
553 /// zip压缩文件
554 /// </summary>
555 /// <param name="filename">filename生成的文件的名称，如：C\123\123.zip</param>
556 /// <param name="directory">directory要压缩的文件夹路径</param>
557 /// <returns></returns>
558 public bool PackFiles(string filename, string directory)
559 {
560 try
561 {
562 directory = directory.Replace("/", "\\");
563
564 if (!directory.EndsWith("\\"))
565 directory += "\\";
566 if (!Directory.Exists(directory))
567 {
568 Directory.CreateDirectory(directory);
569 }
570 if (File.Exists(filename))
571 {
572 File.Delete(filename);
573 }
574
575 FastZip fz = new FastZip();
576 fz.CreateEmptyDirectories = true;
577 fz.CreateZip(filename, directory, true, "");
578
579 return true;
580 }
581 catch (Exception)
582 {
583 return false;
584 }
585 }
586
587 /// <summary>
588 /// gzip压缩文件
589 /// </summary>
590 /// <param name="filename">需要进行压缩的文件</param>
591 /// <param name="nowfilename">压缩后的文件的名字</param>
592 /// <returns></returns>
593 public void GPackFiles(string filename, string nowfilename)
594 {
595 using (FileStream fs = new FileStream(filename, FileMode.Open, FileAccess.Read))
596 {
597 //创建写入流
598 using (FileStream save = new FileStream(nowfilename, FileMode.Create, FileAccess.Write))
599 {
600 //创建包含写入流的压缩流
601 using (GZipStream gs = new GZipStream(save, CompressionMode.Compress))
602 {
603 //创建byte[]数组中转数据
604 byte[] b = new byte[1024 * 1024];
605 int count = 0;
606 //循环将读取流中数据写入到byte[]数组中
607 while ((count = fs.Read(b, 0, b.Length)) > 0)
608 {
609 //将byte[]数组中数据写入到压缩流
610 gs.Write(b, 0, b.Length);
611 }
612 }
613 }
614 }
615
616 }
617
618 /// <summary>
619 /// gzip压缩文件
620 /// </summary>
621 /// <param name="filePath">需要进行压缩的文件</param>
622 /// <param name="zipFilePath">压缩后的文件的名字</param>
623 /// <returns></returns>
624 public void gZipFile(string filePath, string zipFilePath)
625 {
626 Stream s = new GZipOutputStream(File.Create(zipFilePath));
627 FileStream fs = File.OpenRead(filePath);
628 int size;
629 byte[] buf = new byte[4096];
630 do
631 {
632 size = fs.Read(buf, 0, buf.Length);
633 s.Write(buf, 0, size);
634 } while (size > 0);
635 s.Close();
636 fs.Close();
637 }
638
639 public string Zip(string value)
640 {
641 //Transform string into byte[]
642 byte[] byteArray = new byte[value.Length];
643 int indexBA = 0;
644 foreach (char item in value.ToCharArray())
645 {
646 byteArray[indexBA++] = (byte)item;
647 }
648 //Prepare for compress
649 System.IO.MemoryStream ms = new System.IO.MemoryStream();
650 System.IO.Compression.GZipStream sw = new System.IO.Compression.GZipStream(ms,System.IO.Compression.CompressionMode.Compress);
651 //Compress
652 sw.Write(byteArray, 0, byteArray.Length);
653 //Close, DO NOT FLUSH cause bytes will go missing...
654 sw.Close();
655 //Transform byte[] zip data to string
656 byteArray = ms.ToArray();
657 System.Text.StringBuilder sB = new System.Text.StringBuilder(byteArray.Length);
658 foreach (byte item in byteArray)
659 {
660 sB.Append((char)item);
661 }
662 ms.Close();
663 sw.Dispose();
664 ms.Dispose();
665 return sB.ToString();
666 }
667
668 public string Compress(string param)
669 {
670 byte[] data = System.Text.Encoding.UTF8.GetBytes(param);
671 //byte[] data = Convert.FromBase64String(param);
672 MemoryStream ms = new MemoryStream();
673 Stream stream = new ICSharpCode.SharpZipLib.BZip2.BZip2OutputStream(ms);
674 try
675 {
676 stream.Write(data, 0, data.Length);
677 }
678 finally
679 {
680 stream.Close();
681 ms.Close();
682 }
683 return Convert.ToBase64String(ms.ToArray());
684 }
685
686 /// <summary>
687 /// 解压
688 /// </summary>
689 /// <param name="param"></param>
690 /// <returns></returns>
691 public string Decompress(string param)
692 {
693 string commonString = "";
694 byte[] buffer = Convert.FromBase64String(param);
695 MemoryStream ms = new MemoryStream(buffer);
696 Stream sm = new ICSharpCode.SharpZipLib.BZip2.BZip2InputStream(ms);
697 //这里要指明要读入的格式，要不就有乱码
698 StreamReader reader = new StreamReader(sm, System.Text.Encoding.UTF8);
699 try
700 {
701 commonString = reader.ReadToEnd();
702 }
703 finally
704 {
705 sm.Close();
706 ms.Close();
707 }
708 return commonString;
709 }
710
711 /// <summary>
712 /// tar压缩文件
713 /// </summary>
714 /// <param name="filename">filename生成的文件的名称，如：C\123\123.zip</param>
715 /// <param name="directory">directory要压缩的文件夹路径</param>
716 /// <returns></returns>
717 public void TarCreateFromStream(string filename , string directory)
718 {
719
720 // 创建输出流。不必是磁盘，可以是内存流等。
721 string tarOutFn = filename;
722 Stream outStream = File.Create(tarOutFn);
723 TarOutputStream tarOutputStream = new TarOutputStream(outStream);
724
725 CreateTarArchive(tarOutputStream, directory);
726
727 // 关闭归档文件也关闭底层流。
728 tarOutputStream.Close();
729 }
730
731 private void CreateTarArchive(TarOutputStream tarOutputStream, string sourceDirectory)
732 {
733 // 可选地，为目录本身写一个条目。
734 // TarEntry tarEntry = TarEntry.CreateEntryFromFile(sourceDirectory);
735 // tarOutputStream.PutNextEntry(tarEntry);
736 // 将每个文件写入tar。
737 string[] filenames = Directory.GetFiles(sourceDirectory);
738
739 foreach (string filename in filenames)
740 {
741 using (Stream inputStream = File.OpenRead(filename))
742 {
743 int idxStart = filename.LastIndexOf('\\') + 1;
744 string tarName = filename.Substring(idxStart, filename.Length - idxStart);
745 long fileSize = inputStream.Length;
746 TarEntry entry = TarEntry.CreateTarEntry(tarName);
747
748 // 必须设置大小，否则当输出超过时，TAROutPutsFipe将失败。
749 entry.Size = fileSize;
750
751 // 在写入数据之前，将条目添加到TAR流中。
752 tarOutputStream.PutNextEntry(entry);
753
754 // 这是从TracSovi.Read EngyCype复制的
755 byte[] localBuffer = new byte[32 * 1024];
756 while (true)
757 {
758 int numRead = inputStream.Read(localBuffer, 0, localBuffer.Length);
759 if (numRead <= 0)
760 {
761 break;
762 }
763 tarOutputStream.Write(localBuffer, 0, numRead);
764 }
765 }
766 tarOutputStream.CloseEntry();
767 }
768 // 递归。如果不需要就删除。
769 //string[] directories = Directory.GetDirectories(sourceDirectory);
770 //foreach (string directory in directories)
771 //{
772 // CreateTarArchive(tarOutputStream, directory);
773 //}
774 }
775
776 }
777 }