CanalSharp 基于 MySQL 增量订阅和消费组件 Canal 的 .NET 客户端

Question

CanalSharp 是阿里巴巴开源项目 mysql 数据库 binlog 的增量订阅&消费组件 Canal 的 .NET 客户端。在数据库中，更改数据捕获（CDC）是一组软件设计模式，用于确定和跟踪已更改的数据，以便可以使用已更改的数据来采取措施，Canal 便是 mysql 数据库的一种 cdc 组件。

快速入门

安装

Install-Package CanalSharp

初始化日志

var loggerFactory = LoggerFactory.Create(builder =>
{
  builder
    .AddFilter("Microsoft", LogLevel.Debug)
    .AddFilter("System", LogLevel.Information)
    .AddConsole();
});
var logger= loggerFactory.CreateLogger<SimpleCanalConnection>();

CanalSharp 使用 Microsoft.Extensions.Logging.Abstractions ，因为目前主流日志组件，如：nlog、serilog 等，全部支持此日志抽象接入，也就是说你可以通过安装 nlog、serilog 对其的适配，来使用它们，无论是 Console App 或则是 Web App。

创建连接

var conn=new SimpleCanalConnection(new SimpleCanalOptions("127.0.0.1",11111,1234),logger);
//连接到 Canal Server
await conn.ConnectAsync();
//订阅
await conn.SubscribeAsync();

获取数据

var msg = await conn.GetAsync(1024);

中文文档：https://www.wenjiangs.com/docs/canalsharp-docs