本文共 392 字,大约阅读时间需要 1 分钟。
适用于PostgreSQL数据库之间的逻辑增量同步。
对PostgreSQL的版本要求,8.3以上即可。 最小的同步单位为行,用户可以选择表为同步对象,并且可以对表进行分组(有事务关联的表作为一个分组)。 不同的分组,可以并行订阅,消费消息。 如图: A,B,C三个表有事务关联,放到一个消息队列。 D,E,F三个表有事务关联,放到另一个消息队列。 在数据库中跟踪表的变更,记录到数据库的MQ中。 订阅者将MQ翻译成SQL,按照事务的提交顺序,在目标端回放这些SQL。从而达到逻辑复制的目的。 与MySQL的binlog 复制原理一致。 应用场景举例:实测性能:
单个分组支持大于8000条SQL每秒的同步速度。 并行执行的情况,支持大于2万条SQL每秒的同步速度。转载地址:http://gvmwo.baihongyu.com/