исключения в службе Windows - служба останавливается при возникновении исключения

Question

Я разработал службу Windows, которая просматривает папку для новых файлов. Моя проблема в том, что когда возникает исключение, сервис перестает работать. Основное назначение услуги: 1. смотреть папку для создания файла 2. прочитать файл 3. вставить данные файла в базу данных Что я действительно хочу сделать, это не потерять вставку файла! Каждый новый файл должен быть прочитан, а его данные вставлены в базу данных. Но если возникает исключение, такое как «Процесс не может получить доступ к файлу« c: \ newfile.txt », потому что он используется другим процессом.», Процесс останавливается. Мой код для обслуживания:

public partial class weatherService : ServiceBase
    {
        private FileSystemWatcher FSW;
        private FswHandler Handler;

        public weatherService()
        {
            InitializeComponent();            
        }

        protected override void OnStart(string[] args)
        {
            FSW = new FileSystemWatcher("c:\\cvvv", "*.txt");
            Handler = new FswHandler();

            FSW.Created += Handler.OnEvent;

            FSW.EnableRaisingEvents = true;    

        }

        protected override void OnStop()
        {
            FSW.EnableRaisingEvents = false;
            FSW.Dispose();
        }

        protected override void OnPause()
        {
            FSW.EnableRaisingEvents = false;
        }

        protected override void OnContinue()
        {
            FSW.EnableRaisingEvents = true;
        }
    }

И код обработчика:

public class FswHandler
    {
        private string[] data;
        private StreamReader reader;
        private StreamWriter sw;

        public void OnEvent(Object source, FileSystemEventArgs Args)
        {
            LogEvent(" [reading file] ");
            readFile(Args.FullPath, Args.Name);
        }

        public void LogEvent(string msg) {
            sw = new StreamWriter("C:\\Users\\Olga\\Desktop\\weatherlog.txt", true);    
            sw.WriteLine("Action : "+ msg +" occured in " + DateTime.Now.ToString());
            sw.Close();
        }
        public void readFile(string path, string filename)
        {
            LogEvent(" [got in readFile] to read file " + filename);
            try
            {
                reader = new StreamReader(path);
            }
            catch (Exception ex)
            {
                LogEvent(ex.Message);
            }
            try
            {
                reader = File.OpenText(path);
            }
            catch (Exception ex)
            {
                LogEvent(ex.Message);
            }
            string titlesLine;
            string valuesLine;

            LogEvent(" [getting 1st line] ");

            titlesLine = reader.ReadLine();

            LogEvent(" [getting 2nd line] ");

            valuesLine = reader.ReadLine();

            LogEvent(" [splitting 2nd line] ");
            data = valuesLine.Split(new Char[] { ' ', '\t' });

            LogEvent(" [starting inserting] ");
            insData(filename);

            reader.Close();

        }

        public void insData(string filename) {
            string connString = "server=83.212.92.197;port=3306;database=mydata;uid=distusr;pwd=usdist1";
            MySqlConnection conn = new MySqlConnection(connString);
            MySqlCommand command = conn.CreateCommand();

            DateTime cdt = System.DateTime.Now;

            String.Format("{0:MM/dd/yyyy HH:mm:ss}", cdt);
            string dt = cdt.ToString();
            int space_pos = dt.IndexOf(" ");
            string date = dt.Substring(0, space_pos);
            string time = dt.Substring(space_pos+1, dt.Length-space_pos+1);

            command.CommandText = "INSERT INTO datainput(filename, measDate, measTime, out2, out3, out4, out5, out6, out7, out8, out9, out10," +
            "out11, out12, out13, out14, out15, out16, out17, out18, out19, out20," +
            "out21, out22, out23, out24, out25, out26, out27, out28, out29, out30," +
            "out31, out32, out33, out34, out35, out36, out37, out38, out39, out40," +
            "out41, out42, out43) VALUES ('" + filename + "','" + date + "','" + time +
            "','" + data[14] + "','" + data[15] + "','" + data[16] + "','" + data[17] + "'," +
            "'" + data[18] + "','" + data[19] + "','" + data[20] + "','" + data[21] + "','" + data[22] + 
            "','" + data[23] + "'," + "'" + data[24] + "','" + data[25] + "','" + data[26] + 
            "','" + data[27] + "','" + data[28] + "'," +"'" + data[29] + "','" + data[30] + 
            "','" + data[31] + "','" + data[32] + "','" + data[33] + "'," + "'" + data[34] + 
            "','" + data[35] + "','" + data[36] + "','" + data[37] + "','" + data[38] + "'," + 
            "'" + data[39] + "','" + data[40] + "','" + data[41] + "','" + data[42] + "','" + data[43] + 
            "'," + "'" + data[44] + "','" + data[45] + "','" + data[46] + "','" + data[47] + 
            "','" + data[48] + "'," + "'" + data[49] + "','" + data[50] + "','" + data[51] +
            "','" + data[52] + "','" + data[53] + "','" + data[54] + "','" + data[55] + "')";

            LogEvent(" [opening database] ");

            try{
                conn.Open();
            }
            catch (Exception ex){
                LogEvent(ex.Message);
            }

            LogEvent(" [executing query] ");

            try
            {
                command.ExecuteNonQuery();
            }
            catch (Exception ex){
                LogEvent(ex.Message);
            }

            LogEvent(" [data have been inserted] ");


            conn.Close();
        }
    }

Что я могу сделать, чтобы избежать потери файла? Я тоже пробовал

        protected void DelayExecution(int nSeconds)
        {
            DateTime end = DateTime.UtcNow.AddSeconds (nSeconds);
            while (DateTime.UtcNow < end){}
        }

        try
        {
            reader = File.OpenText(path);
        }
        catch (Exception ex)
        {
            LogEvent(ex.Message);
            DelayExecution(2);
            readFile(path, filename);
        }

но проблема остается. В этом случае он запускается поверх функции и после того, как процесс вставляет данные в БД, а затем снова переходит к [получение 1-й строки]. Я использую LogEvent, поэтому могу отлаживать свой сервис, поэтому у меня так много выполняемых LogEvents.

Любая помощь будет отличной ...

Answer 1

Вы можете попробовать использовать этот метод расширения в цикле с Thread.Sleep:

/// <summary>
/// Extension methods for FileInfo
/// </summary>
public static class ExtensionMethods_FileInfo
{
    /// <summary>
    /// Verifies if the file is in use
    /// </summary>
    /// <param name="fi">Original FileInfo object</param>
    /// <returns>Returns a boolean value with the state of the file</returns>
    public static Boolean IsInUse(this FileInfo fi)
    {
        try
        {
            if (File.Exists(fi.FullName))
                File.Move(fi.FullName, fi.FullName);
            return false;
        }
        catch (IOException)
        {
            return true;
        }
    }
}

Я предлагаю вам не писать код (кроме логирования) в разделе "catch", поскольку это может привести к дальнейшим ошибкам.

while (new FileInfo(path).IsInUse())
    System.Threading.Thread.Sleep(1000);

// Then do your job...