启用查询通知

项目
05/09/2023

使用查询通知的应用程序具有一组通用的要求。必须正确配置数据源才能支持 SQL 查询通知，并且用户必须具有正确的客户端和服务器端权限。

若要使用查询通知，必须：

为数据库启用查询通知。
确保用于连接数据库的用户 ID 具有所需的权限。
使用 SqlCommand 对象与关联的通知对象（SqlDependency 或 SqlNotificationRequest）一起执行有效的 SELECT 语句。
如果要监视的数据发生更改，请提供代码以处理通知。

查询通知需求

只有满足下列特定要求的 SELECT 语句才支持查询通知。下表提供了 SQL Server 文档中服务代理和查询通知文档的链接。

SQL Server 文档

启用查询通知运行示例代码

若要通过使用 SQL Server Management Studio 在 AdventureWorks 数据库上启用 Service Broker，请执行下面的 Transact-SQL 语句：

ALTER DATABASE AdventureWorks SET ENABLE_BROKER;

为了使查询通知示例正确运行，必须在数据库服务器上执行以下 Transact-SQL 语句。

CREATE QUEUE ContactChangeMessages;  
  
CREATE SERVICE ContactChangeNotifications  
  ON QUEUE ContactChangeMessages  
([http://schemas.microsoft.com/SQL/Notifications/PostQueryNotification]);

查询通知权限

执行请求通知的命令的用户必须具有对服务器的 SUBSCRIBE QUERY NOTIFICATIONS 数据库权限。

在部分信任情况下运行的客户端代码需要 SqlClientPermission。

以下代码创建 SqlClientPermission 对象，并将 PermissionState 设置为 Unrestricted。如果未对调用堆栈中处于较高位置的所有调用方授予权限，Demand 会在运行时强制执行 SecurityException。

// Code requires directives to
// System.Security.Permissions and
// System.Data.SqlClient

private bool CanRequestNotifications()
{
    SqlClientPermission permission =
        new SqlClientPermission(
        PermissionState.Unrestricted);
    try
    {
        permission.Demand();
        return true;
    }
    catch (System.Exception)
    {
        return false;
    }
}

' Code requires directives to
' System.Security.Permissions and
' System.Data.SqlClient

Private Function CanRequestNotifications() As Boolean

    Dim permission As New SqlClientPermission( _
      PermissionState.Unrestricted)

    Try
        permission.Demand()
        Return True
    Catch ex As Exception
        Return False
    End Try

End Function

选择通知对象

查询通知 API 提供两个用于处理通知的对象：SqlDependency 和 SqlNotificationRequest。通常情况下，大多数非 ASP.NET 应用程序应使用 SqlDependency 对象。 ASP.NET 应用程序应使用更高级别的 SqlCacheDependency，以便包装 SqlDependency 并为管理通知和缓存对象提供框架。

使用 SqlDependency

要使用 SqlDependency，必须对所使用的 SQL Server 数据库启用 Service Broker，并且用户必须具有接收通知的权限。 Service Broker 对象（如通知队列）是预定义的。

此外，SqlDependency 会自动启动一个工作线程以在通知发布到队列中时处理这些通知；它还会分析 Service Broker 消息，将此信息作为事件参数数据公开。必须通过调用 Start 方法建立对数据库的依赖关系，从而初始化 SqlDependency。这是一个静态方法，对于每个所需的数据库连接，在应用程序初始化期间仅需调用一次。必须在应用程序终止时为执行的每个相关连接调用 Stop 方法。

使用 SqlNotificationRequest

与此相反，SqlNotificationRequest 要求你自己实现整个侦听基础结构。此外，必须定义队列所支持的所有支持 Service Broker 对象，例如队列、服务和消息类型。如果你的应用程序需要特殊通知消息或通知行为，或者你的应用程序是较大的 Service Broker 应用程序的一部分，则此手动方法非常有用。

通过