Canal實(shí)現(xiàn)數(shù)據(jù)同步的原理：

1.是根據(jù)模擬mysql slave的主從交互協(xié)議，偽裝自己是mysql slave，向mysql master發(fā)送dump請(qǐng)求。

2.mysql master收到dump請(qǐng)求后,開始推送 binary log給canal

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

mysql開啟binlog模式

?(1)查看當(dāng)前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的服務(wù)。

(3) 進(jìn)入mysql

mysql -h localhost -u root -p

（4）創(chuàng)建賬號(hào) 用于測(cè)試使用

使用root賬號(hào)創(chuàng)建用戶并授予權(quán)限

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

canal服務(wù)端安裝配置

（1）下載地址canal

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

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

解壓縮之后的目錄結(jié)構(gòu)如下：

?

（3）修改 exmaple下的實(shí)例配置

vi conf/example/instance.properties

?

修改如圖所示的幾個(gè)參數(shù)。

一定要注釋掉下面這個(gè)參數(shù)，這樣就會(huì)掃描全庫

#canal.instance.defaultDatabaseName =

（3）啟動(dòng)服務(wù)：

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

（4）查看日志：

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

?

這樣就表示啟動(dòng)成功了。

?

SpringBoot集成Canal

我們這里使用的一個(gè)開源的項(xiàng)目，它實(shí)現(xiàn)了springboot與canal的集成。比原生的canal更加優(yōu)雅。

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

下載后，本地進(jìn)入

cmd進(jìn)入目錄，mvn? insrall，加載pom坐標(biāo)。

Springboot項(xiàng)目使用

監(jiān)聽器類實(shí)現(xiàn)

?

自定義監(jiān)聽

?

?

?

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。