在C#中实现数据库变更通知，常用机制是 SqlDependency，它基于 SQL Server 的 Service Broker 技术，能在数据发生变化时自动触发回调。这个功能特别适合需要实时更新缓存或界面的场景，比如监控订单状态、库存变化等。
1. 启用 Service Broker
SqlDependency 依赖于 SQL Server 的 Service Broker 服务，必须确保数据库已启用该功能。
-- 检查是否启用SELECT is_broker_enabled FROM sys.databases WHERE name = 'YourDatabaseName'-- 如果未启用，执行以下命令（需独占访问）
ALTER DATABASE YourDatabaseName SET ENABLE_BROKER;
2. 配置 SqlConnection 字符串
连接字符串不需要特殊设置，但 SqlDependency 内部会使用专门的监听通道，确保应用有足够权限连接数据库并订阅通知。
3. 使用 SqlDependency 监听变更
基本流程：启动监听 → 创建命令 → 绑定依赖 → 设置回调 → 执行查询。
示例代码：
using System;
using System.Data.SqlClient;
<p>class Program
{
static void Main()
{
// 第一步：启动监听（只需一次，通常在程序启动时）
SqlDependency.Start(GetConnectionString());</p><pre class='brush:php;toolbar:false;'> string connString = GetConnectionString();
using (var conn = new SqlConnection(connString))
{
conn.Open();
using (var cmd = new SqlCommand("SELECT Id, Name FROM Users", conn))
{
// 绑定 SqlDependency
var dependency = new SqlDependency(cmd);
dependency.OnChange += OnDataChanged;
// 执行查询（注意：必须执行，否则不注册）
using (var reader = cmd.ExecuteReader())
{
while (reader.Read())
{
Console.WriteLine($"{reader["Id"]} - {reader["Name"]}");
}
}
}
}
Console.WriteLine("等待变更通知...");
Console.ReadLine();
// 程序结束时停止监听
SqlDependency.Stop(connString);
}
static void OnDataChanged(object sender, SqlNotificationEventArgs e)
{
// 变更触发后，此方法被调用
Console.WriteLine($"变更类型: {e.Type}, 来源: {e.Source}, 信息: {e.Info}");
// 可在此重新加载数据或刷新缓存
}
static string GetConnectionString()
{
return "Server=.;Database=TestDb;Integrated Security=true";
}}
4. 注意事项与限制
SqlDependency 只适用于 SQL Server（包括 LocalDB 和 Express） 支持的查询有限制：不能使用 *，必须包含表名，不能有聚合函数无 GROUP BY 等 通知是一次性的：每次变更后需重新创建依赖 依赖于 SQL Server Service Broker，网络和权限配置要正确 适合低频变更场景，高频变更可能丢失通知基本上就这些。如果使用的是其他数据库（如 MySQL、PostgreSQL），则无法使用 SqlDependency，需考虑轮询、数据库触发器结合消息队列，或使用数据库特有的通知机制（如 PostgreSQL 的 LISTEN/NOTIFY）。对于 SQL Server，SqlDependency 是最直接的内置方案。
