Подтвердить что ты не робот

Копирование файла с индикатором выполнения

Я использовал этот код:

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Windows.Forms;
using System.IO;

namespace WindowsApplication1 {
  public partial class Form1 : Form {
    // Class to report progress
    private class UIProgress {
      public UIProgress(string name_, long bytes_, long maxbytes_) {
        name = name_; bytes = bytes_; maxbytes = maxbytes_;
      }
      public string name;
      public long bytes;
      public long maxbytes;
    }
    // Class to report exception {
    private class UIError {
      public UIError(Exception ex, string path_) {
        msg = ex.Message; path = path_; result = DialogResult.Cancel;
      }
      public string msg;
      public string path;
      public DialogResult result;
    }
    private BackgroundWorker mCopier;
    private delegate void ProgressChanged(UIProgress info);
    private delegate void CopyError(UIError err);
    private ProgressChanged OnChange;
    private CopyError OnError;

    public Form1() {
      InitializeComponent();
      mCopier = new BackgroundWorker();
      mCopier.DoWork += Copier_DoWork;
      mCopier.RunWorkerCompleted += Copier_RunWorkerCompleted;
      mCopier.WorkerSupportsCancellation = true;
      OnChange += Copier_ProgressChanged;
      OnError += Copier_Error;
      button1.Click += button1_Click;
      ChangeUI(false);
    }

    private void Copier_DoWork(object sender, DoWorkEventArgs e) {
      // Create list of files to copy
      string[] theExtensions = { "*.jpg", "*.jpeg", "*.bmp", "*.png", "*.gif" };
      List<FileInfo> files = new List<FileInfo>();
      string path = Environment.GetFolderPath(Environment.SpecialFolder.MyDocuments);
      DirectoryInfo dir = new DirectoryInfo(path);
      long maxbytes = 0;
      foreach (string ext in theExtensions) {
        FileInfo[] folder = dir.GetFiles(ext, SearchOption.AllDirectories);
        foreach (FileInfo file in folder) {
          if ((file.Attributes & FileAttributes.Directory) != 0) continue;
          files.Add(file);
          maxbytes += file.Length;
        }
      }
      // Copy files
      long bytes = 0;
      foreach (FileInfo file in files) {
        try {
          this.BeginInvoke(OnChange, new object[] { new UIProgress(file.Name, bytes, maxbytes) });
          File.Copy(file.FullName, @"c:\temp\" + file.Name, true);
        }
        catch (Exception ex) {
          UIError err = new UIError(ex, file.FullName); 
          this.Invoke(OnError, new object[] { err });
          if (err.result == DialogResult.Cancel) break;
        }
        bytes += file.Length;
      }
    }
    private void Copier_ProgressChanged(UIProgress info) {
      // Update progress
      progressBar1.Value = (int)(100.0 * info.bytes / info.maxbytes);
      label1.Text = "Copying " + info.name;
    }
    private void Copier_Error(UIError err) {
      // Error handler
      string msg = string.Format("Error copying file {0}\n{1}\nClick OK to continue copying files", err.path, err.msg);
      err.result = MessageBox.Show(msg, "Copy error", MessageBoxButtons.OKCancel, MessageBoxIcon.Exclamation);
    }
    private void Copier_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) {
      // Operation completed, update UI
      ChangeUI(false);
    }
    private void ChangeUI(bool docopy) {
      label1.Visible = docopy;
      progressBar1.Visible = docopy;
      button1.Text = docopy ? "Cancel" : "Copy";
      label1.Text = "Starting copy...";
      progressBar1.Value = 0;
    }
    private void button1_Click(object sender, EventArgs e) {
      bool docopy = button1.Text == "Copy";
      ChangeUI(docopy);
      if (docopy) mCopier.RunWorkerAsync();
      else mCopier.CancelAsync();
    }
  }
}

размещен здесь (тот, что nobugz опубликовал) в копировании файлов и отображении статуса в строке состояния.

Я хотел постоянно увеличивать значение индикатора выполнения при копировании, особенно больших файлов. В этом примере кода происходит то, что значение индикатора выполнения останавливается на каждом скопированном файле, а после копирования одного файла оно увеличивается до размера следующего копируемого файла. Я хотел, чтобы он работал так же, как CopyFileEx в Windows, чтобы индикатор выполнения непрерывно увеличивался при копировании (я не могу использовать CopyFileEx потому что хотел иметь собственную реализацию).

4b9b3361

Ответ 1

Вам нужно что-то вроде этого:

    public delegate void ProgressChangeDelegate(double Persentage, ref bool Cancel);
    public delegate void Completedelegate();

    class CustomFileCopier
    {
        public CustomFileCopier(string Source, string Dest)
        {
            this.SourceFilePath = Source;
            this.DestFilePath = Dest;

            OnProgressChanged += delegate { };
            OnComplete += delegate { };
        }

        public void Copy()
        {
            byte[] buffer = new byte[1024 * 1024]; // 1MB buffer
            bool cancelFlag = false;

            using (FileStream source = new FileStream(SourceFilePath, FileMode.Open, FileAccess.Read))
            {
                long fileLength = source.Length;
                using (FileStream dest = new FileStream(DestFilePath, FileMode.CreateNew, FileAccess.Write))
                {
                    long totalBytes = 0;
                    int currentBlockSize = 0;

                    while ((currentBlockSize = source.Read(buffer, 0, buffer.Length)) > 0)
                    {
                        totalBytes += currentBlockSize;
                        double persentage = (double)totalBytes * 100.0 / fileLength;

                        dest.Write(buffer, 0, currentBlockSize);

                        cancelFlag = false;
                        OnProgressChanged(persentage, ref cancelFlag);

                        if (cancelFlag == true)
                        {
                            // Delete dest file here
                            break;
                        }
                    }
                }
            }

            OnComplete();
        }

        public string SourceFilePath { get; set; }
        public string DestFilePath { get; set; }

        public event ProgressChangeDelegate OnProgressChanged;
        public event Completedelegate OnComplete;
    }

Просто запустите его в отдельном потоке и подпишитесь на событие OnProgressChanged.

Ответ 2

Мне нравится это решение, потому что

Механизм копирования находится в рамках

public delegate void IntDelegate(int Int);

public static event IntDelegate FileCopyProgress;
public static void CopyFileWithProgress(string source, string destination)
{
    var webClient = new WebClient();
    webClient.DownloadProgressChanged += DownloadProgress;
    webClient.DownloadFileAsync(new Uri(source), destination);
}

private static void DownloadProgress(object sender, DownloadProgressChangedEventArgs e)
{
    if(FileCopyProgress != null)
        FileCopyProgress(e.ProgressPercentage);
}

Пути UNC

Это должно работать с путями UNC до тех пор, пока настроены разрешения. Если нет, вы получите эту ошибку, и в этом случае я проголосую за маршрут пользователя с аутентифицированным запросом.

System.UnauthorizedAccessException: доступ к пути '\ testws01\c $\ foo' отрицается.

ASP.NET не имеет права доступа к запрашиваемому ресурсу. Рассмотрим предоставление прав доступа ресурсу к запросу ASP.NET идентичность. ASP.NET имеет базовый идентификатор процесса (обычно {MACHINE}\ASPNET для IIS 5 или сетевой службы на IIS 6 и IIS 7 и настроенный идентификатор пула приложений в IIS 7.5), который используется, если приложение не олицетворяет собой. Если приложение выдавая себя за помощью <identity impersonate="true"/>, тождество будет анонимный пользователь (обычно IUSR_MACHINENAME) или аутентифицированный запросить пользователя.

Ответ 3

Создание собственной логики копирования файлов с использованием 2 потоков, представленных Gal, является жизнеспособным вариантом, но его не рекомендуется исключительно потому, что существует очень сложная операционная система Windows, оптимизированная по надежности, безопасности и производительности с именем CopyFileEx.

который сказал в следующей статье: http://msdn.microsoft.com/en-us/magazine/cc163851.aspx они делают именно то, что вы хотите, но, конечно, вам нужно использовать CopyFileEx

Удачи.

** РЕДАКТИРОВАТЬ ** (исправлен мой ответ, плохо виттен)

Ответ 4

Вы можете копировать части потока файлов из каждого файла и обновлять после каждого обновленного "куска". Таким образом, он будет более непрерывным - вы также можете легко вычислить относительный размер текущего "куска", который вы копируете относительно общего размера потока, чтобы показать правильный процент.

Ответ 5

Здесь оптимизированное решение, использующее расширения .NET и двойной буфер для лучшей производительности. Новая перегрузка CopyTo добавляется в FileInfo с действием, которое указывает прогресс только тогда, когда оно изменилось.

Эта примерная реализация в WPF с индикатором выполнения с именем progressBar1, который выполняет операцию копирования в фоновом режиме.

private FileInfo _source = new FileInfo(@"C:\file.bin");
private FileInfo _destination = new FileInfo(@"C:\file2.bin");

private void CopyFile()
{
  if(_destination.Exists)
    _destination.Delete();

  Task.Run(()=>{
    _source.CopyTo(_destination, x=>Dispatcher.Invoke(()=>progressBar1.Value = x));
  }).GetAwaiter().OnCompleted(() => MessageBox.Show("File Copied!"));
}

Вот пример консольного приложения

class Program
{
  static void Main(string[] args)
  {
    var _source = new FileInfo(@"C:\Temp\bigfile.rar");
    var _destination = new FileInfo(@"C:\Temp\bigfile2.rar");

    if (_destination.Exists) _destination.Delete();

    _source.CopyTo(_destination, x => Console.WriteLine($"{x}% Complete"));
    Console.WriteLine("File Copied.");
  }
}

Чтобы использовать, создайте новый файл, например FileInfoExtensions.cs, и добавьте этот код:

public static class FileInfoExtensions
{
  public static void CopyTo(this FileInfo file, FileInfo destination, Action<int> progressCallback)
  {
    const int bufferSize = 1024 * 1024;  //1MB
    byte[] buffer = new byte[bufferSize], buffer2 = new byte[bufferSize];
    bool swap = false;
    int progress = 0, reportedProgress = 0, read = 0;
    long len = file.Length;
    float flen = len;
    Task writer = null;

    using (var source = file.OpenRead())
    using (var dest = destination.OpenWrite())
    {
      dest.SetLength(source.Length);
      for (long size = 0; size < len; size += read)
      {
        if ((progress = ((int)((size / flen) * 100))) != reportedProgress)
          progressCallback(reportedProgress = progress);
        read = source.Read(swap ? buffer : buffer2, 0, bufferSize);
        writer?.Wait();  // if < .NET4 // if (writer != null) writer.Wait(); 
        writer = dest.WriteAsync(swap ? buffer : buffer2, 0, read);
        swap = !swap;
      }
      writer?.Wait();  //Fixed - Thanks @sam-hocevar
    }
  }
}

Двойной буфер работает, используя один поток для чтения и один поток для записи, поэтому максимальная скорость продиктована только медленнее. Используются два буфера (двойной буфер), гарантируя, что потоки чтения и записи никогда не будут использовать один и тот же буфер одновременно.

Пример: код читается в буфере 1, а затем, когда чтение завершается, операция записи начинает записывать содержимое буфера 1. Без записи завершения записи буфер заменяется на буфер 2, и данные считываются в буфер 2, в то время как буфер 1 все еще написано. Как только чтение завершается в буфере 2, он ожидает завершения записи в буфере 1, начинает писать буфер 2, и процесс повторяется. По сути, 1 поток всегда читает, и каждый всегда пишет.

WriteAsync использует перекрывающиеся ввода-вывода, который использует порты завершения ввода/вывода, которые полагаются на аппаратное обеспечение для выполнения асинхронных операций, а не потоков, что делает это очень эффективным. TL;DR: я солгал, что есть 2 потока, но концепция одинаков.

Ответ 6

вы можете использовать диспетчер для обновления вашего ProgressBar.

UpdateProgressBarDelegate updatePbDelegate = new UpdateProgressBarDelegate(ProgressBar1.SetValue);

Dispatcher.Invoke(updatePbDelegate, System.Windows.Threading.DispatcherPriority.Background, new object[] { ProgressBar.ValueProperty, value });