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();
}
}
}
}