HttpExt.cs

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;

namespace Install.Core.Common
{
    public class HttpExt
    {
        /// <summary>
        /// http下载文件
        /// </summary>
        /// <param name="url">下载文件地址</param>
        /// <returns></returns>
        public static byte[] HttpDownload(string url)
        {
            try
            {
                MemoryStream fs = new MemoryStream();
                // 设置参数
                HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
                //发送请求并获取相应回应数据
                HttpWebResponse response = request.GetResponse() as HttpWebResponse;
                //直到request.GetResponse()程序才开始向目标网页发送Post请求
                Stream responseStream = response.GetResponseStream();
                //创建本地文件写入流
                long totalSize = response.ContentLength;
                int postion = 0;
                byte[] bArr = new byte[1024];
                int size = responseStream.Read(bArr, 0, (int)bArr.Length);

                while (size > 0)
                {
                    postion += size;

                    fs.Write(bArr, 0, size);
                    size = responseStream.Read(bArr, 0, (int)bArr.Length);

                }
                Console.WriteLine();
                //stream.Close();
                fs.Close();
                responseStream.Close();

                return fs.ToArray();
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex);
                return null;
            }
        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="url">下载的路径</param>
        /// <param name="path">下载到的本地位置</param>
        /// <param name="md5">md5</param>
        /// <param name="totalSizeChanged">文件总大小 byte</param>
        /// <param name="currSizeChanged">已经下载大小 byte</param>
        /// <param name="speedChanged">下载速度 byte/s</param>
        /// <param name="elapsedTimeSecChanged">已经消耗的秒数</param>
        /// <param name="remainingTimeSecChanged">预计剩余秒数</param>
        /// <returns></returns>
        public static bool BreakpointDownload(
            string url, string path, string md5,
            Action<long> totalSizeChanged = null,
            Action<long> currSizeChanged = null,
            Action<long> speedChanged = null,
            Action<int> elapsedTimeSecChanged = null,
            Action<int> remainingTimeSecChanged = null)
        {
            //1.下载 md5 文件
            string path_md5 = $"{path}.md5";

            if (File.Exists(path_md5))
            {
                //获取本地 md5
                StreamReader sr = new StreamReader(path_md5, System.Text.Encoding.UTF8);
                string localMd5 = sr.ReadLine();
                localMd5 = localMd5.Trim();
                sr.Close();

                //2. 检测 下载回来的md5 与 本地的md5 是否一致， 一致则断点下载
                if (md5 == localMd5)
                {
                    //相同， 继续下载
                    bool ret = BreakpointDownload(url, path, false, totalSizeChanged, currSizeChanged, speedChanged, elapsedTimeSecChanged, remainingTimeSecChanged);
                    if (ret == true)
                    {
                        //下载完了
                        //把本地的 md5 文件删除
                        File.Delete(path_md5);
                    }
                    return ret;
                } 
            }


            {
                //没有本地 md5 信息，创建
                //保存到 filePath.md5
                StreamWriter sw = new StreamWriter(path_md5, false, System.Text.Encoding.UTF8);
                sw.WriteLine(md5);
                sw.Flush();
                sw.Close();

                //重新下载
                return BreakpointDownload(url, path, true, totalSizeChanged, currSizeChanged, speedChanged, elapsedTimeSecChanged, remainingTimeSecChanged);
            }

        }

        /// <summary>
        /// 
        /// </summary>
        /// <param name="url">下载的路径</param>
        /// <param name="path">下载到的本地位置</param>
        /// <param name="isRedownload">重新下载？</param>
        /// <param name="totalSizeChanged">文件总大小 byte</param>
        /// <param name="currSizeChanged">已经下载大小 byte</param>
        /// <param name="speedChanged">下载速度 byte/s</param>
        /// <param name="elapsedTimeSecChanged">已经消耗的秒数</param>
        /// <param name="remainingTimeSecChanged">预计剩余秒数</param>
        /// <returns></returns>
        public static bool BreakpointDownload(
            string url, string path, bool isRedownload=false,
            Action<long> totalSizeChanged = null,
            Action<long> currSizeChanged =null,
            Action<long> speedChanged = null,
            Action<int> elapsedTimeSecChanged = null,
            Action<int> remainingTimeSecChanged = null)
        {
            string tempPath = System.IO.Path.GetDirectoryName(path);// + @"\temp";
            if (!string.IsNullOrEmpty(tempPath))
            {
                //先新建文件夹
                if(!System.IO.Directory.Exists(tempPath))
                    System.IO.Directory.CreateDirectory(tempPath);
                tempPath += @"\";
            }
            //System.IO.Directory.CreateDirectory(tempPath);  //创建临时文件目录
            string tempFile = $@"{tempPath}{System.IO.Path.GetFileName(path)}.temp"; //临时文件

            if (isRedownload)
            {
                if (System.IO.File.Exists(path))
                {
                    System.IO.File.Delete(path);    //存在则删除
                }
                //重新下载
                if (System.IO.File.Exists(tempFile))
                {
                    System.IO.File.Delete(tempFile);    //存在则删除
                }
            }
            else {
                if (System.IO.File.Exists(path))
                    return true;//已经下载过了
            }

            try
            {
                //FileStream fs = new FileStream(tempFile, FileMode.Append, FileAccess.Write, FileShare.ReadWrite);
                // 设置参数
                HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;

                FileStream fs = new FileStream(tempFile, FileMode.Append, FileAccess.Write, FileShare.ReadWrite);

                request.AddRange(Convert.ToInt32(fs.Length));//接上次下载的字节开始下载文件   

                Stopwatch stopwatch = new Stopwatch();
                stopwatch.Start();
                int elapsedTimeSec = 0;
                //发送请求并获取相应回应数据
                HttpWebResponse response = request.GetResponse() as HttpWebResponse;
                //直到request.GetResponse()程序才开始向目标网页发送Post请求
                Stream responseStream = response.GetResponseStream();

                long downloadSize = 0;
                long currSize = fs.Length;
                long totalSize = response.ContentLength + currSize;
                currSizeChanged?.Invoke(currSize);
                totalSizeChanged?.Invoke(totalSize);
                
                do {
                    byte[] bArr = new byte[1024];
                    int size = responseStream.Read(bArr, 0, (int)bArr.Length);
                    if (size <= 0)
                        break;//没有数据。。。。
                    currSize += size;
                    currSizeChanged?.Invoke(currSize);

                    downloadSize += size;
                    if (elapsedTimeSec != (int)stopwatch.Elapsed.TotalSeconds) {

                        elapsedTimeSec = (int)stopwatch.Elapsed.TotalSeconds;
                        elapsedTimeSecChanged?.Invoke(elapsedTimeSec);
                        //过了1秒
                        long speed = (long)(downloadSize / stopwatch.Elapsed.TotalSeconds);
                        speedChanged?.Invoke(speed);

                        //更新剩余时间
                        int remainingTimeSec = (int)((totalSize - currSize) / speed);
                        remainingTimeSecChanged?.Invoke(remainingTimeSec);
                    }

                    fs.Write(bArr, 0, size);
                } while (true);

                fs.Close();
                responseStream.Close();

                //把临时文件，重命名
                System.IO.File.Move(tempFile, path);
                return true;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
    }
}