20200728-直接提取压缩包里的文件

  • A+
所属分类:.NET技术
摘要

一 使用背景:通过Http 请求下载一个压缩的文件到服务器内存中(重点:不用保存到本地 ),然后通过代码直接提取压缩包的文件

一 使用背景:

通过Http 请求下载一个压缩的文件到服务器内存中(重点:不用保存到本地),然后通过代码直接提取压缩包的文件

 

二 实现思路:(注:需要提前安装 ICSharpCode.SharpZipLib.dll)

20200728-直接提取压缩包里的文件

1 通过Http请求下载压缩文件到服务器的内存中

2 读取内存中压缩的包的流(注意先将:Stream 转换成MemoryStream)

3 通过ICSharpCode.SharpZipLib.Zip.dll的ZipFile方法将压缩包的MemoryStream 注入

4 通过文件索引提取压缩包里的文件流

5 保存上传文件到指定位置

 

三 参考代码:

20200728-直接提取压缩包里的文件20200728-直接提取压缩包里的文件

 1         public string HttpDownloadFile(int tenantId, RequestHeaadModel heaadModel)  2         {  3             var dfsResultPath = string.Empty;  4             var listDfsPath = new List<string>();  5             try  6             {  7                 #region Http请求参数设置  8                 ServicePointManager.Expect100Continue = false;  9                 ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls11 | SecurityProtocolType.Tls12 | SecurityProtocolType.Tls | SecurityProtocolType.Ssl3; 10                 ServicePointManager.ServerCertificateValidationCallback += (object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors) => true; 11                 HttpWebRequest request = (HttpWebRequest)WebRequest.Create(heaadModel.ResquestParamUrl); 12                 request.Headers.Add("x-qys-accesstoken", heaadModel.Accesstoken); 13                 request.Headers.Add("x-qys-timestamp", "0"); 14                 request.Headers.Add("x-qys-signature", heaadModel.Searect); 15                 request.ContentType = heaadModel.ContentType; 16                 request.Method = "GET"; 17                 request.Timeout = 100000; 18                 request.Accept = "application/octet-stream"; 19                 #endregion 20  21                 #region 对响应的压缩包解析 22                 using (WebResponse webRes = request.GetResponse()) 23                 { 24                     #region  1 获取响应的压缩包文件流 25                     var length = (long)webRes.ContentLength; 26                     var response = webRes as HttpWebResponse; 27                     var stream = response.GetResponseStream(); 28                     #endregion 29  30                     #region 2   将压缩包文件流程读取到内存中 31                     var stmMemory = new MemoryStream(); 32                     if (length == -1) 33                     { 34                         length = 1024; 35                     } 36                     var buffer = new byte[length]; 37                     int i; 38                     while ((i = stream.Read(buffer, 0, buffer.Length)) > 0) 39                     { 40                         stmMemory.Write(buffer, 0, i); 41                     } 42                     #endregion 43  44                     #region 3 循环读取压缩包的文件 45                     var zipFile_ = new ICSharpCode.SharpZipLib.Zip.ZipFile(stmMemory); 46                     int count = int.Parse(zipFile_.Count.ToString());//获取文件个数 47                     for (int j = 0; j < count; j++) 48                     { 49                         var tempSteam = zipFile_.GetInputStream(long.Parse($"{i}"));//压缩包里的文件索引 50                         var stmMemory2 = new MemoryStream(); 51                         var buffer2 = new byte[zipFile_[i].Size]; 52                         int m; 53                         //将单个文件的文件流读取到内存中 54                         while ((m = tempSteam.Read(buffer2, 0, buffer2.Length)) > 0) 55                         { 56                             stmMemory2.Write(buffer2, 0, m); 57                         } 58                         stmMemory2.Seek(0, SeekOrigin.Begin); 59                         var dfsItem = new DfsItem("TenantBaseFile", zipFile_[i].Name, 60                             stmMemory2, tenantId); 61                         var dfsPath = Dfs.Store(dfsItem); 62  63                         Logger.Debug($"下载背调文件地址:{dfsPath.ToString()}"); 64                         listDfsPath.Add(dfsPath.ToString()); 65                         stmMemory2.Close(); 66                         stmMemory2.Flush(); 67                     } 68                     #endregion 69                     stmMemory.Close(); 70                     stmMemory.Flush(); 71                 } 72                 #endregion 73             } 74             catch (Exception ex) 75             { 76                 Logger.Debug($"下载报告异常:异常信息:{ex.Message},堆栈信息:{ex.StackTrace}"); 77             } 78  79             return string.Join(",", listDfsPath); 80         }

View Code