SqlDependency数据库监控类的使用方法

ALTER DATABASE [YOUR DBNAME] SET NEW_BROKER WITH ROLLBACK IMMEDIATE; 
ALTER DATABASE [YOUR DBNAME] SET ENABLE_BROKER;

public string connString;

private string SqlMonitorCmd;

public SQLHelper(bool SqlMonitorEnable, string sqlMonitorCmd, string ConnString)
{
    connString = ConnString;
    SqlMonitorCmd = sqlMonitorCmd;
    if (SqlMonitorEnable && !string.IsNullOrEmpty(SqlMonitorCmd) && !string.IsNullOrEmpty(connString))
    {
        SqlDependency.Start(connString);
        SqlMonitor();
    }
}

private void SqlMonitor()
{
       using (SqlConnection connection = new SqlConnection(connString))
       {
                connection.Open();
                //依赖是基于某一张表的,而且查询语句只能是简单查询语句,不能带top或*,同时必须指定所有者,即类似[dbo].[]
                using (SqlCommand command = new SqlCommand(SqlMonitorCmd, connection))
                {
                    command.CommandType = CommandType.Text;
                    SqlDependency sqlDependency = new SqlDependency(command);
                    sqlDependency.OnChange += new OnChangeEventHandler(dependency_OnChange);
                    command.ExecuteReader();
                }
        }
}

  private void dependency_OnChange(object sender, SqlNotificationEventArgs e)
  {
         if (e.Type == SqlNotificationType.Change) //只有数据发生变化时,才重新获取并数据
         {
             SqlChanged?.Invoke();
             SqlMonitor();//由于OnChange只能触发一次，所以要重新绑定
         }
  }