↓推荐关注↓
转自:dongshaodongshao.blog.csdn.net/article/details/107190925
转自:dongshao
dongshao.blog.csdn.net/article/details/107190925
一、方案1(UDF)
演示案例下面是MySQL的表下面是UDF的解析代码定义对应的触发器
二、方案2(解析binlog)
Canal开源技术canal是阿里巴巴旗下的一款开源项目,纯Java开发。基于数据库增量日志解析,提供增量数据订阅&消费,目前主要支持了MySQL(也支持mariaDB)开源参考地址有:https://github.com/liukelin/canal_mysql_nosql_sync工作原理(模仿MySQL复制):canal模拟mysql slave的交互协议,伪装自己为mysql slave,向mysql master发送dump协议mysql master收到dump请求,开始推送binary log给slave(也就是canal)canal解析binary log对象(原始为byte流)架构:eventParser (数据源接入,模拟slave协议和master进行交互,协议解析)eventSink (Parser和Store链接器,进行数据过滤,加工,分发的工作)eventStore (数据存储)metaManager (增量订阅&消费信息管理器)server代表一个canal运行实例,对应于一个jvm instance对应于一个数据队列 (1个server对应1..n个instance)instance模块:大致的解析过程如下:parse解析MySQL的Bin log,然后将数据放入到sink中sink对数据进行过滤,加工,分发store从sink中读取解析好的数据存储起来然后自己用设计代码将store中的数据同步写入Redis中就可以了其中parse/sink是框架封装好的,我们做的是store的数据读取那一步更多关于Cancl可以百度搜索下面是运行拓扑图MySQL表的同步,采用责任链模式,每张表对应一个Filter 。例如zvsync中要用到的类设计如下:下面是具体化的zvsync中要用到的类 ,每当新增或者删除表时,直接进行增删就可以了
三、附加
但是在实际开发中可能有人会用下面的方案:
- EOF -
0、极客专属:几十款程序员秒懂的卫衣
1、往代码里掺东西,你还敢用?再见,Notepad++
2、世界上最伟大最邪恶的软件发明
3、ChatGPT 连夜迭代:你老婆不好使了
关注「程序员的那些事」加星标,不错过圈内事
点赞和在看就是最大的支持❤️