摘要：
实现步骤：1.在数据库中启用Service Broker。检查数据库_ Broker_enabledFROMsys中是否启用了Service Broker SELECTIS。DatabasesWHERE Name='数据库名称'查询结果：is_ broker_ enabledde的结果为0，这意味着数据库未启动Service broker解决方案：使用数据库名称goALTERDATABASE数据库名称SETNEW_ BROKERWITHROLLBACKIMEDIATE；ALTERDATABASE数据库名称SETENABLE_ BROKER；注意：如果这两个句子同时执行，如果这两句话分别执行，将显示消息“回滚非法交易。估计回滚完成：100%”。查询再次出现_ broker_启用状态为1。数据库未能成功启动Service broker。
开发环境: .net / C# (.net core理论上也可以)
数据库：MS SQL Server 2005 以上 （我用的sqlserver2012）
功能：SqlDependency提供了一种机制，当被监听的数据库中的数据发生变化时,SqlDependency会自动触发OnChange事件来通知应用程序,从而达到让应用程序实时更新数据(或缓存)的目的，而不用定期请求后端，如果加上SignalR技术，基本可以实现实时通信。
我的场景：每天数据变化少，一天不超过十次，但是每次都希望得到提醒，并反应到前台web页面上。
实现步骤：
1、数据库启用 Service Broker
检查数据库是否启用了Service Broker
SELECT is_broker_enabled FROM sys.databases WHERE name = '数据库名'
查询结果：is_broker_enabled de 结果是 0，代表数据库没有启动 Service Broker
解决办法：
use 数据库名 go ALTER DATABASE 数据库名 SET NEW_BROKER WITH ROLLBACK IMMEDIATE; ALTER DATABASE 数据库名 SET ENABLE_BROKER;
注：两句同时执行，单独执行会显示 "正在回滚不合法事务。估计回滚已完成: 100%"
再次查询is_broker_enabled状态，状态为1，数据库没有启动 Service Broker成功。
2、Webconfig 中启用缓存
在<system.web>节点加入
<caching> <sqlCacheDependency enabled="true" pollTime="1000"> <databases> <add name="PDMCAPPS" connectionStringName="数据库连接字符串" pollTime="1000"/> </databases> </sqlCacheDependency> </caching>
3、在Global.asax添加启用和停止监听
string connectionString = ConfigurationManager.ConnectionStrings["数据库连接字符串名称"].ConnectionString; void Application_Start(object sender, EventArgs e) { // Code that runs on application startup System.Data.SqlClient.SqlDependency.Start(connectionString); } void Application_End(object sender, EventArgs e) { // Code that runs on application shutdown System.Data.SqlClient.SqlDependency.Stop(connectionString); }
4、主程序代码
private static string conn = ConfigurationManager.ConnectionStrings["连接字符串名称"].ConnectionString; static SqlDependency dependency; protected void Page_Load(object sender, EventArgs e) { SqlDependency.Start(conn); //传入连接字符串,启动基于数据库的监听 if (!IsPostBack) { Update(conn); } } //使用SqlDependency监控数据库表变化 private void Update(string conn) { using (SqlConnection connection = new SqlConnection(conn)) { StringBuilder strsql = new StringBuilder(); //对被监控的目标表做简单查询，此处 要注意 不能使用* 表名要加[dbo] 否则会出现一直调用执行 OnChange strsql.Append(@"sql查询语句，查询目标表"); using (SqlCommand command = new SqlCommand(strsql.ToString(), connection)) { connection.Open(); command.CommandType = CommandType.Text; dependency = new SqlDependency(command); dependency.OnChange += new OnChangeEventHandler(dependency_OnChange);//添加监控，检测数据表变化 //必须要执行一下command command.ExecuteNonQuery(); //Console.WriteLine(dependency.HasChanges); //connection.Close(); } } } //检测到数据表变化后执行动作 private void dependency_OnChange(object sender, SqlNotificationEventArgs e) { if (e.Type == SqlNotificationType.Change) { //这里要再次调用 Update(conn); //刷新前台页面 Response.AddHeader("Refresh", "0"); } }