EF Core：如何创建检测数据库外部新增记录变更的服务

针对你用.NET Core + EF，要实时检测数据库新增记录并触发指定函数的需求，这里给几个基于数据库原生特性的靠谱方案，完全避开轮询带来的高负载问题：

按数据库类型分的具体实现 #

SQL Server #

• Change Data Capture（CDC）：给目标表开启CDC后，数据库会自动把新增、修改、删除的记录存到专门的变更日志表里。你可以写个.NET Core后台服务，轻量查询未处理的日志记录（哪怕每秒查一次，因为日志表只有变更数据，负载极低），一旦有新数据就执行指定函数。CDC对数据库性能影响很小，适配高并发场景。
• Service Broker：创建数据库触发器，当表有新记录插入时，向Service Broker发送消息。然后在.NET Core里写个长连接服务监听Broker的消息队列，收到消息后直接执行逻辑。这种纯异步触发的方式，完全不会阻塞数据插入操作。

PostgreSQL #

• LISTEN/NOTIFY：先写一个数据库触发器，当目标表新增记录时，调用NOTIFY命令发送通知到指定频道。然后用Npgsql连接数据库，在.NET Core服务里通过Listen方法监听该频道，一收到通知就执行你的函数。这个方案轻量高效，实时性拉满。

MySQL #

• Binlog监听：开启MySQL的二进制日志（Binlog）并设置为ROW模式，然后用.NET的Binlog解析库（比如MySqlBinlogReader）监听Binlog，解析出新增记录的事件后触发对应操作。这种方式能获取最原始的变更数据，适合对数据完整性要求高的场景。
• 触发器+中间表：创建触发器，把新增记录的关键信息写入一个中间表，再用.NET Core后台服务轻量监听这个中间表（仅变更数据，负载极低），查到新数据就执行指定函数，比直接轮询主表高效太多。

结合EF Core的优化技巧 #

EF Core本身没有原生实时监听能力，但可以用EF来统一处理变更后的数据：比如用EF读取CDC日志表或中间表，筛选出未处理的记录，执行完函数后标记为已处理，让数据处理逻辑更统一。

额外注意事项 #

• 先确认你的数据库版本支持对应特性（比如SQL Server 2008及以上才支持CDC）。
• 高并发场景下建议搭配消息队列（比如RabbitMQ）做缓冲：数据库触发的消息先存入队列，.NET服务从队列消费执行函数，避免瞬间请求过载压垮服务。
• 做好异常处理和断点续传，比如服务重启后要能接续处理未完成的变更，避免数据遗漏。

内容的提问来源于stack exchange，提问作者Arekadiusz