View Code? Open in Web Editor
NEW
This project forked from sunzsh/canaldemo
canaldemo's Introduction
- 复制
canal
config
两个包完整内容到自己的项目(基础类相关)
- 在自己项目新建一个
dbchange
及 dbchange/listener
包,留作 监听业务逻辑相关代码 存放使用
- 如果项目没有引入kafka,需要自行导入相关依赖,SpringBoot项目可以参考本demo的
pom.xml
文件
- 复制
application.properties
中 kafka相关配置到自己的项目
- 如果自己项目已经在使用 kafka 请注意配置项
spring.kafka.consumer.enable-auto-commit:false
- 若自己的项目中该配置是true,可自行修改
CanalRoot
中的监听代码(去掉ack相关代码)
- 修改
CanalRoot.PACKAGE_OF_DBCHANGE
变量,指定自己项目的 dbchange
完整包名
- 开始使用
dbchange
中存放与数据库表相对应的spring事件,命名规则:表名转驼峰+Event
dbchange/listener
中存放监听各个表事件的方法,推荐命名规则(非强制):表名转驼峰+业务描述
- 监听基类分两种
- 异步消费:
DBChangeBaseListenerAsync
java获取到的数据库变动顺序可能是乱的
- 同步消费:
DBChangeBaseListenerSync
java获取到的数据库变动是有序的
- 严谨情况下,不知道该用哪种基类,就用"同步版"
DBChangeBaseListenerSync
canaldemo's People
Contributors
Watchers