binlog 采集驱动流程
2022-08-02 17:07:59 8 举报binlog 采集驱动流程
作者其他创作
大纲/内容
是
校验连接池是否连接
校验是否开启binlog
否/继续执行
1.获取日志基础数据，第一个日志文件信息，最后一个日志文件信息，接入的表信息，将信息放入runningStorage缓存中
每分钟校验是否阻塞
关闭监听器
启动文件状态监听
否
第一次
监听获取数据
创建每三分钟执行校验线程
本次调用结束
继续监听
判断是否读取行阻塞
启动事件进行解析binlog
是/创建新线程
开始
判断是否采集文件已过期
成功
返回采集结果
driver
采集到大于4000条/或者采集到数据并且当前文件已采集结束
2.调用采集功能
关闭监听
关闭成功递归调用启动监听
获取binlog日志是否开启标记并记录到runningStorage
获取mysql全量数据
当前采集到最后一个文件
采集功能
组装连接信息
再次执行
创建单线程并启动连接与监听
判断是否采集到最后的文件
是否有数据
返回
driver调用采集
结束
收藏
0 条评论
下一页
