浅谈MySQL与redis缓存的同步方案

本文介绍mysql与redis缓存的同步的两种方案

  • 方案1:通过mysql自动同步刷新redis,mysql触发器+udf函数实现
  • 方案2:解析mysql的binlog实现,将数据库中的数据同步到redis

一、方案1(udf)

场景分析:当我们对mysql数据库进行数据操作时,同时将相应的数据同步到redis中,同步到redis之后,查询的操作就从redis中查找

过程大致如下:

在mysql中对要操作的数据设置触发器trigger,监听操作

客户端(nodeserver)向mysql中写入数据时,触发器会被触发,触发之后调用mysql的udf函数

udf函数可以把数据写入到redis中,从而达到同步的效果

方案分析:

  • 这种方案适合于读多写少,并且不存并发写的场景
  • 因为mysql触发器本身就会造成效率的降低,如果一个表经常被操作,这种方案显示是不合适的

演示案例

下面是mysql的表

下面是udf的解析代码

定义对应的触发器

二、方案2(解析binlog)

在介绍方案2之前我们先来介绍一下mysql复制的原理,如下图所示:

  • 主服务器操作数据,并将数据写入bin log
  • 从服务器调用i/o线程读取主服务器的bin log,并且写入到自己的relay log中,再调用sql线程从relay log中解析数据,从而同步到自己的数据库中

方案2就是:

  • 上面mysql的整个复制流程可以总结为一句话,那就是:从服务器读取主服务器bin log中的数据,从而同步到自己的数据库中
  • 我们方案2也是如此,就是在概念上把主服务器改为mysql,把从服务器改为redis而已(如下图所示),当mysql中有数据写入时,我们就解析mysql的bin log,然后将解析出来的数据写入到redis中,从而达到同步的效果

例如下面是一个云数据库实例分析:

云数据库与本地数据库是主从关系。云数据库作为主数据库主要提供写,本地数据库作为从数据库从主数据库中读取数据

本地数据库读取到数据之后,解析bin log,然后将数据写入写入同步到redis中,然后客户端从redis读数据

这个技术方案的难点就在于:如何解析mysql的bin log。但是这需要对binlog文件以及mysql有非常深入的理解,同时由于binlog存在statement/row/mixedlevel多种形式,分析binlog实现同步的工作量是非常大的

canal开源技术

canal是阿里巴巴旗下的一款开源项目,纯java开发。基于数据库增量日志解析,提供增量数据订阅&消费,目前主要支持了mysql(也支持mariadb)

开源参考地址有:

工作原理(模仿mysql复制):

  •  canal模拟mysql slave的交互协议,伪装自己为mysql slave,向mysql master发送dump协议
  • mysql master收到dump请求,开始推送binary log给slave(也就是canal)
  • canal解析binary log对象(原始为byte流)

架构:

server代表一个canal运行实例,对应于一个jvm

instance对应于一个数据队列 (1个server对应1..n个instance)

instance模块:

  •  eventparser (数据源接入,模拟slave协议和master进行交互,协议解析)
  • eventsink (parser和store链接器,进行数据过滤,加工,分发的工作)
  • eventstore (数据存储)
  • metamanager (增量订阅&消费信息管理器)

大致的解析过程如下:

  • parse解析mysql的bin log,然后将数据放入到sink中
  • sink对数据进行过滤,加工,分发
  • store从sink中读取解析好的数据存储起来
  • 然后自己用设计代码将store中的数据同步写入redis中就可以了
  • 其中parse/sink是框架封装好的,我们做的是store的数据读取那一步

更多关于cancl可以百度搜索

下面是运行拓扑图

mysql表的同步,采用责任链模式,每张表对应一个filter。例如zvsync中要用到的类设计如下:

下面是具体化的zvsync中要用到的类,每当新增或者删除表时,直接进行增删就可以了

三、附加

本文上面所介绍的都是从mysql中同步到缓存中。但是在实际开发中可能有人会用下面的方案:

  • 客户端有数据来了之后,先将其保存到redis中,然后再同步到mysql中
  • 这种方案本身也是不安全/不可靠的,因此如果redis存在短暂的宕机或失效,那么会丢失数据

到此这篇关于浅谈mysql与redis缓存的同步方案的文章就介绍到这了,更多相关mysql与redis缓存同步内容请搜索www.887551.com以前的文章或继续浏览下面的相关文章希望大家以后多多支持www.887551.com!

(0)
上一篇 2022年3月21日
下一篇 2022年3月21日

相关推荐