Как я могу реализовать FileSystemWatcher для местоположения FTP (на С#). Идея - всякий раз, когда что-либо добавляется в место FTP, я хочу скопировать его на локальный компьютер. Любые идеи будут полезны.
Это продолжение моего предыдущего вопроса Селективная загрузка FTP с использованием .NET.
Вам нужно будет выполнить опрос, где вы периодически будете запрашивать содержимое каталога. Сравните это с кэшированным списком из предыдущего вызова и определите, что произошло в этом случае.
В протоколе FTP нет ничего, что могло бы помочь вам с этим.
Класс FileSystemWatcher работает, регистрируя события с операционной системой хоста Windows. Таким образом, он ограничен работой локальных путей и путей UNC к каталогам, размещенным в системах Windows. Документация MSDN на FileSystemWatcher объясняет пути, которые вы можете использовать, и некоторые из потенциальных проблем с использованием класса.
Если вы хотите получать уведомления об изменениях на FTP-сайте, вам нужно будет использовать механизм опроса, чтобы узнать текущий статус файлов или папок, которые вы заинтересованы в мониторинге. Вы сможете увидеть, когда файлы будут добавлены и удалены путем сравнения снимков FTP-сайта для изменений и повышения похожих событий при обнаружении изменений. К сожалению, вы не сможете обнаружить события переименования, но другие изменения должны быть простыми, чтобы отслеживать этот способ.
Вы не можете использовать FileSystemWatcher или любой другой способ, потому что у протокола FTP нет API для уведомления клиента об изменениях в удаленном каталоге.
Все, что вы можете сделать, - это периодически перебирать удаленное дерево и находить изменения.
Это на самом деле довольно легко реализовать, если вы используете клиентскую библиотеку FTP, которая поддерживает рекурсивный листинг удаленного дерева. К сожалению, встроенный FTP-клиент .NET FtpWebRequest этого не делает. Но, например, в сборке WinSCP.NET версии 5.9 (или новее) вы можете использовать метод Session.EnumerateRemoteFiles.
См. статью Отслеживание изменений на SFTP/FTP-сервере:
// 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 см. в моем ответе на С# Загрузка всех файлов и подкаталогов по FTP.
Напишите простую службу для создания FileSystemWatcher, указывая на ваше местоположение ftp.
Затем, когда файл загружен или изменен, в вашей службе будет запущено событие, которое затем можно использовать для копирования файла на локальный компьютер.
File.Copy и т.д.
Взгляните на: этот блог
Вы можете отслеживать местоположение 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;
}
}
}
Способ, которым я обрабатываю это, - загрузить один элементный байтовый массив с именем ".ftpComplete" . FileSystemWatcher наблюдает только за файлами ".ftpComplete" и заставляет их отключать, чтобы узнать фактический загруженный файл. Так как файл ".ftpComplete" имеет только 1 байт, он загружается примерно так же быстро, как он создается на FTP-сервере, поэтому его можно удалить, как только вы сделаете все, что вам нужно, с основным загруженным файлом
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();
Вы можете использовать Robo-FTP script для отслеживания FTP-сайта для изменений. Вот ссылка на образец script, который отправляет электронное письмо при обнаружении изменения: http://kb.robo-ftp.com/script_library/show/40
Я посмотрел на предыдущий вопрос, который вы связали. Я думаю, вы должны иметь возможность модифицировать образец Robo-FTP и использовать команду SETLEFT с параметром /split, чтобы заставить ее разобрать папку имя и номер файла ISO измененного файла, а затем переместите файл в нужное место.
кто-нибудь знает, как я могу подключиться к ftp-серверу без пароля и имени пользователя? Я попробовал те:
SessionOptions sessionOptions = new SessionOptions {Protocol = Protocol.Ftp, HostName = "example.com", UserName = "", Password = "",};
или же
SessionOptions sessionOptions = new SessionOptions {Protocol = Protocol.Ftp, HostName = "example.com",};
Но у меня все та же ошибка...