2009-08-14 20 views
9

FileSystemWatcherをFTPロケーション(C#)に実装するにはどうすればよいですか?このアイデアは、私がローカルマシンにコピーしたいFTPの場所に何かが追加されたときはいつでもあります。どんなアイディアも参考になります。FTP用FileSystemWatcher

これは以前の質問Selective FTP download using .NETのフォローアップです。

+0

ポーリングタイプのアプローチを使用します。新しいファイルがあるかどうかを確認するには、ftpサイトを定期的にチェックする必要があります。 – jersoft

答えて

14

ポーリングソリューションを実装する必要があります。ここでは、定期的にディレクトリの内容を尋ねます。これを以前の呼び出しのキャッシュリストと比較し、そのようなことが起こったかどうかを判断します。

FTPプロトコルには、残念なことに役立つものは何もありません。

3

FileSystemWatcherを作成する簡単なサービスを作成し、ftpの場所を指定します。

ファイルをアップロードまたは変更すると、サービスでイベントが発生し、そのファイルをローカルマシンにコピーできます。
File.Copyなど

見HAV:this blog

+0

'FileSystemWatcher'はURLで動作しますか? –

+0

UNCの場所で、URLのものではありません。 – Bravax

7

ホストのWindowsオペレーティングシステムでのイベントのために登録することによりFileSystemWatcherクラス作品。したがって、WindowsシステムでホストされているディレクトリへのローカルパスとUNCパスでの作業に限定されています。 FileSystemWatcherのMSDNドキュメントでは、使用できるパスとそのクラスを使用する際の潜在的な問題のいくつかについて説明しています。

FTPサイトの変更をアラートする場合は、監視するファイルまたはフォルダの現在の状態をポーリングメカニズムを使用して尋ねる必要があります。 FTPサイトのスナップショットと変更を比較し、変更を検出したときに同様のイベントを発生させることにより、ファイルの追加と削除のタイミングを確認できます。残念ながら、名前変更イベントは検出できませんが、他の変更はこのように簡単に監視する必要があります。

0

私がこれを処理する方法は、 ".ftpComplete"という1要素のバイト配列をアップロードすることです。 FileSystemWatcherは、 ".ftpComplete"ファイルのみを監視し、実際にアップロードされたファイルを知るために、最後から削除します。 「.ftpComplete」ファイルは1バイトのみであるので、あなたがメインのアップロードされたファイル

 FtpWebRequest request = (FtpWebRequest)FtpWebRequest.Create(
      FTPAddress + "/" + Path.GetFileName(filePath) + ".ftpComplete"); 
     request.Method = WebRequestMethods.Ftp.UploadFile; 
     request.Credentials = new NetworkCredential(username, password); 
     request.UsePassive = true; 
     request.UseBinary = true; 
     request.KeepAlive = false; 
     byte[] buffer = new byte[1]; 
     Stream reqStream = request.GetRequestStream(); 
     reqStream.Write(buffer, 0, buffer.Length); 
     reqStream.Close(); 
2

にする必要が何でも一度それを削除することができますので、それは、程度の速それがFTPサーバー上に作成されてアップロード

public class FtpFileSystemWatcher 
{ 

    public bool IsRunning 
    { 
     get; 
     private set; 
    } 
    public string FtpUserName 
    { 
     get; 
     set; 
    } 
    public string FtpPassword 
    { 
     get; 
     set; 
    } 
    public string FtpLocationToWatch 
    { 
     get; 
     set; 
    } 
    public string DownloadTo 
    { 
     get; 
     set; 
    } 
    public bool KeepOrignal 
    { 
     get; 
     set; 
    } 
    public bool OverwriteExisting 
    { 
     get; 
     set; 
    } 
    public int RecheckIntervalInSeconds 
    { 
     get; 
     set; 
    } 
    private bool DownloadInprogress 
    { 
     get; 
     set; 
    } 

    private System.Timers.Timer JobProcessor; 

    public FtpFileSystemWatcher(string FtpLocationToWatch = "", string DownloadTo = "", int RecheckIntervalInSeconds = 1, string UserName = "", string Password = "", bool KeepOrignal = false, bool OverwriteExisting = false) 
    { 
     this.FtpUserName = UserName; 
     this.FtpPassword = Password; 
     this.FtpLocationToWatch = FtpLocationToWatch; 
     this.DownloadTo = DownloadTo; 
     this.KeepOrignal = KeepOrignal; 
     this.RecheckIntervalInSeconds = RecheckIntervalInSeconds; 
     this.OverwriteExisting = OverwriteExisting; 

     if (this.RecheckIntervalInSeconds < 1) this.RecheckIntervalInSeconds = 1; 
    } 

    public void StartDownloading() 
    { 

     JobProcessor = new Timer(this.RecheckIntervalInSeconds * 1000); 
     JobProcessor.AutoReset = false; 
     JobProcessor.Enabled = false; 
     JobProcessor.Elapsed += (sender, e) => 
     { 
      try 
      { 

       this.IsRunning = true; 

       string[] FilesList = GetFilesList(this.FtpLocationToWatch, this.FtpUserName, this.FtpPassword); 

       if (FilesList == null || FilesList.Length < 1) 
       { 
        return; 
       } 

       foreach (string FileName in FilesList) 
       { 
        if (!string.IsNullOrWhiteSpace(FileName)) 
        { 
         DownloadFile(this.FtpLocationToWatch, this.DownloadTo, FileName.Trim(), this.FtpUserName, this.FtpPassword, this.OverwriteExisting); 

         if (!this.KeepOrignal) 
         { 
          DeleteFile(Path.Combine(this.FtpLocationToWatch, FileName.Trim()), this.FtpUserName, this.FtpPassword); 
         } 
        } 
       } 

       this.IsRunning = false; 
       JobProcessor.Enabled = true;      
      } 

      catch (Exception exp) 
      { 
       this.IsRunning = false; 
       JobProcessor.Enabled = true; 
       Console.WriteLine(exp.Message); 
      } 
     }; 

     JobProcessor.Start(); 
    } 

    public void StopDownloading() 
    { 
     try 
     { 
      this.JobProcessor.Dispose(); 
      this.IsRunning = false; 
     } 
     catch { } 
    } 

    private void DeleteFile(string FtpFilePath, string UserName, string Password) 
    { 
     FtpWebRequest FtpRequest; 
     FtpRequest = (FtpWebRequest)FtpWebRequest.Create(new Uri(FtpFilePath)); 
     FtpRequest.UseBinary = true; 
     FtpRequest.Method = WebRequestMethods.Ftp.DeleteFile; 

     FtpRequest.Credentials = new NetworkCredential(UserName, Password); 
     FtpWebResponse response = (FtpWebResponse)FtpRequest.GetResponse(); 
     response.Close(); 

    } 
    private void DownloadFile(string FtpLocation, string FileSystemLocation, string FileName, string UserName, string Password, bool OverwriteExisting) 
    { 
     try 
     { 
      const int BufferSize = 2048; 
      byte[] Buffer = new byte[BufferSize]; 

      FtpWebRequest Request; 
      FtpWebResponse Response; 

      if (File.Exists(Path.Combine(FileSystemLocation, FileName))) 
      { 
       if (OverwriteExisting) 
       { 
        File.Delete(Path.Combine(FileSystemLocation, FileName)); 
       } 
       else 
       { 
        Console.WriteLine(string.Format("File {0} already exist.", FileName)); 
        return; 
       } 
      } 

      Request = (FtpWebRequest)FtpWebRequest.Create(new Uri(Path.Combine(FtpLocation, FileName))); 
      Request.Credentials = new NetworkCredential(UserName, Password); 
      Request.Proxy = null; 
      Request.Method = WebRequestMethods.Ftp.DownloadFile; 
      Request.UseBinary = true; 

      Response = (FtpWebResponse)Request.GetResponse(); 

      using (Stream s = Response.GetResponseStream()) 
      { 
       using (FileStream fs = new FileStream(Path.Combine(FileSystemLocation, FileName), FileMode.CreateNew, FileAccess.ReadWrite)) 
       { 
        while (s.Read(Buffer, 0, BufferSize) != -1) 
        { 
         fs.Write(Buffer, 0, BufferSize); 
        } 
       } 
      } 
     } 
     catch { } 

    } 
    private string[] GetFilesList(string FtpFolderPath, string UserName, string Password) 
    { 
     try 
     { 
      FtpWebRequest Request; 
      FtpWebResponse Response; 

      Request = (FtpWebRequest)FtpWebRequest.Create(new Uri(FtpFolderPath)); 
      Request.Credentials = new NetworkCredential(UserName, Password); 
      Request.Proxy = null; 
      Request.Method = WebRequestMethods.Ftp.ListDirectory; 
      Request.UseBinary = true; 

      Response = (FtpWebResponse)Request.GetResponse(); 
      StreamReader reader = new StreamReader(Response.GetResponseStream()); 
      string Data = reader.ReadToEnd(); 

      return Data.Split('\n'); 
     } 
     catch 
     { 
      return null; 
     } 
    } 


} 
0

FTPサイトで変更を監視するには、Robo-FTPスクリプトを使用できます。以下は、変更が検出されたときに電子メールを送信するサンプルスクリプトへのリンクです。http://kb.robo-ftp.com/script_library/show/40

リンクした前の質問を見ました。 Robo-FTPサンプルを変更し、/ splitオプションを付けてSETLEFTコマンドを使用して、変更されたファイルのフォルダ名とISOファイル番号を解析し、ファイルを適切な場所に移動できるようにする必要があります。

4

FileSystemWatcherなどを使用することはできません.FTPプロトコルには、リモートディレクトリの変更についてクライアントに通知するためのAPIがないためです。

できることは、定期的にリモートツリーを繰り返して変更を見つけることです。

リモートツリーの再帰的なリストをサポートするFTPクライアントライブラリを使用すると、実際に実装するのはむしろ簡単です。残念ながら、組み込みの.NET FTPクライアントであるFtpWebRequestはありません。たとえば、WinSCP .NET assemblyバージョン5.9(またはそれ以降)の場合は、Session.EnumerateRemoteFiles methodを使用できます。

記事Watching for changes in SFTP/FTP server参照してください:あなたが実際には変更をダウンロードしたい場合、それは方法簡単です、

// Setup session options 
SessionOptions sessionOptions = new SessionOptions 
{ 
    Protocol = Protocol.Ftp, 
    HostName = "example.com", 
    UserName = "user", 
    Password = "password", 
}; 

using (Session session = new Session()) 
{ 
    // Connect 
    session.Open(sessionOptions); 

    List<string> prevFiles = null; 

    while (true) 
    { 
     // Collect file list 
     List<string> files = 
      session.EnumerateRemoteFiles(
       "/remote/path", "*.*", EnumerationOptions.AllDirectories) 
      .Select(fileInfo => fileInfo.FullName) 
      .ToList(); 
     if (prevFiles == null) 
     { 
      // In the first round, just print number of files found 
      Console.WriteLine("Found {0} files", files.Count); 
     } 
     else 
     { 
      // Then look for differences against the previous list 
      IEnumerable<string> added = files.Except(prevFiles); 
      if (added.Any()) 
      { 
       Console.WriteLine("Added files:"); 
       foreach (string path in added) 
       { 
        Console.WriteLine(path); 
       } 
      } 

      IEnumerable<string> removed = prevFiles.Except(files); 
      if (removed.Any()) 
      { 
       Console.WriteLine("Removed files:"); 
       foreach (string path in removed) 
       { 
        Console.WriteLine(path); 
       } 
      } 
     } 

     prevFiles = files; 

     Console.WriteLine("Sleeping 10s..."); 
     Thread.Sleep(10000); 
    } 
} 

(私はWinSCPのの著者です)


もののを。ループ内でSession.SynchronizeDirectoriesを使用してください。

session.SynchronizeDirectories(
    SynchronizationMode.Local, "/remote/path", @"C:\local\path", true).Check(); 

あなたがサードパーティのライブラリを使用したくない場合は、FtpWebRequestの制限を行う必要があります。リモートディレクトリツリーを再帰的にリストする方法の例については、FtpWebRequestを参照してください。C# Download all files and subdirectories through FTPへの回答を参照してください。