数据同步的解决方案Canal
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)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: python提交事务_事务提交和回滚
- 下一篇: 云财经服务器维护,云财经服务器维护