首页 > > 网络编程 > Php编程 >

基于HTTP的断点传输

2018-06-22 04:36:09来源：未知阅读 ()

最近项目需要做一个类似于迅雷的文件下载功能，这类需求可能比较常见，希望可以帮助到有需要的同学

要求：

1.支持断点传输

2. 多文件同时下载

3. 由于是客户内部试用，服务器只支持HTTP文件下载不支持FTP文件（并没有用户权限的要求）

由于根据服务器传来的Json字符串解析后进行下载，首先构建Json对象，推荐一个库Newtonsoft.Json

 public class DownloadFile
    {
        [JsonProperty("police_num")]
        public string PoliceNumber { get; set; }

        [JsonProperty("equipment_num")]
        public string EquipmentNumber { get; set; }

        [JsonProperty("upload_date")]
        public DateTime UploadDateTime { get; set; }

        [JsonProperty("type")]
        public string FileType { get; set; }

        [JsonProperty("file_name")]
        public string FileName { get; set; }

        [JsonProperty("file_path")]
        public string FilePath { get; set; }
    }

JsonProperty不区分大小写

public class DownloadTask : ObservableObject
    {
        /// <summary>
        /// </summary>
        public static readonly int BufferSize = 1024;

        /// <summary>
        ///     一次请求大小,每次请求100kb
        /// </summary>
        public static long Step = 1024*100;

        private int _process;

        /// <summary>
        ///     下载文件参数
        /// </summary>
        public DownloadFile DownloadFile { get; set; }

        /// <summary>
        ///     下载文件状态
        /// </summary>
        public SegmentState SegmentState { get; set; }

        /// <summary>
        ///     默认存储路径
        /// </summary>
        public string DefaultDirectory { get; set; }

        /// <summary>
        ///     当前进度
        /// </summary>
        public long CurrentSize { get; set; }

        /// <summary>
        ///     文件流对象，用于生成文件
        /// </summary>
        public FileStream FileStream { get; set; }

        /// <summary>
        ///     下载起始位置
        /// </summary>
        public long RangeFrom { get; set; }

        /// <summary>
        ///     总大小
        /// </summary>
        public long TotalSize { get; set; }

        /// <summary>
        ///     链接地址
        /// </summary>
        public string Url { get; set; }

        /// <summary>
        ///     界面显示进度
        /// </summary>
        public int Process
        {
            get { return _process; }
            set
            {
                _process = value;
                RaisePropertyChanged("Process");
            }
        }
    }


下载服务类，DownloaderService.cs，功能包括启动下载，暂停，针对文件是否存在进行初始化，获取文件大小方便界面显示

 public class DownloaderService
    {

        public void OnStart(DownloadTask downloadTask)
        {
            if (!InitService(downloadTask)) return;
            var downloadThread = new Thread(BeginDownloadFile) { IsBackground = true };
            downloadThread.Start(downloadTask);
        }

        public void OnStop(DownloadTask downloadTask)
        {
            downloadTask.SegmentState = SegmentState.Paused;
        }

        private bool InitService(DownloadTask downloadTask)
        {
            try
            {
                if (string.IsNullOrEmpty(downloadTask.Url))
                {
                    return false;
                }

                downloadTask.DownloadFile.FileName = downloadTask.Url.Substring(downloadTask.Url.LastIndexOf('/') + 1);

                var fullName = Path.Combine(downloadTask.DefaultDirectory, downloadTask.DownloadFile.FileName);

                if (File.Exists(fullName))
                {
                    if (downloadTask.TotalSize == 0)
                    {
                        GetTotalSize(downloadTask);
                    }
                    if (downloadTask.CurrentSize == downloadTask.TotalSize)
                    {
                        if (MessageBox.Show("文件已经存在是否覆盖此文件", "TCL", MessageBoxButton.YesNo, MessageBoxImage.Information) !=
                        MessageBoxResult.Yes)
                            return false;
                        File.Delete(fullName);
                        downloadTask.CurrentSize = 0;
                    }
                    downloadTask.FileStream = new FileStream(fullName, FileMode.OpenOrCreate, FileAccess.ReadWrite);
                    downloadTask.SegmentState = SegmentState.Downloading;
                    return true;
                }
                downloadTask.SegmentState = SegmentState.Downloading;
                downloadTask.FileStream = new FileStream(fullName, FileMode.OpenOrCreate, FileAccess.ReadWrite);
                return true;
            }
            catch (Exception ex)
            {
                LogLightConsole.WriteLog(ex.ToString(), EunmMsgType.Error);
                return false;
            }
        }

        private void BeginDownloadFile(object obj)
        {
            try
            {
                var downloadTask = (DownloadTask)obj;
                while (true)
                {
                    if (downloadTask.SegmentState == SegmentState.Paused)
                    {
                        downloadTask.FileStream.Close();
                        break;
                    }
                    //从0计数，需要减一
                    var from = downloadTask.CurrentSize;
                    if (from < 0)
                    {
                        from = 0;
                    }

                    var to = downloadTask.CurrentSize + DownloadTask.Step - 1;
                    if (to >= downloadTask.TotalSize && downloadTask.TotalSize > 0)
                    {
                        to = downloadTask.TotalSize - 1;
                    }
                    if (downloadTask.TotalSize == 0)
                    {
                        GetTotalSize(downloadTask);
                    }
                    if (from >= downloadTask.TotalSize || downloadTask.CurrentSize >= downloadTask.TotalSize)
                    {
                        downloadTask.SegmentState = SegmentState.Finished;
                        downloadTask.FileStream.Close();
                        downloadTask.Process = 100;
                        return;
                    }

                    var request = (HttpWebRequest)WebRequest.Create(downloadTask.Url);
                    //request.Method = "GET";            
                    request.AddRange("bytes", from, to);
                    request.Timeout = 1000 * 20;
                    var response = (HttpWebResponse)request.GetResponse();
                    var buffer = new byte[1024];
                    using (var stream = response.GetResponseStream())
                    {
                        if (stream != null)
                        {
                            var size = stream.Read(buffer, 0, buffer.Length);
                            while (size > 0)
                            {
                                //只将读出的字节写入文件
                                downloadTask.FileStream.Write(buffer, 0, size);
                                downloadTask.CurrentSize += size;
                                size = stream.Read(buffer, 0, buffer.Length);
                                downloadTask.Process = (int)(downloadTask.CurrentSize * 100 / downloadTask.TotalSize);
                                downloadTask.FileStream.Flush();
                            }
                        }
                        //如果返回的response头中Content-Range值为空，说明服务器不支持Range属性，不支持断点续传,返回的是所有数据
                        if (response.Headers["Content-Range"] == null)
                        {
                            downloadTask.SegmentState = SegmentState.Finished;
                        }
                    }
                }

            }
            catch (Exception ex)
            {
                LogLightConsole.WriteLog("BeginDownloadFile" + ex, EunmMsgType.Error);
            }
        }

        /// <summary>
        ///     获取文件总大小
        /// </summary>
        public void GetTotalSize(DownloadTask downloadTask)
        {
            var request = (HttpWebRequest)WebRequest.Create(downloadTask.Url);
            //request.Method = "POST";
            //request.Headers.Add("charset:" + "utf-8");
            request.Timeout = 1000 * 20;
            var response = (HttpWebResponse)request.GetResponse();
            downloadTask.TotalSize = response.ContentLength;
        }
    }

HTTP 1.1版本本身已经扩展了断点传输功能，但是这需要服务器同时也支持，这只是提供了一个简单的例子，具体的针对数据上下文以及成功失败的callback函数，就是做一下委托封装用就好，如果具体使用有什么问题可以私信我，谢谢大家支持！

response.Headers["Content-Range"] == null 说明服务器不支持断点传输

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有

上一篇：C#学习笔记-图像处理篇（一）绘制公章

下一篇：.Net Core 之图形验证码

IDC资讯：主机资讯注册资讯托管资讯 vps资讯网站建设

网站运营：建站经验策划盈利搜索优化网站推广免费资源

网站联盟：联盟新闻联盟介绍联盟点评网赚技巧

行业资讯：搜索引擎网络游戏电子商务广告传媒

网络编程： Asp.Net编程 Asp编程 Php编程 Xml编程 Access Mssql Mysql 其它

服务器技术： Web服务器 Ftp服务器 Mail服务器 Dns服务器安全防护

软件技巧：其它软件 Word Excel Powerpoint Ghost Vista QQ空间 QQ FlashGet 迅雷

网页制作： FrontPages Dreamweaver Javascript css photoshop fireworks Flash

程序设计： Java技术 C/C++ VB delphi

网络知识：网络协议网络安全网络管理组网方案 Cisco技术

操作系统： Win2000 WinXP Win2003 Mac OS Linux FreeBSD

热门词条

最新资讯

热门关注

热门标签