Hiriver：MySQL 数据变化的监控与分发框架 | 软件推介

授权协议：Apache

开发语言：Java

操作系统：跨平台

软件作者：xuc

github 地址： https://github.com/rolandhe/hiriver

• 强烈推荐 使用5.6.9+版本，并使用binlog file name + position的方式处理同步点。

• 虽然5.6.9+版本提供 gtid 功能，它是用于表示事务的唯一的id，理论上，基于它可以实现HA功能，当mysql出现故障时可以自动从一台mysql从库切换到另一台，并且不会丢失或者重复数据，但是 在实际的使用过程中gtid依然存在bug，并不稳定，而且存在多个gtid时很难找到mysql认识的初始同步点。

• mysql5.6.9之前的版本，必须binlog file name和在该文件中的偏移位置作为同步点。

• 创建自己的mysql 5.6.28

• 开启row base和gtid 模式（如果使用gtid作为同步点，必须开启）

• 创建自己的复制账号，创建repl database和一张表，并在表示写入数据

• 下载代码，找到hiriver-sample模块，它是一个基于spring的web应用,有3 spring xml配置文件，分别是：

• 修改示例中 hiriver-sample.properties 的参数,修改数据库相关属性、初始同步点、同步点存储路径和表名过滤黑、白名单配置

• 初始化同步点使用channel.0000.binlog和channel.0000.binlog.pos属性，可以通过执行

命令获取对应信息

修改后如图：

• 修改spring-boot.xml中的最后一行为:

• 使用tomcat/jetty或maven jetty插件运行示例即可

• 下载代码，找到hiriver-sample模块，它是一个基于spring的web应用,有3 spring xml配置文件，分别是：

• 修改示例中hiriver-sample.properties的参数,修改数据库相关属性、初始同步点、同步点存储路径和表名过滤黑、白名单配置，其中channel_0000.gtid参数的配置需要从mysql中查询数获取，执行

命令，得到如下结果：

这是一个范围，你只需要使用

即可.修改后如图：

• 修改spring-boot.xml中的最后一行为:

• 使用tomcat/jetty或maven jetty插件运行示例即可

实现mysql binlog dump协议，负责与mysql建立socket连接，完成用户名密码验证后，执行数据dump命令，并持续的读取、解析mysql binlog event数据。

mysql文本协议的实现，mysql文本协议即jdbc背后的协议，主要用于执行sql读取数据，也可以执行一些其他的命令，比如读取表定义的元数据等，之所以不使用mysql jdbc是由于两个原因：一是不想引入一个第三方包，降低依赖性；二是mysql的文本协议支持更多指令，比如COM_FIELD_LIST指令方便的获取到表字段是否为空、是否是索引字段等信息，而jdbc是个通用的api，并没有暴露这些指令实现。

• channelId

• sourceHostUrl,该数据来自哪个数据库

• gtId， 该数据所在的事务的gtid，在不支持gtid模式下，为null

• binlogPos, 当前数据所在事务的binlogfile + pos,无论哪种模式，一定补位null

• isStartTransEvent， 当前是否一个事务的开启

isPositionStoreTrigger,当前是否一个事务的结束，当时true时需要记录同步点。

• rowDataMap, 行数据,每一行使用• BinlogResultRow描述

• columnDefMap, 类定义描述