SqlDependency數據庫同步+signalr 推送消息

sqlDependency提供了這樣一種能力:當被監測的數據庫中的數據發生變化時,SqlDependency會自動觸發OnChange事件來通知應用程序,從而達到讓系統自動更新數據(或緩存)的目的.

快速上手可參見園友的下列文章

http://www.cnblogs.com/xrinehart/archive/2006/07/27/461106.html .NET 2.0 SqlDependency快速上手指南
http://www.cnblogs.com/gesenkof99/archive/2008/12/19/1358584.html 採用SQLServer2005 Broker和SqlDependency類來提供數據更改通知(原創)

這裏參考他們的文章,本身也作了一個小的示例程序(Sql2005環境)

1.先建一個測試表

CREATE TABLE [dbo].[Messages](
    [ID] [int] IDENTITY(1,1) NOT NULL,
    [UserID] [varchar](50) COLLATE Chinese_PRC_CI_AS NOT NULL,
    [Message] [nvarchar](256) COLLATE Chinese_PRC_CI_AS NOT NULL,
 CONSTRAINT [PK_Messages] PRIMARY KEY CLUSTERED 
(
    [ID] ASC
)WITH (PAD_INDEX  = OFF, STATISTICS_NORECOMPUTE  = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS  = ON, ALLOW_PAGE_LOCKS  = ON) 

ON [PRIMARY]
)

而後能夠利用Sql2005的管理器,隨便輸入幾條數據

2.控制檯程序主要代碼

using System;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;

namespace SqlDependencyTest
{
    class Program
    {
        private static string _connStr;

        static void Main(string[] args)
        {
            _connStr = ConfigurationManager.ConnectionStrings["ConnStr"].ToString();
            SqlDependency.Start(_connStr);//傳入鏈接字符串,啓動基於數據庫的監聽
            UpdateGrid();

            Console.Read();
        }


        private static void UpdateGrid()
        {
            using (SqlConnection connection = new SqlConnection(_connStr))
            {
                //依賴是基於某一張表的,並且查詢語句只能是簡單查詢語句,不能帶top或*,同時必須指定全部者,即相似[dbo].[ ]
                using (SqlCommand command = new SqlCommand("select ID,UserID,[Message] From [dbo].[Messages]", connection))
                {
                    command.CommandType = CommandType.Text;
                    connection.Open();
                    SqlDependency dependency = new SqlDependency(command);
                    dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);

                   SqlDataReader sdr = command.ExecuteReader();
                   Console.WriteLine();
                   while (sdr.Read())
                   {
                       Console.WriteLine("Id:{0}\tUserId:{1}\tMessage:{2}",sdr["ID"].ToString(), sdr["UserId"].ToString(), 

sdr["Message"].ToString());
                   }
                   sdr.Close();
                }
            }
        }


        private static void dependency_OnChange(object sender, SqlNotificationEventArgs e)
        {
            UpdateGrid();
        }
    }
}

 

3.測試運行

運行該控制檯程序後,會輸出[Messages]表的全部數據,這時不要關閉控制檯程序,直接在Sql2005的管理器裏對[Messages]表的數據作些修改(好比新增/刪除等),再看一下控制檯,會發現自動從新輸出了新的數據.

注意:若是在web應用中,由於頁面必須經過瀏覽器請求才能激活服務端的處理,因此頁面一旦處理完成並顯示到瀏覽器後,放着不動的狀況下,OnChange事件始終是得不到觸發的.

最後再推薦一篇園子裏高人的文章:
http://www.cnblogs.com/artech/archive/2008/08/11/1265055.html 是結合Enterprise Library的緩存應用程序塊與SqlDependency的綜合應用,寫得很不錯,強烈推薦想使用緩存的朋友看看.