Canal實現數據同步的原理：

1.是根據模擬mysql slave的主從交互協議，偽裝自己是mysql slave，向mysql master發送dump請求。

2.mysql master收到dump請求后,開始推送 binary log給canal

3.canal解析binary log對象（原始byte流）處理。

mysql開啟binlog模式

?(1)查看當前mysql是否開啟binlog模式。

SHOW VARIABLES LIKE '%log_bin%'

如果log_bin的值為OFF是未開啟，為ON是已開啟。

（2）修改/etc/my.cnf 需要開啟binlog模式。

[mysqld] log-bin=mysql-bin binlog-format=ROW server_id=1

修改完成之后，重啟mysqld的服務。

(3) 進入mysql

mysql -h localhost -u root -p

（4）創建賬號 用于測試使用

使用root賬號創建用戶并授予權限

create user canal@'%' IDENTIFIED by 'canal'; GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT,SUPER ON *.* TO 'canal'@'%'; FLUSH PRIVILEGES;

canal服務端安裝配置

（1）下載地址canal

https://github.com/alibaba/canal/releases/tag/canal-1.0.24

（2）下載之后 上傳到linux系統中，解壓縮到指定的目錄/usr/local/canal

解壓縮之后的目錄結構如下：

?

（3）修改 exmaple下的實例配置

vi conf/example/instance.properties

?

修改如圖所示的幾個參數。

一定要注釋掉下面這個參數，這樣就會掃描全庫

#canal.instance.defaultDatabaseName =

（3）啟動服務：

[root@localhost canal]# ./bin/startup.sh

（4）查看日志：

cat /usr/local/canal/logs/canal/canal.log

?

這樣就表示啟動成功了。

?

SpringBoot集成Canal

我們這里使用的一個開源的項目，它實現了springboot與canal的集成。比原生的canal更加優雅。

https://github.com/chenqian56131/spring-boot-starter-canal

下載后，本地進入

cmd進入目錄，mvn? insrall，加載pom坐標。

Springboot項目使用

監聽器類實現

?

自定義監聽

?

?

?

總結

以上是生活随笔為你收集整理的数据同步的解决方案Canal的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。