圖1.該圖顯示了.NET的查詢通知所使用的Pubs數(shù)據(jù)庫(kù)中的缺省隊(duì)列和服務(wù)。
下面是理解這一過程的一些有關(guān)重要內(nèi)容：
· 存在一些規(guī)則以指出SQL Server接收哪些類型的查詢。
· 一旦SQL Server發(fā)送回通知，隊(duì)列和服務(wù)即被刪除。這意味著，你僅能在每次請(qǐng)求中得到一個(gè)通知。一個(gè)典型的應(yīng)用程序會(huì)重新查詢數(shù)據(jù)庫(kù)并且，在同時(shí)，請(qǐng)求在Service Broker中創(chuàng)建一種新的依賴性。
· 返回到應(yīng)用程序的信息也不過是“something changed”。該應(yīng)用程序并不被通知改變了什么（請(qǐng)參考本文中的SQLNotificationEventArgs一節(jié)了解更多的信息）。
· 盡管依賴性被綁定到從查詢中返回的行上；但是，它并不被查詢中的單個(gè)列加以過濾。如果你有一個(gè)查詢—它返回你的組織的基本成員姓名以及那些單個(gè)改變之一的地址（但是，其姓名并不改變），這將觸發(fā)一個(gè)改變通知。很希望，這種特殊行為在未來(lái)的版本中會(huì)有所改變。
· 通知被返回，通過一個(gè)專門針對(duì)這一目的建立的SqlConnection。這個(gè)連接并不加入連接池中。
三. 何時(shí)使用查詢通知
查詢通知是針對(duì)于并不經(jīng)常改變的數(shù)據(jù)而設(shè)計(jì)的。最好把它應(yīng)用于服務(wù)器端的應(yīng)用程序(例如ASP.NET或remoting)而不是客戶端應(yīng)用程序(例如Windows表單應(yīng)用程序)。記住，每一個(gè)通知請(qǐng)求都要在SQL Server中注冊(cè)。如果你擁有大量的都有通知請(qǐng)求的客戶端應(yīng)用程序，那么這可能會(huì)導(dǎo)致你的服務(wù)器產(chǎn)生資源問題。微軟推薦，對(duì)于客戶端應(yīng)用程序，你應(yīng)該限制查詢通知使用為不多于十個(gè)并行用戶。
對(duì)于大規(guī)模應(yīng)用程序來(lái)說，查詢通知可能是一種強(qiáng)有力的幫助，而不用簡(jiǎn)單地添加越來(lái)越多的服務(wù)器以滿足要求。設(shè)想，有一家大型的為成千上百萬(wàn)用戶提供在線軟件更新服務(wù)的軟件公司。不是使每一個(gè)用戶的更新操作都觸發(fā)服務(wù)器上的另一個(gè)查詢來(lái)確定需要哪些組件，而是能夠緩沖查詢結(jié)果并且可以直接從該緩存中服務(wù)匹配的查詢。
注意：對(duì)于客戶端應(yīng)用程序來(lái)說，應(yīng)該限制你的查詢通知使用—不多于十個(gè)并發(fā)用戶。
對(duì)于較小規(guī)模的情況而言，下拉式列表框是另一種典型的數(shù)據(jù)集；此時(shí)該數(shù)據(jù)集更新的次數(shù)并不如請(qǐng)求的次數(shù)多。產(chǎn)品列表、州列表、國(guó)家列表、供應(yīng)商、銷售人，甚至更多不太需要頻繁改變的信息正是使用通知的較好候選。
四. 為使用查詢通知作準(zhǔn)備
因?yàn)槟J(rèn)情況下SQL Server 2005處于高度安全的狀態(tài)，所以你需要“打開”一些功能才能使用查詢通知。首先，你要使用的每一個(gè)數(shù)據(jù)庫(kù)都需要啟動(dòng)Service Broker功能。為此，你可以在T-SQL中使用如下命令實(shí)現(xiàn)：
USE mydatabase
ALTER DATABASE mydb SET ENABLE_BROKER
另外，你需要授予一些SQL Server權(quán)限以允許非管理員帳戶能夠參與使用查詢通知。
五. SqlDependency.Start和Stop
SqlDependency和SqlCacheDependency都要求，在任何通知請(qǐng)求前先調(diào)用靜態(tài)方法SqlDependency.Start()。這個(gè)方法負(fù)責(zé)創(chuàng)建一個(gè)SqlConnection以實(shí)現(xiàn)在數(shù)據(jù)改變時(shí)接收通知。注意，你僅需要在一個(gè)應(yīng)用程序的生命周期的開始建立這些內(nèi)容。例如，在一個(gè)ASP.NET應(yīng)用程序中，global.asax文件的Application_Start事件處理器就是實(shí)現(xiàn)這一功能的好地方。
注意，對(duì)包含在通知中的每一個(gè)連接都應(yīng)該調(diào)用Start方法。因此，如果你在應(yīng)用程序中存取多個(gè)數(shù)據(jù)庫(kù)，那么你需要為每一個(gè)數(shù)據(jù)庫(kù)調(diào)用Start。在下列示例中，有一個(gè)針對(duì)Pubs數(shù)據(jù)庫(kù)的連接串pubsConn，它在這個(gè)應(yīng)用程序的web.config文件中定義。
為了切斷這個(gè)連接，你可以使用SqlDependency.Stop()，這也是一個(gè)靜態(tài)方法。
ByVal e as EventArgs)
System.Data.SqlClient.SqlDependency.Start _
(System.Configuration.ConfigurationManager. _
Connectionstrings("pubsConn").ConnectionString)
End Sub
Sub Application_End(ByVal sender as Object，
ByVal e as EventArgs)
System.Data.SqlClient.SqlDependency.Stop _
(System.Configuration.ConfigurationManager. _
Connectionstrings("pubsConn").ConnectionString)
End Sub
如果你在調(diào)用Start和Stop的同時(shí)觀察SQL Server Profiler，那么你會(huì)看到許多有趣的信息。當(dāng)調(diào)用Start時(shí)，應(yīng)用程序運(yùn)行一個(gè)查詢以確保支持Service Broker，然后創(chuàng)建一個(gè)存儲(chǔ)過程備以后用于清除在Service Broker基礎(chǔ)結(jié)構(gòu)中的SqlDependency隊(duì)列和服務(wù)。最后，它運(yùn)行一個(gè)SQL Server 2005 WaitFor命令，該命令負(fù)責(zé)查詢?cè)贜otification Service部分的入口。這就是如果你使用ADO.NET的低級(jí)SqlNotificationRequest對(duì)象的話所有你需要顯式完成的事情。
在整個(gè)的.NET 2.0的設(shè)計(jì)過程中，SqlDependency底層架構(gòu)從一種推模式（來(lái)自SQL Server）改變?yōu)橐环N拉模式（來(lái)自.NET）。這樣做的原因是為了解決第一次設(shè)計(jì)時(shí)所導(dǎo)致的一些安全問題。微軟的Sushil Chordia在MSDN上發(fā)表了一篇有關(guān)于這種改進(jìn)的文章，該文詳細(xì)描述了這一改進(jìn)的內(nèi)在機(jī)理。
六. 你的第一個(gè)通知
下面，讓我們開始使用SqlDependency來(lái)分析一下所有上面這些是如何協(xié)同工作的。
首先，我們創(chuàng)建一個(gè)類NotificationTest來(lái)存取你的數(shù)據(jù)。在這個(gè)類中，還要?jiǎng)?chuàng)建一個(gè)典型的函數(shù)以便從Pubs數(shù)據(jù)庫(kù)的Authors表中查詢一些數(shù)據(jù)并返回一個(gè)SqlDataReader。
Imports System.Data.SqlClient
Public Class NotificationTest
Public Function DepTest() As SqlDataReader
Dim conn As New SqlConnection(connstring)
conn.Open()
Dim cmd As New SqlCommand(
"SELECT * FROM authors("， conn)")
Dim rdr As SqlDataReader
rdr = cmd.ExecuteReader()
Return rdr
End Function
End Class
現(xiàn)在，讓我們修改代碼來(lái)加入這種依賴性。首先，聲明一個(gè)名為SqlDependency的對(duì)象。為了使之用于該類中的其它函數(shù)中，我把它定義為一個(gè)類變量。
然后，你需要改變這個(gè)查詢。查詢通知要求你顯式地列舉在你的查詢中的列，以及總是使用一種“兩部分”的表名。注意一下在修改后的代碼示例中的新的查詢文本。
然后，實(shí)例化新的SqlDependency并且把它依附到命令中。
就是這些。當(dāng)執(zhí)行命令時(shí)，依賴性隨著它直到數(shù)據(jù)庫(kù)。在它處理查詢的同時(shí)，SQL Server能夠看到這一依賴性并且把它發(fā)送到Service Broker以注冊(cè)它。
Imports System.Data.SqlClient
Public Class NotificationTest
Dim
dep As SqlDependency
Public Function DepTest() As SqlDataReader
Dim conn As New SqlConnection(connstring)
conn.Open()
Dim cmd As New SqlCommand( _
"SELECT au_id， au_lname，au_fname " & _
"FROM dbo.authors"， conn)
dep = New SqlDependency(cmd)
Dim rdr As SqlDataReader
rdr = cmd.ExecuteReader()
Return rdr
End Function
End Class
現(xiàn)在，你已經(jīng)注冊(cè)了依賴性，但是當(dāng)通知返回到應(yīng)用程序時(shí)你還根本沒有捕獲它。不過，SqlDependency類提供了兩種方式來(lái)了解一個(gè)通知。一種方式是通過OnChange事件，你可以通過創(chuàng)建一個(gè)代理來(lái)捕獲它；另一種方式是通過屬性HasChanges，你可以在你的應(yīng)用程序邏輯中對(duì)之進(jìn)行測(cè)試。在下列代碼中，我在OnDepChange事件中添加了代碼以便在后面的某個(gè)時(shí)候測(cè)試通知。
Imports System.Data.SqlClient
Public Class NotificationTest
Dim dep As SqlDependency
Public Function DepTest() As SqlDataReader
Dim conn As New SqlConnection(connstring)
conn.Open()
Dim cmd As New SqlCommand( _
"SELECT au_id，au_lname，au_fname FROM " + _
"dbo.authors"， conn)
dep = New SqlDependency(cmd)
AddHandler dep.OnChange， AddressOf OnDepChange
Dim rdr As SqlDataReader
rdr = cmd.ExecuteReader()
Return rdr
End Function
'處理器方法
Public Sub OnDepChange(ByVal sender As Object， _
ByVal e As SqlNotificationEventArgs)
Dim DepInfo As String = e.Info.ToString
'做一些事情以響應(yīng)通知
End Sub
Public ReadOnly Property HasChanges() As Boolean
Get
Return dep.HasChanges
End Get
End Property
End Class
現(xiàn)在，我們來(lái)看一下其工作原理。首先，把一個(gè)斷點(diǎn)放到OnDepChange事件的End Sub代碼行。然后，從你喜歡的網(wǎng)頁(yè)、表單程序或控制臺(tái)程序中調(diào)用DepTest函數(shù)來(lái)進(jìn)行測(cè)試。在返回SqlDataReader后，在Visual Studio 2005的Server Explorer或在SQL Server Management Studio中打開Authors表并且編輯某一個(gè)字段內(nèi)容。例如，一旦鎖定這一改變，那么，當(dāng)你把光標(biāo)移動(dòng)到表中的一個(gè)新行時(shí)，斷點(diǎn)應(yīng)該被激活。
七. SQLNotificationEventArgs
當(dāng)你看到通知的確從數(shù)據(jù)庫(kù)中傳來(lái)時(shí)，你可以分析一下相應(yīng)變量的值，它是一個(gè)SqlNotificationEventArgs對(duì)象。SqlDependency總是隨著OnChange事件返回這個(gè)對(duì)象，而且它是很有用的。其中，SqlNotificationInfo是一個(gè)具有18種可能值的枚舉類型。其中，一些值對(duì)應(yīng)情況正常，而另一些顯示出了問題。這些枚舉中有Update，Insert和Delete—告訴你在數(shù)據(jù)中發(fā)生了什么類型的變化。還有其它一些值即
使在事件發(fā)生時(shí)也不會(huì)被發(fā)送。例如，重新啟動(dòng)服務(wù)器將激發(fā)所有的通知；而枚舉值Drop或Truncate告訴你已經(jīng)對(duì)依賴的表實(shí)現(xiàn)了某種操作。
另外，還存在一些依賴性甚至還不能被注冊(cè)的情形，例如如果你試圖對(duì)一個(gè)UPDATE查詢?cè)O(shè)置一個(gè)依賴性將返回Invalid。而返回值Query顯示你的查詢語(yǔ)法并不符合通知的嚴(yán)格規(guī)則。上面枚舉表中的最后兩個(gè)枚舉值，還有其它幾個(gè)與不能注冊(cè)查詢相關(guān)的枚舉值在執(zhí)行該命令時(shí)被立即返回。
通過查找MSDN庫(kù)中的有關(guān)SqlNotificationInfo枚舉文檔，你可以得到這些枚舉的完全列表。
當(dāng)我一些場(chǎng)合上談?wù)摬樵兺ㄖ獣r(shí)，人們總是問我：“通知是否會(huì)告訴你發(fā)生了什么事情？”。回答是“不會(huì)”。
總之，SQLNotificationEventArgs能夠向你給出一個(gè)通知中最為詳細(xì)的信息，而這些信息在調(diào)試排錯(cuò)時(shí)是非常有用的。
聯(lián)系客服
