实现监听Mysql-binlog

共 837字,需浏览 2分钟

 ·

2021-07-31 01:25


引入依赖:


<dependency>
<groupId>com.github.shyiko</groupId>
<artifactId>mysql-binlog-connector-java</artifactId>
<version>0.21.0</version>
</dependency>


配置连接:


BinaryLogClient logClient = new BinaryLogClient( "127.0.0.1", 3306, "root", "123456" );


注册监听:


logClient.registerEventListener(event -> {
EventData data = event.getData();
//如果日志是更新记录
if(data instanceof UpdateRowsEventData){
System.out.println("update");
}else if(data instanceof WriteRowsEventData){
//写操作
System.out.println("write");
}else if(data instanceof DeleteRowsEventData){
//删除操作
System.out.println("delete");

}
});


开始监听:


logClient.connect();




浏览 35
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

分享
举报