自动监视并处理共享目录中的文本文件并处理代码,CSharp代码库,德仔网

代码语言

代码分类

【CSharp】自动监视并处理共享目录中的文本文件并处理

作者:章毅明 / 发布于2014/7/17/ 519

假设在文本文件刚被传输到共享目录中的时候，文本文件名为原始文本文件名+".tmp"，传输完成之后去掉".tmp"，程序会自动监视目录并在文件传输完成之后处理文本文件。


	?using System;
	using System.Collections;
	using System.IO;
	using System.Threading;
	using System.Windows.Forms;
	
	namespace MonitorDirectory
	{
	 class Program
	 {
	 private static FileSystemWatcher FileSystemWatcher1 = null;
	 private static Hashtable fileTable = new Hashtable();
	
	 [STAThread]
	 public static void Main(string[] args)
	 {
	 FolderBrowserDialog dilog = new FolderBrowserDialog();
	 dilog.Description = "请选择要监视的文件夹";
	 if(dilog.ShowDialog() == DialogResult.OK || dilog.ShowDialog() == DialogResult.Yes)
	 {
	 string path=dilog.SelectedPath;
	 FileSystemWatcher1 = new FileSystemWatcher();
	 FileSystemWatcher1.Path = path;
	 FileSystemWatcher1.Filter = "*.tmp";
	 FileSystemWatcher1.IncludeSubdirectories = true;
	 FileSystemWatcher1.Created += new FileSystemEventHandler(FileSystemWatcher1_Created);
	 FileSystemWatcher1.Changed += new FileSystemEventHandler(FileSystemWatcher1_Changed);
	 FileSystemWatcher1.Renamed += new RenamedEventHandler(FileSystemWatcher1_Renamed);
	 FileSystemWatcher1.EnableRaisingEvents=true;
	 //加入任务
	 foreach(string file in Directory.GetFiles(path,"*.txt"))
	 {
	 Tasks task = new Tasks();
	 task.filepathname=file;
	 task.Push();
	 }
	 Tasks t = new Tasks();
	 Thread th = new Thread(new ThreadStart(t.ThreadWork));
	 th.Start();
	 Console.Read();
	 th.Abort();
	 FileSystemWatcher1.EnableRaisingEvents = false;
	 FileSystemWatcher1.Dispose();
	 FileSystemWatcher1 = null;
	 return;
	 }
	 }
	
	 private static void FileSystemWatcher1_Created(object sender, FileSystemEventArgs e)
	 {
	 Monitor.Enter( fileTable.SyncRoot );
	 try
	 {
	 fileTable.Add(e.FullPath,false);
	 Console.WriteLine("文件"+e.FullPath+"被创建");
	 }
	 finally
	 {
	 Monitor.Exit( fileTable.SyncRoot );
	 }
	 }
	
	 private static void FileSystemWatcher1_Changed(object sender, FileSystemEventArgs e)
	 {
	 if(fileTable.ContainsKey(e.FullPath) && !(bool)fileTable[e.FullPath])
	 {
	 Monitor.Enter( fileTable.SyncRoot );
	 try
	 {
	 fileTable[e.FullPath]=true;
	 Console.WriteLine("文件"+e.FullPath+"有数据");
	 }
	 finally
	 {
	 Monitor.Exit( fileTable.SyncRoot );
	 }
	 }
	 }
	
	 private static void FileSystemWatcher1_Renamed(object sender, RenamedEventArgs e)
	 {
	 if(fileTable.ContainsKey(e.OldFullPath) && (bool)fileTable[e.OldFullPath])
	 {
	 Monitor.Enter( fileTable.SyncRoot );
	 try
	 {
	 fileTable.Remove(e.OldFullPath);
	 Console.WriteLine("文件"+e.FullPath+"被处理");
	 Tasks task = new Tasks();
	 task.filepathname=e.FullPath;
	 task.Push();
	 }
	 finally
	 {
	 Monitor.Exit( fileTable.SyncRoot );
	 }
	 }
	 }
	 }
	}

	

	

	

	

	

	using System;
	using System.Collections.Generic;
	using System.IO;
	using System.Linq;
	using System.Threading;
	
	namespace MonitorDirectory
	{
	 public class Tasks
	 {
	 private static Queue<Action> m_List;
	 //线程互斥
	 private static object m_obj = new object();
	
	 public string filepathname {get;set;}
	
	 /// <summary>
	 /// 初始化队列
	 /// </summary>
	 public Tasks()
	 {
	 if(m_List == null)
	 m_List = new Queue<Action>();
	 }
	
	 /// <summary>
	 /// 线程工作的函数
	 /// </summary>
	 public void ThreadWork()
	 {
	 while (true)
	 {
	 //获取任务
	 Action work = Pop();
	 //执行任务
	 work();
	 Thread.Sleep(1);
	 }
	 }
	
	 /// <summary>
	 /// 从任务队列中取出任务
	 /// </summary>
	 /// <returns></returns>
	 public Action Pop()
	 {
	 Monitor.Enter(m_obj);
	 Action ac = null;
	 try
	 {
	 //当队列有数据，出队.否则等待
	 if (m_List.Count > 0)
	 {
	 ac = m_List.Dequeue();
	 }
	 else
	 {
	 Monitor.Wait(m_obj);
	 ac = m_List.Dequeue();
	 }
	 }
	 finally
	 {
	 Monitor.Exit(m_obj);
	 }
	 return ac;
	 }
	
	 /// <summary>
	 /// 把任务加入任务队列
	 /// </summary>
	 public void Push()
	 {
	 //上锁
	 Monitor.Enter(m_obj);
	 //委托
	 Action action = new Action(RunWork);
	 //把任务加入队列中
	 m_List.Enqueue(action);
	 //通知等待队列中的线程锁定对象状态的更改。
	 Monitor.Pulse(m_obj);
	 Monitor.Exit(m_obj);
	 }
	
	 /// <summary>
	 /// 工作函数
	 /// </summary>
	 private void RunWork()
	 {
	 Console.WriteLine("File Size：" + new FileInfo(filepathname).Length);
	 }
	 }
	}

试试其它关键字

　自动监视　　文本文件　

同语言下

可能有用的

章毅明贡献的其它代码(8)