Java binLog日志监听方式

和依珊

目录

• Java binLog日志监听
• 一、Windows下开启MySQL binLog日志
• 二、Java代码示例演示
• 总结

Java binLog日志监听

监听指定的表去做一些处理逻辑，首先是要开启M有SQL的配置，然后再撸代码。

一、Windows下开启MySQL binLog日志

首先要开启MySQL的BinLog 管理

1. show variables like '%log_bin%';

复制代码

如果发现是OFF，打开mysql文件夹下面的my.ini，修改一下

如果不知道my.ini 在哪里，打开【服务】-> 右击属性

拉到最后就可以看见my.ini，然后找到文件后

在 [mysqld] 下面加

1. # 开启bin-log
2. log-bin=mysql-bin # 开启binlog功能
3. binlog-format=ROW # 设置binlog格式
4. server_id=1 # 设置服务ID号

复制代码

然后 重启服务，就会发现已经起好了

二、Java代码示例演示

首先引入Maven包

1. <dependency>
2. <groupId>com.github.shyiko</groupId>
3. <artifactId>mysql-binlog-connector-java</artifactId>
4. <version>0.21.0</version>
5. </dependency>

复制代码

上代码

1. import cn.hutool.core.collection.ListUtil;
2. import com.alibaba.fastjson2.JSON;
3. import com.github.shyiko.mysql.binlog.BinaryLogClient;
4. import com.github.shyiko.mysql.binlog.event.*;
5. import com.ruoyi.common.utils.StringUtils;
6. import com.ruoyi.web.controller.websocket.AlarmWebSocket;
7. import com.ruoyi.web.service.IWidfireDataService;
8. import lombok.extern.slf4j.Slf4j;
9. import org.springframework.beans.factory.annotation.Autowired;
10. import org.springframework.stereotype.Component;
12. import java.io.IOException;
13. import java.util.List;
14. import java.util.Map;
17. /**
18. * mysql bin log 日志监听
19. */
20. @Component
21. @Slf4j
22. public class MySQLBinaryLogConfig {
25. public static IWidfireDataService widfireDataService;
27. @Autowired
28. public void setSenderService(IWidfireDataService widfireDataService){
29. MySQLBinaryLogConfig.widfireDataService= widfireDataService;
30. }
33. private static final List<String> TABLE_NAME = ListUtil.of("alart_ai"); //数据库表，需要监听的表
36. {
37. System.out.println("启动监听：启动中");
38. getThread().start();
39. System.out.println("启动监听：成功");
40. }
42. public Thread getThread() {
43. BinaryLogClient client = new BinaryLogClient("127.0.0.1", 3306, "root", "123456");
44. client.setServerId(1);
45. return new Thread(() -> {
46. client.registerEventListener(event -> {
47. String table =null;
48. final EventData data = event.getData();
49. if (data instanceof TableMapEventData) {
50. TableMapEventData tableMapEventData = (TableMapEventData) data;
51. String database = tableMapEventData.getDatabase();
52. table = tableMapEventData.getTable();
54. log.info("数据表:{},data:{},database:{}",table,data.toString(),database);
55. }else if (data instanceof UpdateRowsEventData) {
56. UpdateRowsEventData tableMapEventData = (UpdateRowsEventData) data;
58. System.out.println("更新:");
59. } else if (data instanceof WriteRowsEventData) {
60. System.out.println("添加:");
61. } else if (data instanceof DeleteRowsEventData) {
62. System.out.println("删除:");
63. }
65. if(StringUtils.isNotEmpty(table) && TABLE_NAME.contains(table)){
66. log.info("<<<<<< 收到MySQL binLog 日志推送 >>>>>>>");
67. //开始编写具体的逻辑
69. }
71. });
72. try {
73. client.connect();
74. } catch (IOException e) {
75. e.printStackTrace();
76. }
77. });
79. }
80. }

复制代码

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持晓枫资讯。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！

123464315

感谢楼主分享。

楮新美

顶顶更健康！！！

123464635

路过，支持一下