mysql二进制binarylog监控服务

针对mysql的增删改操作,我们可以通过监控binlog实时的获取变化的数据,从而可以进行多项数据的后续处理,比如缓存更新,自定义索引服务更新等等;

该服务主要通过监控mysql的二进制数据变化,将变化消息转换为java的DTO从而可以通过实现本项目中的BasicDataExportProcessor类进行自定义处理,本项目借用了mysql-binlog-connector-java,由于该包没有提供变化数据对应的表列名功能,所以只能通过information_schema自行去获取。并映射到template.json文件中,实际项目研发中,需要定时定点获取该文件,而且改文件需要定时更新,以保证表的元数据准确性。

项目类图(由于使用了lombok,类图有lombok的接口实现可忽略):

项目位置:https://github.com/qq472708969/mysql-binary-monitorservice

原文地址:https://www.cnblogs.com/zzq-include/p/12747176.html