使用 StreamReader 并发文件访问时引发异常

Question

我发现了一篇 帖子讨论使用 StreamWriter 处理并发文件访问。

问题在于答案不管理正在访问文件的场景，而是管理多个进程。

让我们简单地说一下：

• 我有多个应用程序
• ，我需要在数据库中有一个集中式日志系统
• ，如果数据库失败，我需要文件系统日志的回退，

有一个已知的并发场景，其中多个应用程序（进程）将尝试写入该文件。 这可以通过在短暂延迟后重新尝试写入来管理。 但如果是安全错误或文件名语法错误，我不想重新尝试。

代码在这里：

// true if an access error occured
bool accessError = false;
// number fo writing attemps
int attempts = 0;

do
{
    try
    {
        // open the file
        using (StreamWriter file = new StreamWriter(filename, true))
        {
            // write the line
            file.WriteLine(log);
            // success
            result = true;
        }
    }
        /////////////// access errors ///////////////
    catch (ArgumentException)
    {
        accessError = true;
    }
    catch (DirectoryNotFoundException)
    {
        accessError = true;
    }
    catch (PathTooLongException)
    {
        accessError = true;
    }
    catch (SecurityException)
    {
        accessError = true;
    }
        /////////////// concurrent writing errors ///////////////
    catch (Exception)
    {
        // WHAT EXCEPTION SHOULD I CATCH HERE ?
        // sleep before retrying
        Thread.Sleep(ConcurrentWriteDelay);
    }
    finally
    {
        attempts++;
    }
    // while the number of attemps has not been reached
} while ((attempts < ConcurrentWriteAttempts)
            // while we have no access error
            && !accessError
            // while the log is not written
            && !result);

我唯一的问题是并发写入时会引发的异常类型。我已经知道事情可以采取不同的方式。让我添加一些注意事项：

• 不，我不想在这种情况下使用 NLog 是的
• ，我使用 IOC + Mutex 处理并发以实现进程内并发 是的
• ，我真的希望所有日志都写入同一个文件中

Answer 1

它将是一个带有文本的 IOException：

“该进程无法访问文件 '{0}'，因为它正在被另一个进程使用。”

这是一个简单的方法：

 static bool LogError(string filename, string log)
    {
        const int MAX_RETRY = 10;
        const int DELAY_MS = 1000; // 1 second
        bool result = false;
        int retry = 0;
        bool keepRetry = true;
        while (keepRetry && !result && retry < MAX_RETRY )
        {
            try
            {
                using (StreamWriter file = new StreamWriter(filename, true))
                {
                    // write the line
                    file.WriteLine(log);
                    // success
                    result = true;
                }
            }
            catch (IOException ioException)
            {
                Thread.Sleep(DELAY_MS);
                retry++; 
            }
            catch (Exception e)
            {

                keepRetry = false;
            }

        }
        return result;
    }