devbox
Cpp五条
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

C# 利用FTP自动下载xml文件后利用 FileSystemWatcher 监控目录下文件变化并自动更新数据库_c#filesystemwatcher能不能监听ftp

作者：Cpp五条 | 2024-03-06 15:27:48

赞

踩

c#filesystemwatcher能不能监听ftp
  1. using FtpLib;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.ComponentModel;
  5. using System.Data;
  6. using System.Diagnostics;
  7. using System.IO;
  8. using System.Linq;
  9. using System.ServiceProcess;
  10. using System.Text;
  11. using System.Threading;
  12. using System.Threading.Tasks;
  13.  
  14. namespace WindowsService1
  15. {
  16. 	public partial class Service1 : ServiceBase
  17. 	{
  18. 		private int TimeoutMillis = 2000; //定时器触发间隔
  19. 		private int _countFileChangeEvent = 0, _countTimerEvent = 0;
  20. 		System.IO.FileSystemWatcher fsw = new System.IO.FileSystemWatcher();
  21. 		System.Threading.Timer m_timer = null;
  22. 		System.Threading.Timer m_timerDownLoad = null;
  23. 		List<String> files = new List<string>(); //记录待处理文件的队列
  24.  
  25. 		private Thread ThreadHello;
  26. 		private Thread ThreadDownLoad;
  27. 		private List<ChannelTvListInfo> lstNewTvInfo;
  28.  
  29. 		public Service1()
  30. 		{
  31. 			InitializeComponent();
  32. 		}
  33. 		//http://blog.csdn.net/hwt0101/article/details/8514291
  34. 		//http://www.cnblogs.com/mywebname/articles/1244745.html
  35. 		//http://www.cnblogs.com/jzywh/archive/2008/07/23/filesystemwatcher.html
  36. 		/// <summary>
  37. 		/// 服务启动的操作
  38. 		/// </summary>
  39. 		/// <param name="args"></param>
  40. 		protected override void OnStart(string[] args)
  41. 		{
  42. 			try
  43. 			{
  44. 				ThreadDownLoad = new Thread(new ThreadStart(ThreadTime));
  45. 				ThreadDownLoad.Start();
  46. 				ThreadHello = new Thread(new ThreadStart(Hello));
  47. 				ThreadHello.Start();
  48. 				WriteInLog("服务线程任务开始", false);
  49. 				System.Diagnostics.Trace.Write("线程任务开始");
  50.  
  51. 			}
  52. 			catch (Exception ex)
  53. 			{
  54. 				System.Diagnostics.Trace.Write(ex.Message);
  55. 				throw ex;
  56. 			}
  57. 		}
  58. 		public List<ChannelTvListInfo> listFTPFiles(string FTPAddress, string username, string password)
  59. 		{
  60. 			List<ChannelTvListInfo> listinfo = new List<ChannelTvListInfo>();
  61. 			using (FtpConnection ftp = new FtpConnection(FTPAddress, username, password))
  62. 			{
  63. 				ftp.Open();
  64. 				ftp.Login();
  65. 				foreach (var file in ftp.GetFiles("/"))
  66. 				{
  67. 					listinfo.Add(new ChannelTvListInfo { TVName = file.Name,
  68. 						LastWriteTime = Convert.ToDateTime(file.LastWriteTime).ToString("yyyy/MM/dd HH:mm") });
  69. 				}
  70. 				ftp.Dispose();
  71. 				ftp.Close();
  72. 			}
  73. 			return listinfo;
  74. 		}
  75. 		/// <summary>
  76. 		/// 服务停止的操作
  77. 		/// </summary>
  78. 		protected override void OnStop()
  79. 		{
  80. 			try
  81. 			{
  82. 				ThreadHello.Abort();
  83. 				WriteInLog("服务线程停止", false);
  84. 				System.Diagnostics.Trace.Write("线程停止");
  85. 			}
  86. 			catch (Exception ex)
  87. 			{
  88. 				System.Diagnostics.Trace.Write(ex.Message);
  89. 			}
  90. 		}
  91.  
  92. 		private void Hello()
  93. 		{
  94. 			try
  95. 			{
  96. 				fsw.Filter = "*.xml"; //设置监控文件的类型
  97. 					fsw.Path = @"D:\ChannelTvXML";   //设置监控的文件目录
  98. 					fsw.IncludeSubdirectories = true;   //设置监控C盘目录下的所有子目录
  99. 					fsw.InternalBufferSize = 100000;
  100. 					fsw.NotifyFilter = NotifyFilters.CreationTime | NotifyFilters.Size | NotifyFilters.LastWrite |
  101. 														 NotifyFilters.FileName | NotifyFilters.DirectoryName; ;   //设置文件的文件名、目录名及文件的大小改动会触发Changed事件
  102. 					fsw.Changed += new FileSystemEventHandler(this.fsw_Changed);
  103. 					fsw.Error += new ErrorEventHandler(this.fsw_Error);
  104. 					fsw.EnableRaisingEvents = true;
  105. 					// Create the timer that will be used to deliver events. Set as disabled
  106. 					if (m_timer == null)
  107. 					{
  108. 						//设置定时器的回调函数。此时定时器未启动
  109. 						m_timer = new System.Threading.Timer(new TimerCallback(OnWatchedFileChange),
  110. 																				 null, Timeout.Infinite, Timeout.Infinite);
  111. 					}
  112. 				 
  113. 			}
  114. 			catch (Exception ex)
  115. 			{
  116. 				System.Diagnostics.Trace.Write(ex.Message);
  117. 				throw ex;
  118. 			}
  119.  
  120. 			Thread.Sleep(5000);
  121.  
  122. 		}
  123. 		private void ThreadTime()
  124. 		{
  125. 			List<ChannelTvListInfo> lstNewTvInfo = listFTPFiles("xxx.xx.140.170", "", "");
  126. 			WriteInLog(lstNewTvInfo.Count + "获取列表信息成功", false);
  127. 			// Create the timer that will be used to deliver events. Set as disabled
  128. 			if (m_timerDownLoad == null)
  129. 			{
  130. 				//设置定时器的回调函数。此时定时器未启动
  131. 				m_timerDownLoad = new System.Threading.Timer(new TimerCallback(DownLoadTvListInfo),
  132. 																		 null, Timeout.Infinite, Timeout.Infinite);
  133. 			}
  134. 			Thread.Sleep(5000);
  135. 		}
  136. 		private void DownLoadTvListInfo(object state)
  137. 		{
  138. 			List<ChannelTvListInfo> lstOldTvInfo = new List<ChannelTvListInfo>();
  139. 			DirectoryInfo TheFolder = new DirectoryInfo(@"D:\ChannelTvXML");
  140. 			foreach (FileInfo NextFile in TheFolder.GetFileSystemInfos())
  141. 			{
  142. 				lstOldTvInfo.Add(new ChannelTvListInfo { TVName = NextFile.Name, LastWriteTime = NextFile.LastWriteTime.ToString("yyyy/MM/dd HH:mm") });
  143. 			}
  144. 			var result = lstNewTvInfo.Except(lstOldTvInfo, new ProductComparer()).ToList();
  145. 			if (result.Count > 0)
  146. 			{
  147. 				foreach (var item in result)
  148. 				{
  149. 					new FtpHelper().DownloadFtpFile("", "", "xx.xx.140.170", @"D:\ChannelTvXML", item.TVName);
  150. 					WriteInLog(item.TVName + "下载成功", false);
  151. 				}
  152. 			}
  153. 			}
  154.     private void fsw_Changed(object sender, FileSystemEventArgs e)
  155. 		{
  156. 			Mutex mutex = new Mutex(false, "Wait");
  157. 			mutex.WaitOne();
  158. 			if (!files.Contains(e.Name))
  159. 			{
  160. 				files.Add(e.Name);
  161. 			}
  162. 			mutex.ReleaseMutex();
  163.  
  164. 			//重新设置定时器的触发间隔，并且仅仅触发一次
  165. 			m_timer.Change(TimeoutMillis, Timeout.Infinite);
  166.  
  167. 		}
  168. 		/// <summary>
  169. 		/// 定时器事件触发代码：进行文件的实际处理
  170. 		/// </summary>
  171. 		/// <param name="state"></param>
  172.  
  173. 		private void OnWatchedFileChange(object state)
  174. 		{
  175. 			_countTimerEvent++;
  176. 			WriteInLog(string.Format("TimerEvent {0}", _countTimerEvent.ToString("#00")), false);
  177. 			List<String> backup = new List<string>();
  178. 			Mutex mutex = new Mutex(false, "Wait");
  179. 			mutex.WaitOne();
  180. 			backup.AddRange(files);
  181. 			files.Clear();
  182. 			mutex.ReleaseMutex();
  183.  
  184. 			foreach (string file in backup)
  185. 			{
  186. 				_countFileChangeEvent++;
  187. 				WriteInLog(string.Format("FileEvent {0} :{1}文件已于{2}进行{3}", _countFileChangeEvent.ToString("#00"),
  188. 					 file, DateTime.Now, "changed"), false);
  189. 			}
  190.  
  191. 		}
  192. 		private void fsw_Error(object sender, ErrorEventArgs e)
  193. 		{
  194. 			WriteInLog(e.GetException().Message, false);
  195. 		}
  196. 		/// <summary>
  197. 		/// 写入文件操作
  198. 		/// </summary>
  199. 		/// <param name="msg">写入内容</param>
  200. 		/// <param name="IsAutoDelete">是否删除</param>
  201. 		private void WriteInLog(string msg, bool IsAutoDelete)
  202. 		{
  203. 			try
  204. 			{
  205. 				string logFileName = @"D:\DownTvList_" + DateTime.Now.ToString("yyyyMMdd") + "_log.txt" + ""; // 文件路径
  206.  
  207. 				FileInfo fileinfo = new FileInfo(logFileName);
  208. 				if (IsAutoDelete)
  209. 				{
  210. 					if (fileinfo.Exists && fileinfo.Length >= 1024)
  211. 					{
  212. 						fileinfo.Delete();
  213. 					}
  214. 				}
  215. 				using (FileStream fs = fileinfo.OpenWrite())
  216. 				{
  217. 					StreamWriter sw = new StreamWriter(fs);
  218. 					sw.BaseStream.Seek(0, SeekOrigin.End);
  219. 					sw.Write("INFO-" + DateTime.Now.ToString() + "--日志内容为:" + msg + "\r\n");
  220. 					//sw.WriteLine("=====================================");
  221. 					sw.Flush();
  222. 					sw.Close();
  223. 				}
  224. 			}
  225. 			catch (Exception ex)
  226. 			{
  227. 				ex.ToString();
  228. 			}
  229. 		}
  230. 	}
  231.  
  232. }
  1. FtpHelper.cs　类代码
  2. using System;
  3. using System.Collections.Generic;
  4. using System.IO;
  5. using System.Linq;
  6. using System.Net;
  7. using System.Text;
  8. using System.Threading.Tasks;
  9.  
  10. namespace WindowsService1
  11. {
  12. 	public class FtpHelper
  13. 	{
  14. 		private FtpWebRequest ftpRequest = null;
  15. 		private FtpWebResponse ftpResponse = null;
  16. 		private Stream ftpStream = null;
  17.  
  18. 		/// <summary>
  19. 		///  Get Filelist  Name
  20. 		/// </summary>
  21. 		/// <param name="userId">ftp userid</param>
  22. 		/// <param name="pwd">ftp password</param>
  23. 		/// <param name="ftpIP">ftp ip</param>
  24. 		/// <returns></returns>
  25. 		public string[] GetFtpFileName(string userId, string pwd, string ftpIP, string filename)
  26. 		{
  27. 			string[] downloadFiles;
  28. 			StringBuilder result = new StringBuilder();
  29. 			try
  30. 			{
  31. 				ftpRequest = (FtpWebRequest)FtpWebRequest.Create(ftpIP + "/" + filename);
  32. 				ftpRequest.Credentials = new NetworkCredential(userId, pwd);
  33. 				ftpRequest.UseBinary = true;
  34. 				ftpRequest.UsePassive = true;
  35. 				ftpRequest.KeepAlive = true;
  36. 				ftpRequest.Method = WebRequestMethods.Ftp.ListDirectory;
  37. 				ftpResponse = (FtpWebResponse)ftpRequest.GetResponse();
  38. 				ftpStream = ftpResponse.GetResponseStream();
  39. 				StreamReader ftpReader = new StreamReader(ftpStream);
  40. 				string line = ftpReader.ReadLine();
  41. 				while (line != null)
  42. 				{
  43. 					result.Append(line);
  44. 					result.Append("\n");
  45. 					line = ftpReader.ReadLine();
  46. 				}
  47. 				result.Remove(result.ToString().LastIndexOf('\n'), 1);
  48. 		
  49. 				ftpReader.Close();
  50. 				ftpStream.Close();
  51. 				ftpResponse.Close();
  52. 				ftpRequest = null;
  53. 				return result.ToString().Split('\n');
  54.  
  55. 			}
  56. 			catch (Exception ex)
  57. 			{
  58. 				downloadFiles = null;
  59. 				return downloadFiles;
  60. 			}
  61. 		}
  62.  
  63. 		public string[] GetFtpFileName(string userId, string pwd, string ftpIP)
  64. 		{
  65. 			string[] downloadFiles;
  66. 			StringBuilder result = new StringBuilder();
  67. 			try
  68. 			{
  69. 				ftpRequest = (FtpWebRequest)FtpWebRequest.Create(ftpIP + "/");
  70. 				ftpRequest.Credentials = new NetworkCredential(userId, pwd);
  71. 				ftpRequest.UseBinary = true;
  72. 				ftpRequest.UsePassive = true;
  73. 				ftpRequest.KeepAlive = true;
  74. 				ftpRequest.Method = WebRequestMethods.Ftp.ListDirectory;
  75. 				ftpResponse = (FtpWebResponse)ftpRequest.GetResponse();
  76. 				ftpStream = ftpResponse.GetResponseStream();
  77. 				StreamReader ftpReader = new StreamReader(ftpStream);
  78. 				string line = ftpReader.ReadLine();
  79. 				while (line != null)
  80. 				{
  81. 					result.Append(line);
  82. 					result.Append("\n");
  83. 					line = ftpReader.ReadLine();
  84. 				}
  85. 				result.Remove(result.ToString().LastIndexOf('\n'), 1);
  86.  
  87. 				ftpReader.Close();
  88. 				ftpStream.Close();
  89. 				ftpResponse.Close();
  90. 				ftpRequest = null;
  91.  				return result.ToString().Split('\n');
  92. 		  
  93. 			}
  94. 			catch (Exception ex)
  95. 			{
  96. 				downloadFiles = null;
  97. 				return downloadFiles;
  98. 			}
  99. 		}
  100.  
  101. 		/// <summary>
  102. 		///从ftp服务器上下载文件的功能
  103. 		/// </summary>
  104. 		/// <param name="userId"></param>
  105. 		/// <param name="pwd"></param>
  106. 		/// <param name="ftpUrl">ftp地址</param>
  107. 		/// <param name="filePath"></param>
  108. 		/// <param name="fileName"></param>
  109. 		public void DownloadFtpFile(string userId, string pwd, string ftpUrl, string filePath, string fileName)
  110. 		{
  111. 			FtpWebRequest reqFTP = null;
  112. 			FtpWebResponse response = null;
  113. 			try
  114. 			{
  115. 				String onlyFileName = Path.GetFileName(fileName);
  116.  
  117. 				string downFileName = filePath + "\\" + onlyFileName;
  118. 				string url = "ftp://" + ftpUrl + "/" + fileName;
  119. 				if (File.Exists(downFileName))
  120. 				{
  121. 					DeleteDir(downFileName);
  122. 				}
  123.  
  124. 				FileStream outputStream = new FileStream(downFileName, FileMode.Create);
  125.  
  126. 				reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(url));
  127. 				reqFTP.Credentials = new NetworkCredential(userId, pwd);
  128. 				reqFTP.UseBinary = true;
  129. 				reqFTP.UsePassive = true;
  130. 				reqFTP.KeepAlive = true;
  131. 				reqFTP.Method = WebRequestMethods.Ftp.DownloadFile;
  132. 				response = (FtpWebResponse)reqFTP.GetResponse();
  133.  
  134.  
  135. 				Stream ftpStream = response.GetResponseStream();
  136. 				long cl = response.ContentLength;
  137. 				int bufferSize = 2048;
  138. 				int readCount;
  139. 				byte[] buffer = new byte[bufferSize];
  140. 				readCount = ftpStream.Read(buffer, 0, bufferSize);
  141. 				while (readCount > 0)
  142. 				{
  143. 					outputStream.Write(buffer, 0, readCount);
  144. 					readCount = ftpStream.Read(buffer, 0, bufferSize);
  145. 				}
  146. 				ftpStream.Close();
  147. 				outputStream.Close();
  148. 				response.Close();
  149.  
  150.  
  151. 			}
  152. 			catch (Exception ex)
  153. 			{
  154. 				throw ex;
  155. 			}
  156. 		}
  157.  
  158.   
  159.         public DateTime GetDateTimestamp(string ftpUrl, string remoteFile, string username, string password)
  160.         {
  161.             string url = "ftp://" + ftpUrl + "/" + remoteFile;
  162.             FtpWebRequest reqFTP = (FtpWebRequest)FtpWebRequest.Create(new Uri(url));
  163.             reqFTP.Credentials = new NetworkCredential(username, password);
  164.             reqFTP.UseBinary = true;
  165.             reqFTP.UsePassive = true;
  166.             reqFTP.KeepAlive = true;
  167.             reqFTP.Method = WebRequestMethods.Ftp.GetDateTimestamp;
  168.             FtpWebResponse response = (FtpWebResponse)reqFTP.GetResponse();
  169.  
  170.             return response.LastModified;
  171.         }
  172. 		/// 基姆拉尔森计算公式计算日期
  173. 		/// </summary>
  174. 		/// <param name="y">年</param>
  175. 		/// <param name="m">月</param>
  176. 		/// <param name="d">日</param>
  177. 		/// <returns>星期几</returns>
  178.  
  179. 		public static string CaculateWeekDay(int y, int m, int d)
  180. 		{
  181. 			if (m == 1 || m == 2)
  182. 			{
  183. 				m += 12;
  184. 				y--;         //把一月和二月看成是上一年的十三月和十四月，例：如果是2004-1-10则换算成：2003-13-10来代入公式计算。
  185. 			}
  186. 			int week = (d + 2 * m + 3 * (m + 1) / 5 + y + y / 4 - y / 100 + y / 400) % 7;
  187. 			string weekstr = "";
  188. 			switch (week)
  189. 			{
  190. 				case 0: weekstr = "星期一"; break;
  191. 				case 1: weekstr = "星期二"; break;
  192. 				case 2: weekstr = "星期三"; break;
  193. 				case 3: weekstr = "星期四"; break;
  194. 				case 4: weekstr = "星期五"; break;
  195. 				case 5: weekstr = "星期六"; break;
  196. 				case 6: weekstr = "星期日"; break;
  197. 			}
  198. 			return weekstr;
  199. 		}
  200. 		/// <summary>
  201. 		/// 返回不带后缀的文件名
  202. 		/// </summary>
  203. 		/// <param name="fileName"></param>
  204. 		/// <returns></returns>
  205. 		public static string GetFirstFileName(string fileName)
  206. 		{
  207. 			return Path.GetFileNameWithoutExtension(fileName);
  208. 		}
  209. 		#region 删除指定目录以及该目录下所有文件
  210. 		/// </summary><param name="dir">欲删除文件或者目录的路径</param>
  211. 		public static void DeleteDir(string dir)
  212. 		{
  213. 			CleanFiles(dir);//第一次删除文件
  214. 			CleanFiles(dir);//第二次删除目录
  215. 		}
  216. 		/// <summary>
  217. 		/// 删除文件和目录
  218. 		/// </summary>
  219. 		///使用方法Directory.Delete( path, true)
  220. 		private static void CleanFiles(string dir)
  221. 		{
  222. 			if (!Directory.Exists(dir))
  223. 			{
  224. 				File.Delete(dir); return;
  225. 			}
  226. 			else
  227. 			{
  228. 				string[] dirs = Directory.GetDirectories(dir);
  229. 				string[] files = Directory.GetFiles(dir);
  230. 				if (0 != dirs.Length)
  231. 				{
  232. 					foreach (string subDir in dirs)
  233. 					{
  234. 						if (null == Directory.GetFiles(subDir))
  235. 						{ Directory.Delete(subDir); return; }
  236. 						else CleanFiles(subDir);
  237. 					}
  238. 				}
  239. 				if (0 != files.Length)
  240. 				{
  241. 					foreach (string file in files)
  242. 					{ File.Delete(file); }
  243. 				}
  244. 				else Directory.Delete(dir);
  245. 			}
  246. 		}
  247. 		#endregion
  248. 	}
  249. 	public class ChannelListInfo
  250. 	{
  251. 		//   public string ChannelID { get; set; }
  252. 		public string WeekDate { get; set; }
  253. 		public string ChannelTV { get; set; }
  254. 		public string ChannelName { get; set; }
  255. 		public string ChannelType { get; set; }
  256. 		public string ChannelSummary { get; set; }
  257. 		//   public string ChannelImg { get; set; }
  258.  
  259. 		public DateTime ChannelStartDate { get; set; }
  260. 		public DateTime ChannelEndDate { get; set; }
  261. 		//   public DateTime? AddTime { get; set; }
  262. 		public DateTime? ChannelPlayDate { get; set; }
  263.  
  264.  
  265. 	}
  266. 	public class ChannelTvListInfo
  267. 	{
  268. 		public string TVName { get; set; }
  269. 		public string LastWriteTime { get; set; }
  270. 	}
  271. 	// Custom comparer for the Product class
  272. 	public class ProductComparer : IEqualityComparer<ChannelTvListInfo>
  273. 	{
  274. 		// Products are equal if their names and product numbers are equal.
  275. 		public bool Equals(ChannelTvListInfo x, ChannelTvListInfo y)
  276. 		{
  277.  
  278. 			//Check whether the compared objects reference the same data.
  279. 			if (Object.ReferenceEquals(x, y)) return true;
  280.  
  281. 			//Check whether any of the compared objects is null.
  282. 			if (Object.ReferenceEquals(x, null) || Object.ReferenceEquals(y, null))
  283. 				return false;
  284.  
  285. 			//Check whether the products' properties are equal.
  286. 			return x.TVName == y.TVName && x.LastWriteTime == y.LastWriteTime;
  287. 		}
  288.  
  289. 		// If Equals() returns true for a pair of objects 
  290. 		// then GetHashCode() must return the same value for these objects.
  291.  
  292. 		public int GetHashCode(ChannelTvListInfo product)
  293. 		{
  294. 			//Check whether the object is null
  295. 			if (Object.ReferenceEquals(product, null)) return 0;
  296.  
  297. 			//Get hash code for the Name field if it is not null.
  298. 			int hashProductName = product.TVName == null ? 0 : product.TVName.GetHashCode();
  299.  
  300. 			//Get hash code for the Code field.
  301. 			int hashProductCode = product.LastWriteTime.GetHashCode();
  302.  
  303. 			//Calculate the hash code for the product.
  304. 			return hashProductName ^ hashProductCode;
  305. 		}
  306.  
  307. 	}
  308. }


声明：本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：【wpsshop博客】
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号