CanalSharp源码：.NET客户端实现MySQL binlog增量订阅与消费

【实例简介】
CanalSharp 是一个基于阿里巴巴开源项目Canal的.NET客户端，专门用于实现MySQL数据库binlog的增量订阅和消费。Canal本身作为一种CDC（Change Data Capture）组件，允许用户跟踪数据库中的数据变更，并据此采取相应措施。

快速入门：
首先，通过NuGet安装CanalSharp：

Install-Package CanalSharp

接下来，初始化日志配置：

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

CanalSharp支持与主流日志组件如nlog、serilog等集成。创建连接并订阅数据：

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

最后，获取数据：

var msg = await conn.GetAsync(1024);

CanalSharp与Canal版本的兼容性由Canal决定，目前支持的版本包括CanalSharp 1.2.0与Canal 1.1.6。

对于任何使用上的问题，建议通过提交Issue来反馈。CanalSharp目前已经完成了与protobuf 3的协议生成、对接Canal、集群支持等重要功能，且在性能和代码质量上都有显著提升。
【实例截图】
【核心代码】
文件清单
└── CanalSharp-ad355ba5473a01d24339b67f711c57ce4c099685
    ├── assets
    │   ├── 668104-20180925182815646-1209020640.png
    │   ├── 668104-20180925182816462-2110152563.png
    │   └── ys.gif
    ├── build
    │   ├── common.props
    │   ├── Jenkinsfile
    │   ├── Release.sh
    │   └── version.props
    ├── CanalSharp.sln
    ├── CanalSharp.sln.DotSettings
    ├── code-of-conduct.md
    ├── code-of-conduct.zh-CN.md
    ├── docs
    │   ├── package.json
    │   ├── package-lock.json
    │   ├── README.md
    │   └── zh
    │       ├── ack.md
    │       ├── assets
    │       │   ├── canal-1.jpg
    │       │   ├── canal.png
    │       │   ├── canalsharp.png
    │       │   └── ncc.png
    │       ├── canal-cfg.md
    │       ├── db-cfg.md
    │       ├── ha.md
    │       ├── parsing-data.md
    │       ├── quick-start.md
    │       ├── README.md
    │       └── subscribe.md
    ├── LICENSE
    ├── README.md
    ├── renovate.json
    ├── sample
    │   ├── CanalSharp.SimpleApp
    │   │   ├── CanalSharp.SimpleApp.csproj
    │   │   └── Program.cs
    │   └── Docker
    │       ├── docker-compose.yml
    │       ├── mysql
    │       │   ├── init
    │       │   │   └── init.sql
    │       │   └── mysqld.cnf
    │       └── var
    │           └── lib
    │               └── mysql
    ├── src
    │   └── CanalSharp
    │       ├── CanalSharp.csproj
    │       ├── CanalSharp.csproj.DotSettings
    │       ├── Check.cs
    │       ├── Connections
    │       │   ├── CanalOptionsBase.cs
    │       │   ├── ConnectionState.cs
    │       │   ├── Enums
    │       │   │   └── FetchDataTimeoutUnitType.cs
    │       │   ├── HA
    │       │   │   ├── CanalClientRunningInfo.cs
    │       │   │   ├── CanalServerRunningInfo.cs
    │       │   │   ├── ClusterCanalConnection.cs
    │       │   │   └── ClusterCanalOptions.cs
    │       │   ├── ICanalConnection.cs
    │       │   └── Simple
    │       │       ├── SimpleCanalConnection.cs
    │       │       └── SimpleCanalOptions.cs
    │       ├── Exceptions
    │       │   └── CanalConnectionException.cs
    │       ├── Extensions
    │       │   └── ProtocolExtensions.cs
    │       ├── Protocol
    │       │   ├── Assets
    │       │   │   ├── CanalEntry.proto
    │       │   │   └── CanalPacket.proto
    │       │   ├── CanalEntry.cs
    │       │   ├── CanalPacket.cs
    │       │   ├── gen.bat
    │       │   ├── gen.sh
    │       │   ├── Message.cs
    │       │   └── README.md
    │       └── Utils
    │           ├── IpUtil.cs
    │           └── SecurityUtil.cs
    └── test
        └── CanalSharp.UnitTest
            ├── CanalSharp.UnitTest.csproj
            ├── db.sql
            ├── Protocol
            │   └── Protocol_Tests.cs
            ├── README.md
            └── Settings.cs

28 directories, 64 files