20200728-直接提取壓縮包里的文件

一 使用背景：

通過Http 請求下載一個壓縮的文件到服務器內存中（重點：不用保存到本地），然后通過代碼直接提取壓縮包的文件

 

二 實現思路：(注：需要提前安裝 ICSharpCode.SharpZipLib.dll)

1 通過Http請求下載壓縮文件到服務器的內存中

2 讀取內存中壓縮的包的流(注意先將:Stream 轉換成MemoryStream)

3 通過ICSharpCode.SharpZipLib.Zip.dll的ZipFile方法將壓縮包的MemoryStream 注入

4 通過文件索引提取壓縮包里的文件流

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

 

三 參考代碼:

        public string HttpDownloadFile(int tenantId, RequestHeaadModel heaadModel)
        {
            var dfsResultPath = string.Empty;
            var listDfsPath = new List<string>();
            try
            {
                #region Http請求參數設置
                ServicePointManager.Expect100Continue = false;
                ServicePointManager.SecurityProtocol = SecurityProtocolType.Tls11 | SecurityProtocolType.Tls12 | SecurityProtocolType.Tls | SecurityProtocolType.Ssl3;
                ServicePointManager.ServerCertificateValidationCallback += (object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors) => true;
                HttpWebRequest request = (HttpWebRequest)WebRequest.Create(heaadModel.ResquestParamUrl);
                request.Headers.Add("x-qys-accesstoken", heaadModel.Accesstoken);
                request.Headers.Add("x-qys-timestamp", "0");
                request.Headers.Add("x-qys-signature", heaadModel.Searect);
                request.ContentType = heaadModel.ContentType;
                request.Method = "GET";
                request.Timeout = 100000;
                request.Accept = "application/octet-stream";
                #endregion

                #region 對響應的壓縮包解析
                using (WebResponse webRes = request.GetResponse())
                {
                    #region  1 獲取響應的壓縮包文件流
                    var length = (long)webRes.ContentLength;
                    var response = webRes as HttpWebResponse;
                    var stream = response.GetResponseStream();
                    #endregion

                    #region 2   將壓縮包文件流程讀取到內存中
                    var stmMemory = new MemoryStream();
                    if (length == -1)
                    {
                        length = 1024;
                    }
                    var buffer = new byte[length];
                    int i;
                    while ((i = stream.Read(buffer, 0, buffer.Length)) > 0)
                    {
                        stmMemory.Write(buffer, 0, i);
                    }
                    #endregion

                    #region 3 循環讀取壓縮包的文件
                    var zipFile_ = new ICSharpCode.SharpZipLib.Zip.ZipFile(stmMemory);
                    int count = int.Parse(zipFile_.Count.ToString());//獲取文件個數
                    for (int j = 0; j < count; j++)
                    {
                        var tempSteam = zipFile_.GetInputStream(long.Parse($"{i}"));//壓縮包里的文件索引
                        var stmMemory2 = new MemoryStream();
                        var buffer2 = new byte[zipFile_[i].Size];
                        int m;
                        //將單個文件的文件流讀取到內存中
                        while ((m = tempSteam.Read(buffer2, 0, buffer2.Length)) > 0)
                        {
                            stmMemory2.Write(buffer2, 0, m);
                        }
                        stmMemory2.Seek(0, SeekOrigin.Begin);
                        var dfsItem = new DfsItem("TenantBaseFile", zipFile_[i].Name,
                            stmMemory2, tenantId);
                        var dfsPath = Dfs.Store(dfsItem);

                        Logger.Debug($"下載背調文件地址：{dfsPath.ToString()}");
                        listDfsPath.Add(dfsPath.ToString());
                        stmMemory2.Close();
                        stmMemory2.Flush();
                    }
                    #endregion
                    stmMemory.Close();
                    stmMemory.Flush();
                }
                #endregion
            }
            catch (Exception ex)
            {
                Logger.Debug($"下載報告異常：異常信息：{ex.Message}，堆棧信息：{ex.StackTrace}");
            }

            return string.Join(",", listDfsPath);
        }