我想知道您建议使用什么方法来避免我的表单在执行存储过程时挂起。请参阅我附加的代码。我正在通过 Stream API 从 Twitter 收集数据,并且在执行存储过程时表单挂起。使用 BackgroundWorker 是避免表单挂起的最佳方法吗?你能给我一个例子,这是如何在我的代码中实现的。
Imports System.Linq
Imports System.Text
Imports System.Net
Imports System.IO
Imports Newtonsoft.Json.Linq
Imports Newtonsoft.Json
Imports System.Data.SqlClient
Imports System.Threading
Public Class Form1
Private Sub btnDB_Click(sender As System.Object, e As System.EventArgs) Handles btnDB.Click
Dim url As String = "https://stream.twitter.com/1.1/statuses/filter.json?track=twitter"
Dim request As WebRequest = WebRequest.Create(url)
request.Credentials = New NetworkCredential("username", "pwd")
Dim WebResponse = request.GetResponse()
Dim encode As Encoding = Encoding.GetEncoding("utf-8")
Dim responseStrem = New StreamReader(WebResponse.GetResponseStream(), encode)
While Not responseStrem.EndOfStream
'Console.WriteLine(responseStrem.ReadLine());
Dim json As String = responseStrem.ReadLine()
If json.Length <> 0 Then
ParseJson(json)
End If
End While
End Sub
Private Sub ParseJson(ByVal Json As String)
Dim connectionstring As String = "Data Source=.;Initial Catalog=db_twitter_stream;User ID=sa;Password=xxx"
Dim counter As Integer = 0
Dim conn As New SqlConnection(connectionstring)
conn.Open()
Dim o As JObject = JObject.Parse(json)
Dim tweet As String = o("text")
Dim source As String = o("source")
Dim created_at As String = o("created_at")
Dim cmd As New SqlCommand("dbo.prc_tweets", conn)
cmd.CommandType = System.Data.CommandType.StoredProcedure
cmd.Parameters.Add(New SqlParameter("@tweet", tweet))
cmd.Parameters.Add(New SqlParameter("@source", source))
cmd.Parameters.Add(New SqlParameter("@created_at", created_at))
cmd.ExecuteNonQuery()
counter = counter + 1
lblCount.Text = counter.ToString()
conn.Close()
End Sub
Private Sub btnQuit_Click(sender As System.Object, e As System.EventArgs) Handles btnQuit.Click
Me.Close()
End Sub
End Class