WebClient.DownloadFileTaskAsync() FTP прерывается загрузка - C#
Формулировка задачи:
Есть список ссылок на файлы ftp. Есть необходимость загрузить эти файлы асинхронно, при этом отобразить прогресс загрузки каждого.
Побыстрому накидал вот такой класс:
Создаю ObservableColletion с объектами этого класса, создаю ListView, в его ItemsSource сую эту коллекцию, в CellDataTemplate есть прогрессбар и текстблок на которые бинжу свойства класса (Progress и ProgressStr). В принципе все работает, файлы асинхронно качаются, прогресс отображается. Но есть 2 нюанса.
Во-первых, файлы скачиваются не равномерно, а прогресс как то скачет. Качается качается, на секунды 2 зависает, потом продолжает качаться и так далее. Но это не страшно. На локальном фтп сервере даже файлы размером > ГБ качаются исправно, прогресс отображается.
Во-вторых, при попытке загрузить с интернета файлы размером > ~60 Мб происходят странные вещи. Файл качается процентов на 10-12 (каждый раз по разному) и процесс загрузки зависает на вечно. При этом файлы меньшего размера скачиваются нормально. Скорость интернет соединения > 10 Мбит. Тот же тоталкоммандер с этого компьютера данные фтп файлы качает за несколько секунд без сбоев.
В чем может быть проблема? Может я как то не правильно организую загрузку файлов?
using System; using System.Net; using System.Runtime.CompilerServices; using System.ComponentModel; namespace FtpSync2 { public class FtpFile2 : INotifyPropertyChanged { public event PropertyChangedEventHandler PropertyChanged; private void NotifyPropertyChanged([CallerMemberName] String propertyName = "") { if (PropertyChanged != null) { PropertyChanged(this, new PropertyChangedEventArgs(propertyName)); } } private double progress; // прогресс загрузки в процентах для прогрессбара (от 0 до 100) private string progressStr; // прогресс загрузки в виде строки для человека public double Progress { get { return this.progress; } set { this.progress = value; NotifyPropertyChanged("Progress"); } } public string ProgressStr { get { return this.progressStr; } set { this.progressStr = value; NotifyPropertyChanged("ProgressStr"); } } public string Uri { get; set; } // ссылка на файл public string FileName { get; set; } // имя файла public string Path { get; set; } // путь для сохранения // Функция конвертирует размер файла в удобный для человека вид private static string GetSizeStr(long size) { string[] suf = { "B", "KB", "MB", "GB", "TB", "PB", "EB" }; if (size == 0) return "0" + suf[0]; long bytes = Math.Abs(size); int place = Convert.ToInt32(Math.Floor(Math.Log(bytes, 1024))); double num = Math.Round(bytes / Math.Pow(1024, place), 1); return (Math.Sign(size) * num).ToString("F1") + suf[place]; } // конструктор класса, сразу же запускает загрузку public FtpFile2(string uri, string path, long size, NetworkCredential credentials) { this.Uri = uri; // ссылка на файл this.FileName = uri.Substring(uri.LastIndexOf("/") + 1); // имя файла this.Path = path; // путь для сохранения WebClient pwc = new WebClient(); pwc.Credentials = credentials; pwc.DownloadProgressChanged += new DownloadProgressChangedEventHandler( (sender, e) => { this.Progress = ((double)e.BytesReceived / size) * 100; this.ProgressStr = String.Format("{0:F1}% ({1} из {2})", this.Progress, GetSizeStr(e.BytesReceived), GetSizeStr(size)); } ); pwc.DownloadFileCompleted += new AsyncCompletedEventHandler( (sender, e) => { this.Progress = 100; this.ProgressStr = "Загрузка завершена."; } ); pwc.DownloadFileTaskAsync(uri, path); } } }
Решение задачи: «WebClient.DownloadFileTaskAsync() FTP прерывается загрузка»
textual
Листинг программы
using System; using System.Diagnostics; using System.IO; using System.Net; using System.Runtime.InteropServices; namespace ConsoleApplication13 { class Program { static void Main(string[] args) { var file = "http://window.edu.ru/resource/367/20367/files/0007_091.pdf".DownloadFile(); using (var sw = new BinaryWriter(new FileStream("D:\\test2.pdf", FileMode.Create))) { sw.Write(file, 0, file.Length); } } } public static class WebUtility { public static byte[] DownloadFile(this string url) { var request = WebRequest.Create(url); using (var response = request.GetResponse()) using (var responseStream = response.GetResponseStream()) { return responseStream.ReadFully(); } } public static byte[] ReadFully(this Stream input) { byte[] buffer = new byte[16 * 1024]; using (var ms = new MemoryStream()) { int read; while ((read = input.Read(buffer, 0, buffer.Length)) > 0) { ms.Write(buffer, 0, read); } return ms.ToArray(); } } } }
ИИ поможет Вам:
- решить любую задачу по программированию
- объяснить код
- расставить комментарии в коде
- и т.д