sqlDependency基于SQL Server的Service Broker实现数据库变更通知，适用于实时更新场景。需启用Service Broker并配置连接，通过启动监听、绑定命令、设置回调来监控变化，支持一次订阅一次通知，适合低频变更，仅用于SQL Server环境。
在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 是最直接的内置方案。