SpringBoot系列之集成阿⾥canal监听MySQLBinlog
1、什么是阿⾥canal？
canal是阿⾥开源的，对数据库增量⽇志解析，提供增量数据订阅和消费的组件。引⽤官⽹的图⽚，canal的⼯作原理主要是模拟 MySQL slave 的交互协议，伪装⾃⼰为 MySQL
slave，向master发送dump 协议，获取到数据后，解析 binary log 对象数据。
2、canal环境搭建
本⽂基于Window系统。
使⽤canal需要确保数据库开启了binlog：
show variables like'log_%';
如果没开启，在mysql my.ini配置⽂件添加配置，注意⽂件内存为的时候，注意编码格式必须为ANSI，不然会编译报错
[mysqld]
# 开启 binlog
log-bin=mysql-bin
# 选择 ROW 模式
binlog-format=ROW
# 配置 MySQL replaction 需要定义，不要和 canal 的 slaveId 重复
server_id=1
配置⽂件修改是否正确，使⽤命令，查看⽇志
mysqld --console
重启MySQL实例
net stop mysql
net start mysql
binlog开启后，创建⼀个canal⽤户并授权，官⽹配置是@%，表⽰所有服务器，因为本地测试的，所以改为localhost就可以
CREATE USER canal IDENTIFIED BY'canal';
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT ON*.*TO'canal'@'localhost' identified by'canal';
FLUSH PRIVILEGES;
下载canal服务端，到下载对应资料，canal.deployer-1.1.是服务端，解压后在conf⽂件夹⾥到\example\instance.properties，修改数据库配置信
息，dbUsername，dbPassword数据库账号密码
# position info(master数据库配置)
canal.instance.master.address=tcdb:59039
canal.instance.master.journal.name=
canal.instance.master.position=
canal.instance.master.timestamp=
canal.id=
# rds oss binlog
canal.instance.rds.accesskey=
canal.instance.rds.secretkey=
canal.instance.rds.instanceId=
# table meta tsdb info
canal.able=true
#canal.instance.tsdb.url=jdbc:mysql://127.0.0.1:3306/canal_tsdb
#canal.instance.tsdb.dbUsername=canal
#canal.instance.tsdb.dbPassword=canal
#canal.instance.standby.address =
#canal.instance.standby.journal.name =
#canal.instance.standby.position =
#canal.instance.standby.timestamp=
#canal.id=
# username/password(⽤户名密码)
canal.instance.dbUsername=canal
canal.instance.dbPassword=canal1uo#A#9R
# 加上默认数据库
canal.instance.defaultDatabaseName=tajiax_canal
tionCharset = UTF-8
# enable druid Decrypt database password
ableDruid=false
#canal.instance.pwdPublicKey=MFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBALK4BUxdDltRRE5/zXpVEVPUgunvscYFtEip3pmLlhrWpacX7y7GCMo2/JM6LeHmiiNdH1FWgGCpUfircSwlWKUCAw
查看canal实例名称，⽂件在D:\dev\canal.deployer-1.1.5\conf\canal.properties：
canal.destination=example
到canal服务器安装⽬录D:\dev\canal.deployer-1.1.5\bin，到startup.bat执⾏。
在码云有⽰例->\ly\canal-application
3、Canal客户端测试
spring frameworkJDK 1.8
SpringBoot2.2.1
Maven 3.2+
开发⼯具
IntelliJ IDEA
smartGit
3.1、引⼊依赖
<dependency>
<groupId>top.javatool</groupId>
<artifactId>canal-spring-boot-starter</artifactId>
<version>1.2.1-RELEASE</version>
</dependency>
3.2、配置canal
# canal实例名称，要跟canal-server运⾏时设置的destination⼀致
# D:\dev\canal.deployer-1.1.5\conf\canal.properties
canal.destination=example
# canal默认监听端⼝
canal.server=127.0.0.1:11111
p.javatool.canal.client=warn
3.3、编写，监听Canal消息
package ity;
import org.springframework.stereotype.Component;
import top.javatool.canal.client.annotation.CanalTable;
import top.javatool.canal.client.handler.EntryHandler;
@CanalTable("tb_user")
@Component
public class UserHandler implements EntryHandler<UserEntity> {
//    @Autowired
//    private RedisHandler redisHandler;
//    @Autowired
//    private Cache<Long, Item> itemCache;
@Override
public void insert(UserEntity item) {
System.out.println("insert," + item);
// 写数据到JVM进程缓存
/
/itemCache.Id(), item);
// 写数据到redis
//redisHandler.saveItem(item);
}
@Override
public void update(UserEntity before, UserEntity after) {
System.out.println("update before," + before);
System.out.println("update after," + after);
// 写数据到JVM进程缓存
//itemCache.Id(), after);
// 写数据到redis
/
/redisHandler.saveItem(after);
}
@Override
public void delete(UserEntity item) {
System.out.println("delete," + item);
// 删除数据到JVM进程缓存
//itemCache.Id());
// 删除数据到redis
//redisHandler.Id());
}
}
当表tb_user进⾏insert、update、delete操作时，会发现监控已⽣效。
注意：更改canal实例名称为canaltest
1、在D:\dev\canal.deployer-1.1.5\conf⽬录下，把example⽂件夹改成canaltest
2、在D:\dev\canal.deployer-1.1.5\conf\canal.properties⽂件中，到canal.destination配置项改为canaltest
3、修改canal配置
canal.destination=canaltest

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。