什么是数据库的变更数据捕获？在C#中如何订阅变更？-C#.Net教程-PHP中文网

什么是数据库的变更数据捕获？在C#中如何订阅变更？

小老鼠

发布： 2025-10-16 11:32:02

原创

558人浏览过

CDC通过捕获数据库变更实现数据同步，C#可通过SQL Server CDC轮询、Debezium+Kafka、触发器+消息队列等方式订阅变更事件。

什么是数据库的变更数据捕获？在c#中如何订阅变更？

变更数据捕获（Change Data Capture，简称 CDC）是一种跟踪数据库中数据变更的技术，能够捕获表中发生的插入、更新和删除操作。它不依赖于应用层的日志，而是直接从数据库的事务日志或触发器等机制中提取变更事件，确保数据变更的实时性和完整性。CDC 常用于数据同步、缓存更新、事件驱动架构和微服务间通信等场景。

常见的 CDC 实现方式

CDC 的实现方式因数据库而异，常见方法包括：

基于事务日志解析：如 MySQL 的 binlog、PostgreSQL 的逻辑复制、SQL Server 的 CDC 特性或变更表。
触发器（Triggers）：在表上创建 INSERT/UPDATE/DELETE 触发器，将变更记录写入专门的变更日志表。
轮询时间戳字段：通过查询带有 LastModifiedTime 字段的表，定期拉取新增或修改的数据（效率较低）。

在 C# 中如何订阅数据库变更

C# 本身不提供原生的 CDC 支持，但可以通过以下几种方式实现对数据库变更的订阅：

1. 使用 SQL Server CDC + 轮询查询

如果使用 SQL Server 并启用了 CDC 功能，系统会自动生成变更表（如 cdc.dbo_YourTable_CT）。你可以用定时任务定期查询这些表获取变更：

// 示例：使用 SqlCommand 查询 SQL Server CDC 变更
using (var connection = new SqlConnection(connectionString))
{
    var command = new SqlCommand(@"
        SELECT __$operation, Id, Name, __$start_lsn 
        FROM cdc.dbo_YourTable_CT 
        WHERE __$start_lsn > @lastLsn", connection);
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">command.Parameters.AddWithValue("@lastLsn", lastProcessedLsn);
connection.Open();
using (var reader = command.ExecuteReader())
{
    while (reader.Read())
    {
        int operation = reader.GetInt32(0); // 1=delete, 2=insert, 3=update(old), 4=update(new)
        // 处理变更
    }
}

登录后复制

}

可通过 sp_cdc_get_min_lsn 和 sp_cdc_get_max_lsn 管理 LSN（日志序列号）范围。

2. 使用 Debezium + Kafka + .NET 消费者

Debezium 是一个开源 CDC 工具，支持 MySQL、PostgreSQL、MongoDB 等，通过读取数据库日志将变更发布到 Kafka。C# 应用可通过 Confluent.Kafka 库订阅 Kafka 主题：

阿里云-虚拟数字人

阿里云-虚拟数字人是什么？ ...

查看详情

using Confluent.Kafka;
<p>var config = new ConsumerConfig
{
BootstrapServers = "localhost:9092",
GroupId = "cdc-group",
AutoOffsetReset = AutoOffsetReset.Latest
};</p><p>using (var consumer = new ConsumerBuilder<Ignore, string>(config).Build())
{
consumer.Subscribe("your_table_changes");</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">while (true)
{
    var consumeResult = consumer.Consume();
    Console.WriteLine($"Received: {consumeResult.Message.Value}");
    // 解析 JSON 消息，处理 insert/update/delete
}

登录后复制

}

Debezium 发送的消息是结构化 JSON，包含 before、after、op（操作类型）、ts_ms 等字段。

3. 使用触发器 + 消息队列

在数据库中创建触发器，将变更写入一个消息表或调用外部服务（如 Service Broker），然后 C# 程序监听该表或接收通知：

-- 示例：SQL Server 触发器
CREATE TRIGGER trg_YourTable_Change
ON dbo.YourTable
AFTER INSERT, UPDATE, DELETE
AS
BEGIN
    INSERT INTO ChangeLog (TableName, Operation, Timestamp)
    VALUES ('YourTable', 'U', GETDATE());
END

登录后复制

C# 中可用 SqlDependency 或后台服务轮询 ChangeLog 表来触发处理逻辑。

4. 使用第三方库或中间件

Microsoft SQLDependency / SqlNotificationRequest：适用于 SQL Server，可监听查询变更（基于 Service Broker）。
Entity Framework Interceptors：在 SaveChanges 时捕获变更，属于应用层方案，不能捕获外部变更。
Wolverine 或 MassTransit：结合持久化存储与事件发布，适合事件溯源架构。