danielchudc / canalsharp

Alibaba mysql database binlog incremental subscription & consumer components Canal's .NET client. 阿里巴巴mysql数据库binlog的增量订阅&消费组件 Canal 的 .NET 客户端

CanalSharp |中文

What is CanalSharp?

CanalSharp is a .NET Client of alibaba's open source component Canal,and it provides .NET developer a much easier way to use Canal.

Canal is a incremental Publish&Subscription component based on mysql's binlog.To learn more a bout Cancal,please visit alibaba/canal/wiki

log based incremental pub&sub model can be applied to many business cases:

1. Database Mirroring
2. Realtime Database backup
3. Multi-level index
4. search build
5. Busienss cache refresh
6. Notification on price change(in e-commerce site) and so on

Application scenario

CanalSharp as a .NET client of canal,it can be used in situations where Canal is being used.We have listed some using scenarios above,here are some more detailed use cases:

1. As a substitution of polling Database to monitor Database changes,it is much more effective than polling.

2. Realtime Update data in search engine when data in mysql database changed.For example,in a E-commerce site,when Product information changed,it can be updated to Elasticsearch、solr,etc in a realtime way.

3. Realtime update data in cache,Also take E-commerce site as an example,when price,inventory and other product information changed,it can be updated to Redis in a realtime way.

4. Database Backup,synchronization.

5. To trigger some other business logics on data change,for example,when a customer place an order without payment in a certain period of time and so the order is cancelled automatically,we get the changed status of the order and then we can push a notification to the customer(or take some other actions)

6. Push changed data to RabbitMq,kafak or other message queues for consuming.

Protocol

As a .NET client of Canal,it use Socket for communication,the transfer Protocol is TCP,and the data exchange Protocol is Google's Protocol Buffer 3.0

Operating principle

1. Canal connect to Mysql database ,pretented to be a slave of mysql

2. CanalSharp(as mentioned it is a client of Cancal) connect to Canal

3. When data in the database changed,it write the changes to binlog

4. Canal send dump request to mysql database,get binlog and then parse it.

5. CancalSharp send request to Canal for data.

6. Canal send parsed data to CanalSharp

7. CancalSharp get data successfully and then send an acknowledgement to Canal(optional)

8. Canal record the consumption position

The following picture shows how it works:

Get Start

1. Install Canal

To Install and configure Canal, please visit https://github.com/alibaba/canal/wiki/QuickStart

2.Create a .NET Core Console Project

3. Install CanalSharp from Nuget

Install-Package CanalSharp.Client

4. Connect to Canal

//canal' destination config,default to example
var destination = "example";
//instantiate a simple CanalClient connector object(it does not support clustering),the parameters are canal's IP Address,port number,destination,username and password
var connector = CanalConnectors.NewSingleConnector("127.0.0.1", 11111, destination, "", "");
//connect to Canal
connector.Connect();
//Subscription,the parameter is a Filter,if we provided nothing it use Canal's default Filter. a filter is a rule for filtering data,data go throgh the filter will be passed in.
connector.Subscribe(".*\\..*");

//Get data with acknowledgement to indicate success
connector.Get(batchSize);
//Get data without acknowledgement to indicate success
connector.GetWithoutAck(batchSize);

for more detailed information please visit Sample

Quick as running sample

1. Run mysql and canal by command

git clone https://github.com/CanalSharp/CanalSharp.git
cd  CanalSharp
cd docker
docker-compose up -d

2. Use navicat or orther client to connect to mysql

ip：the ip address of the server where docker running

mysql username：root

mysql password：000000

mysql port：4406

There is a default database named test,which contains a table named test

3.run the sample project

4.Test it

Execute the following sql:

insert into test values(1000,'111');
update test set name='222' where id=1000;
delete from test where id=1000;

we can see that after executing insrt,update,delete sql,Our CanalSharp get the changed data.

Next Goal

CanalSharp clustering support

Contribute

One of the easiest ways to contribute is to participate in discussions and discuss issues. You can also contribute by submitting pull requests with code changes.

License

Apache 2.0