c# - SqlBulkCopy.WriteToServer()不断获取“连接已关闭”

Question

这对我来说毫无意义，但也许有敏锐的眼睛的人可以发现问题所在。

我有一个使用FileSystemWatcher的Windows服务。它处理一些文件并将数据上载到MSSQL数据库。它在我的机器上完全可以正常工作-与Visual Studio分离（即不调试）并作为服务运行。如果将此编译后的代码复制到我们的服务器，并使其指向相同的数据库，甚至指向相同的文件（！），则每次都会出现此错误：

System.InvalidOperationException: Invalid operation. The connection is closed.
   at System.Data.SqlClient.SqlConnection.GetOpenTdsConnection()
   at System.Data.SqlClient.SqlBulkCopy.CopyBatchesAsyncContinuedOnError(Boolean cleanupParser)
   at System.Data.SqlClient.SqlBulkCopy.<>c__DisplayClass30.<CopyBatchesAsyncContinuedOnSuccess>b__2c()
   at System.Data.SqlClient.AsyncHelper.<>c__DisplayClass9.<ContinueTask>b__8(Task tsk)

我尝试将本地代码指向服务器的文件，并且工作正常。 .Net 4.5.1在两台计算机上。服务都在同一个域用户下运行。令人困惑。也许我对SqlBulkCopy.WriteToServerAsync（）不了解？它会自动共享连接或其他内容吗？它在通话之间或其他时间之间关闭吗？以下是相关代码：

private static void ProcessFile(FileInfo fileInfo)
{
    using (var bulkCopy = new SqlBulkCopy("Data Source=myserver;Initial Catalog=mydb;Persist Security Info=True;User ID=myusr;Password=mypwd;")
    using (var objRdr = ObjectReader.Create(ReadLogFile(fileInfo)
                                    .Where(x => !string.IsNullOrEmpty(x.Level)),
                                         "Id", "AppId", "AppDomain", "AppMachine",
                                         "LocalDate", "UtcDate", "Thread", "Level", "Logger", "Usrname",
                                         "ClassName", "MethodName", "LineNo", "Message", "Exception",
                                         "StackTrace", "Properties"))
    {
        bulkCopy.DestinationTableName = "EventLog";
        bulkCopy.BulkCopyTimeout = 600;
        bulkCopy.EnableStreaming = true;
        bulkCopy.BatchSize = AppConfig.WriteBatchSize;
        bulkCopy.WriteToServerAsync(objRdr).ContinueWith(t =>
            {
                if (t.Status == TaskStatus.Faulted)
                {
                    CopyToFailedDirectory(fileInfo);
                    _log.Error(
                        string.Format(
                            "Error copying logs to database for file {0}. File has been copied to failed directory for inspection.",
                            fileInfo.FullName), t.Exception.InnerException ?? t.Exception);
                    Debug.WriteLine("new handle error {0}",
                                    (t.Exception.InnerException ?? t.Exception).Message);
                }
                if (t.Status == TaskStatus.RanToCompletion)
                {
                    _log.InfoFormat("File {0} logs have been copied to database.", fileInfo.FullName);
                    Debug.WriteLine("Yay, finished {0}!", fileInfo.Name);
                }
                // if this is the last one, delete the original file
                if (t.Status == TaskStatus.Faulted || t.Status == TaskStatus.RanToCompletion)
                {
                    Debug.WriteLine("deleting file {0}", fileInfo.Name);
                    PurgeFile(fileInfo);
                }
            });
    }
}

如果您要求，请注意以下几点：


ObjectReader是 FastMember IDataReader实现。快速疯狂。它会将文件读入具有列出的属性的自定义对象。
它将为每个文件引发错误。
同样，它既可以作为服务也可以作为控制台应用程序在我的机器上运行。我什至让它在服务器上工作一次。它引发了错误，并且再也无法正常工作。


有任何想法吗？

Answer 1

看起来像是异步问题。

如果我错了，请告诉我，但是我注意到的是，您在using语句中包含了SqlBulkCopy和ObjectReader，这很棒，但是，您正在异步进行所有处理。一旦调用它，它开始工作，您的using语句将处理您的对象，这也会终止您的连接。

奇怪的是，这听起来有时候确实可行，但在那时它可能只是成为比赛条件。