如何在ASP.NET webservice中执行SQL事务异步

Question

我有许多连接到它的webservice。 我用这个代码：

IAsyncResult result = sqlCommand.BeginExecuteNonQuery(); 
while (!result.IsCompleted) 
{ 
    System.Threading.Thread.Sleep(500); 
} 
sqlCommand.EndExecuteNonQuery(result); 

我觉得这不是一个最好的方法，因为我叫Sleep()。 PS。这种方法将是Web Service与服务器

UPDATE2的减速性能： 我试着描述我的代码更多： 我有Web客户端和2个事件（ProgressChanged和DownloadCompleted）

[WebMethod] 
public void DonwloadFromRemoteServer(string uniqueId, string url) 
{ 
    if (!Directory.Exists(uniqueId)) 
     Directory.CreateDirectory(uniqueId); 

    WebClient wc = new WebClient(); 

    wc.DownloadProgressChanged += (sender, args) => wc_DownloadProgressChanged(sender, args, uniqueId, Path.GetFileName(url)); 

    wc.DownloadFileCompleted += (sender, args) => wc_DownloadFileCompleted(sender, args, uniqueId, Path.GetFileName(url)); 
    wc.DownloadFileAsync(new Uri(url), String.Format("{0}\\{1}", uniqueId, Path.GetFileName(url))); 
} 

void wc_DownloadProgressChanged(object sender, DownloadProgressChangedEventArgs e, string uniqueId, string fileName) 
{ 
    SqlConnection connection = new SqlConnection("Data Source=.\\SQLSERVER;Initial Catalog=XRingtoneDB;Integrated Security=True;Asynchronous Processing=true"); 
    connection.Open(); 
    SqlCommand sqlCommand = new SqlCommand(); 
    sqlCommand.Connection = connection; 
    sqlCommand.CommandText = String.Format("IF NOT EXISTS(SELECT uniqueId FROM downloads WHERE uniqueID = '{0}') " + 
             "INSERT INTO downloads VALUES ('{0}', '{1}', '{2}') " + 
             "IF EXISTS(SELECT uniqueId FROM downloads WHERE uniqueID = '{0}') " + 
             "Update downloads " + 
             "set progress='{2}' " + 
             "where uniqueId='{0}' ", uniqueId, fileName, e.BytesReceived); 

    AsyncCallback callback = ((result) => 
    { 
     sqlCommand.EndExecuteNonQuery(result); 
     connection.Close(); 
    }); 

    sqlCommand.BeginExecuteNonQuery(callback, sqlCommand); 
} 

void wc_DownloadFileCompleted(object sender, System.ComponentModel.AsyncCompletedEventArgs e, string uniqueId, string fileName) 
{ 
    SqlConnection connection = new SqlConnection("Data Source=.\\SQLSERVER;Initial Catalog=XRingtoneDB;Integrated Security=True;Asynchronous Processing=true"); 
    connection.Open(); 
    SqlCommand sqlCommand = new SqlCommand(); 
    sqlCommand.Connection = connection; 

    sqlCommand.CommandText = String.Format("update downloads " + 
               "set progress='Completed' " + 
               "where uniqueId='{0}' and fileName='{1}'", uniqueId, fileName); 

    AsyncCallback callback = ((result) => 
    { 
     sqlCommand.EndExecuteNonQuery(result); 
     sqlCommand.Connection.Close(); 
    }); 
    sqlCommand.BeginExecuteNonQuery(callback, sqlCommand); 
} 

ProgressChanged工作正常但DownloadCompleted只能在调试模式下工作。 我认为这是因为我需要暂停或在这些调用之间等待。

Update3： 有时我在执行下载后有两个相同的行在数据库中！ 困惑 我是否需要关闭所有连接？

Answer 1

你应该调用BeginExecuteNonQuery的过载接受回调，并在回调结束查询。

更新

如果您有需要对数据库执行完成后执行额外的代码，那么这段代码需要在回调中启动。

例如，如果您目前有：

sqlCommand.BeginExecuteNonQuery(callback, sqlCommand); 
DoSomeAdditionalWorkNow(); 

DoSomeAdditionalWorkNow不会等到查询完成，如果它取决于指令更新的数据，你就会有问题。

这可以通过调用额外的工作方法正在进入回调这样补救：

AsyncCallback callback = ((result) => 
{ 
    sqlCommand.EndExecuteNonQuery(result); 
    connection.Close(); 
    DoSomeAdditionalWorkNow(); 
}); 
sqlCommand.BeginExecuteNonQuery(callback, sqlCommand); 

然而

我认为你是过于复杂编程的生活。您正在执行的查询是不长运行，您将与同步版本执行他们是完美的罚款：

sqlCommand.ExecuteNonQuery(); 

Answer 2

你可以使用的AsyncCallback代替Sleep()

AsyncCallback callback = new AsyncCallback(HandleCallback); 
sqlcommand.BeginExecuteNonQuery(callback, sqlcommand); 

处理使用回调的异步状态。

private void HandleCallback(IAsyncResult result) 
{ 
    SqlCommand command = (SqlCommand)result.AsyncState; 
    command.EndExecuteNonQuery(result); 
    .... 
} 

更新2

代码整体都不错但是，你允许倍数文件下载一个唯一的ID？如果您正在下载具有相同唯一标识的不同文件它可能会更新报告不完整进度的下载表。

不确定你的意思DownloadCompleted只能在调试模式下工作，但是您可以在您的WebMethod中使用私有变量来控制流。说到这一点，由于您使用数据库来更改报告状态，但不会插入大量数据，因此您应该考虑使用同步查询，以便更好地归档结果。