duckula3/checkpoint

发布 : 2020-12-21 浏览 :

springboot项目监听binlog

  duckula3可以与springboot完成结合,见示例:https://gitee.com/rjzjh/duckula3-dev-demoduckula3-dev-demo-springboot子项目,引入两个包,

1
2
3
4
5
6
7
8
9
10
     <dependency>
<groupId>net.wicp.tams</groupId>
<artifactId>common-spring-autoconfig</artifactId>
<version>最大版本</version>
</dependency>
<dependency>
<groupId>net.wicp.tams</groupId>
<artifactId>common-binlog-alone</artifactId>
<version>最大版本</version>
</dependency>

common-spring-autoconfig会有注解支持,common-binlog-alone是duckula3的监听框架。

在spring的启动主类上加上EnableTams注解,如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
@SpringBootApplication
@ImportResource("classpath:beanRefContext.xml")
@Configuration
@MapperScan("net.wicp.tams.app.duckula.controller.dao")
@EnableTams(packages = "net.wicp.tams.app.demo.tams.outer", springconfpres = "spring.datasource.dynamic.datasource.master")
public class DuckulaSpringbootApplication {

public static void main(String[] args) {
System.setProperty("DEPLOY_ENV", "dev");// TODO 上线前请去掉此句,在本机设置好环境变量也可去掉此句
SpringApplication.run(DuckulaSpringbootApplication.class, args);
}

}
  • packages:用于把包加入springboot的管理,多个包用逗号隔开
  • springconfpres:用于把spring管理的配置项(指定前缀的)加到内存配置中心,因为duckula3为采用的是非spring框架的java来开发的,所以它使用的是内存配置中心的配置项。有了此配置项,那么后面的监听任务就不需要再配置数据库相关的配置信息了。

创建一个监听器:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
package net.wicp.tams.app.demo.tams.outer.listener;

import net.wicp.tams.common.Result;
import net.wicp.tams.common.binlog.alone.DuckulaAssit;
import net.wicp.tams.common.binlog.alone.ListenerConf.ColHis;
import net.wicp.tams.common.binlog.alone.ListenerConf.DuckulaEvent;
import net.wicp.tams.common.binlog.alone.annotation.BinlogListener;
import net.wicp.tams.common.binlog.alone.binlog.bean.Rule;
import net.wicp.tams.common.binlog.alone.binlog.listener.AbsBinlogListener;

//@BinlogListener(ip = "192.168.104.107", conf = "abc", port = 3308, user = "pvuser", password = "pvuser@TM", chk = "net.wicp.tams.common.binlog.alone.checkpoint.CheckPointMysql", rule = "chps`t_sample`{}")
//chk默认为CheckPointH2db,如果不变无需配置。conf:随意,不能重复 rule:监听配置,监听duckula库sys_user表
@BinlogListener(conf = "abc", chk = "net.wicp.tams.common.binlog.alone.checkpoint.CheckPointMemory", rule = "duckula`sys_user`{}")
public class TestListener extends AbsBinlogListener {
@Override
public void doBusiTrue(Rule rule, DuckulaEvent duckulaEvent, boolean isSplit) {
String username = DuckulaAssit.getValue(duckulaEvent, "username", 0);
System.out.println("username=" + username);
}

// 当修改表时触发,如加字段
@Override
public Result doAlterTableCallBack(Rule rule, ColHis colHis, String sql) {
return Result.getSuc();
}

@Override
public void doInit(Rule rule, int index) {

}
}

这个监听器需要继承AbsBinlogListener虚类,需要实现3个方法:

  • doBusiTrue:用于实现binlog的处理器其中有3个参数。

    rule:指命中的规则,具体看 规则配置一节。

    duckulaEvent:这是一个probuff3的对象,它会放置binlog监听的数据。DuckulaAssit是一个帮助类,帮助你使用这个对象

    isSplit:是否分隔,为了保证条件有序(同一条记录增删改顺序播放)需要把binlog事件包的数据分隔为一条条的事件,默认为false

  • doAlterTableCallBack:当数据库有修改时会触发它,有了它就可以做到修改监听的表时不用停止监听,它也有3个参数

    rule:指命中的规则,具体看 规则配置一节。

    colHis:修改后的数据库字段集。

    sql:执行数据库表字段修改的update原始语句

  • doInit:初始化动作,如果你的监听器需要初始化一些资源(如:连接kafka等),可以在这个方法中执行,它有2个参数

    rule:指命中的规则,具体看 规则配置一节。

    index:第几个规则

本文作者 : andy.zhou
原文链接 : https://rjzjh.gitee.io/2020/12/21/duckula3/demo-enableTams/
版权声明 : 本博客所有文章除特别声明外,均采用 CC BY-NC-SA 4.0 许可协议。转载请注明出处!

知识 & 情怀 | 二者兼得

微信扫一扫, 向我投食

微信扫一扫, 向我投食

支付宝扫一扫, 向我投食

支付宝扫一扫, 向我投食

留下足迹