如何在不遇到"多个根节点"问题的情况下编写 XElement 以同步归档？

Question

我正在使用XML模拟数据库，当用伪数据加载它时，我不断收到一个错误，告诉我有多个根元素。打开文件后，我可以确认多个根元素正在写入文件，但除了简单地同步调用进程之外，我所做的一切似乎都无法阻止它这样做

下面是我的代码示例：

// Check to see if the file is available. If it is, parse it. Otherwise create
// a new root element. Done in the constructor since the XElement is used in
// multiple locations.
public CourseXmlWriter()
{
    if (!File.Exists(Settings.Default.DataDirectory + Settings.Default.AltDb))
    {
        _courses = new XElement("Courses");
    }
    else
    {
        var attempts = 0;
        while (attempts < MaxAttempts)
        {
            try
            {
                using (var stream = new FileStream(_dataFile, 
                 FileMode.OpenOrCreate, FileAccess.Read, FileShare.None))
                {
                    _courses = XElement.Load(stream);
                }
                break;
            }
            catch (IOException)
            {
                Thread.Sleep(1000);
                attempts++;
            }
        }
    }
}

对于初始加载，我只是试图读取文件以便对其进行解析，所以我限制了对它的访问。我还确保在解析时没有人可以访问它。在继续并完全拒绝请求之前，我会尝试一段时间。

然后，当试图将信息写入文件时，我会执行以下操作：

var attempts = 0;
while (attempts < MaxAttempts)
{
    try
    {
        using (var stream = new FileStream(_dataFile,
          FileMode.OpenOrCreate, FileAccess.Write, FileShare.None))
        {
            _courses.Save(stream);
        }
        break;
    }
    catch (IOException)
    {
        attempts++;
        Thread.Sleep(1000);
    }
}

同样，这是异步运行的，在它与There are multiple root elements. Line 15, position 6.崩溃之前，我可以成功地写入一些（15-150）记录，其中位置和行是可变的。

以下是异步调用和回调：

呼叫：

for (var i = 0; i < coursesToGenerate; i++)
{
    var request = new CreateCourseRequest
    {
        Description = Path.GetRandomFileName().Replace(".", ""),
        Name = Path.GetRandomFileName().Replace(".", "")
    };
    Func<CreateCourseRequest, CreateCourseResponse> func = 
          _courseAgent.CreateCourse;
    func.BeginInvoke(request, CreateCourseComplete, func);
}

回调：

private void CreateCourseComplete(IAsyncResult ar)
{
    var caller = (Func<CreateCourseRequest, CreateCourseResponse>) ar.AsyncState;
    var result = caller.EndInvoke(ar);
    if (result.Status == ResponseBase.ResponseStatus.Successful)
    {
        _successful++;
    }
}

有什么想法吗？

Answer 1

我的猜测是，在开始编写文件后，您将捕获一个IOException，并开始重新编写文档。

尝试捕获该异常并将其记录下来。

当代码捕获异常并忽略它时，这通常不是一个好兆头