C# Apache-2.0

CanalSharp

Alibaba mysql database binlog subscription & consumer components Canal's .NET client.

D

dotnetcore

Dernière activité 25 sept. 2026
dotnetcore/CanalSharp

594

étoiles

97

forks

17

issues ouvertes

binlogcanalcanal-clientcdcmysqlnetcorenetstandard20real-time

Ce README est souvent en anglais.

CanalSharp

Latest version Member project of .NET Core Community

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);

支持版本

CanalSharp Canal
1.2.0 1.1.6

Mysql 版本由 Canal 决定。

文档

Github: docs

WebSite: Canal Document (推荐)

问题反馈

请通过 Issue 向我们提交问题反馈,在提交时尽可能提供详细的信息,以便我们进行排查和解决。

贡献代码

如果你有一些好的想法,欢迎您提交 Pull Request 或者 Issue

重构进度

目前重构的版本已经完全覆盖旧版本,且性能更高,代码更优美,实现了旧版本未实现的部分功能,支持最新的 Canal。

Task Status
protobuf 3 协议生成 已完成
对接 Canal 已完成
数据订阅封装 TODO
集群支持(Service 集群和 Client 集tgi群) 已完成
数据发送到Kafka 直接通过 Canal 发送
数据发送到Redis 直接通过 Canal 发送

Projets similaires

阿里巴巴 MySQL binlog 增量订阅&消费组件

Java
Aalibaba
29,7 k étoiles7,6 k

MySQL Connector for .NET

C#ado-netasyncdotnet
Mmysql-net
1,5 k étoiles353

RabbitMQ .NET client for .NET Standard 2.0+ and .NET 4.6.2+

C#c-sharpdotnetdotnet-core
Rrabbitmq
2,3 k étoiles621