我要评论java binlog日志监听
监听指定的表去做一些处理逻辑，首先是要开启m有sql的配置，然后再撸代码。
一、windows下开启mysql binlog日志
首先要开启mysql的binlog 管理
show variables like '%log_bin%';
如果发现是off，打开mysql文件夹下面的my.ini，修改一下
如果不知道my.ini 在哪里，打开【服务】-> 右击属性
拉到最后就可以看见my.ini，然后找到文件后
在 [mysqld] 下面加
# 开启bin-log log-bin=mysql-bin # 开启binlog功能 binlog-format=row # 设置binlog格式 server_id=1 # 设置服务id号
然后 重启服务，就会发现已经起好了
二、java代码示例演示
首先引入maven包
<dependency>
<groupid>com.github.shyiko</groupid>
<artifactid>mysql-binlog-connector-java</artifactid>
<version>0.21.0</version>
</dependency>上代码
import cn.hutool.core.collection.listutil;
import com.alibaba.fastjson2.json;
import com.github.shyiko.mysql.binlog.binarylogclient;
import com.github.shyiko.mysql.binlog.event.*;
import com.ruoyi.common.utils.stringutils;
import com.ruoyi.web.controller.websocket.alarmwebsocket;
import com.ruoyi.web.service.iwidfiredataservice;
import lombok.extern.slf4j.slf4j;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.stereotype.component;
import java.io.ioexception;
import java.util.list;
import java.util.map;
/**
* mysql bin log 日志监听
*/
@component
@slf4j
public class mysqlbinarylogconfig {
public static iwidfiredataservice widfiredataservice;
@autowired
public void setsenderservice(iwidfiredataservice widfiredataservice){
mysqlbinarylogconfig.widfiredataservice= widfiredataservice;
}
private static final list<string> table_name = listutil.of("alart_ai"); //数据库表，需要监听的表
{
system.out.println("启动监听：启动中");
getthread().start();
system.out.println("启动监听：成功");
}
public thread getthread() {
binarylogclient client = new binarylogclient("127.0.0.1", 3306, "root", "123456");
client.setserverid(1);
return new thread(() -> {
client.registereventlistener(event -> {
string table =null;
final eventdata data = event.getdata();
if (data instanceof tablemapeventdata) {
tablemapeventdata tablemapeventdata = (tablemapeventdata) data;
string database = tablemapeventdata.getdatabase();
table = tablemapeventdata.gettable();
log.info("数据表:{},data:{},database:{}",table,data.tostring(),database);
}else if (data instanceof updaterowseventdata) {
updaterowseventdata tablemapeventdata = (updaterowseventdata) data;
system.out.println("更新:");
} else if (data instanceof writerowseventdata) {
system.out.println("添加:");
} else if (data instanceof deleterowseventdata) {
system.out.println("删除:");
}
if(stringutils.isnotempty(table) && table_name.contains(table)){
log.info("<<<<<< 收到mysql binlog 日志推送 >>>>>>>");
//开始编写具体的逻辑
}
});
try {
client.connect();
} catch (ioexception e) {
e.printstacktrace();
}
});
}
}总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持代码网。
发表评论