通过mysql自动同步redis

在服务端开发过程中，一般会使用MySQL等关系型数据库作为最终的存储引擎，Redis其实也可以作为一种键值对型的数据库，但在一些实际场景中，特别是关系型结构并不适合使用Redis直接作为数据库。这俩家伙简直可以用“男女搭配，干活不累”来形容，搭配起来使用才能事半功倍。本篇我们就这两者如何合理搭配以及他们之间数据如何进行同步展开。

一般地，Redis可以用来作为MySQL的缓存层。为什么MySQL最好有缓存层呢？想象一下这样的场景：在一个多人在线的游戏里，排行榜、好友关系、队列等直接关系数据的情景下，如果直接和MySQL正面交手，大量的数据请求可能会让MySQL疲惫不堪，甚至过量的请求将会击穿数据库，导致整个数据服务中断，数据库性能的瓶颈将掣肘业务的开发；那么如果通过Redis来做数据缓存，将大大减小查询数据的压力。在这种架子里，当我们在业务层有数据查询需求时，先到Redis缓存中查询，如果查不到，再到MySQL数据库中查询，同时将查到的数据更新到Redis里；当我们在业务层有修改插入数据需求时，直接向MySQL发起请求，同时更新Redis缓存。

在上面这种架子中，有一个关键点，就是MySQL的CRUD发生后自动地更新到Redis里，这需要通过MySQL UDF来实现。具体来说，我们把更新Redis的逻辑放到MySQL中去做，即定义一个触发器Trigger，监听CRUD这些操作，当操作发生后，调用对应的UDF函数，远程写回Redis，所以业务逻辑只需要负责更新MySQL就行了，剩下的交给MySQL UDF去完成。

一. 什么是UDF

UDF，是User Defined Function的缩写，用户定义函数。MySQL支持函数，也支持自定义的函数。UDF比存储方法有更高的执行效率，并且支持聚集函数。

UDF定义了5个API：xxx_init()、xxx_deinit()、xxx()、xxx_add()、xxx_clear()。给出了这些API的说明。相关的结构体定义在mysql_com.h里，它又被mysql.h包含，使用时只需#include即可。他们之间的关系和执行顺序可以以下图来表示：

1. xxx()

这是主函数，5个函数至少需要xxx()，对MySQL操作的结果在此返回。函数的声明如下：

SQL TypeC/C++ Type

[root@localhost zhxilin]#

我们定义一个最简单的UDF主函数：


args[args[

由于mysql提供的接口是C实现的，我们在C++中使用时需要添加：

接下来编译成动态库.so：

[zhxilin@localhost mysql-redis-test]$ g++ -shared -fPIC -I /usr/include/mysql -o simple_add.so simple.

-shared 表示编译和链接时使用的是全局共享的类库;

-fPIC编译器输出位置无关的目标代码，适用于动态库；

-I /usr/include/mysql 指明包含的头文件mysql.h所在的位置。

编译出simple_add.so后用root拷贝到/usr/lib64/mysql/plugin下：

[root@localhost mysql-redis-test]#

紧接着可以在MySQL中创建函数执行了。登录MySQL，创建关联函数：

mysql

测试UDF函数：

mysql

可以看到，UDF正确执行了加法。

创建UDF函数的语法是CREATE FUNCTION xxx RETURNS [INTEGER/STRING/REAL] SONAME '[so name]';

删除UDF函数的语法是 DROP FUNCTION simple_add;

mysql

三. 在UDF中访问Redis

跟上述做法一样，只需在UDF里调用Redis提供的接口函数。Redis官方给出了，封装了Redis的基本操作。

源码是依赖boost，需要先安装boost：

[root@localhost dev]#

然后下载redis cpp client源码：

[root@localhost dev]# git clone https:

使用时需要把redisclient.h、anet.h、fmacros.h、anet.c 这4个文件考到目录下，开始编写关于Redis的UDF。我们定义了redis_hset作为主函数，连接Redis并调用hset插入哈希表，redis_hset_init作为初始化，检查参数个数和类型。



args && args->args[args[args[hset(args->args[args[args[arg_type[arg_type[arg_type[arg_type[arg_type[arg_type[ptr =

编译链接：

[zhxilin@localhost mysql-redis-test]$ g++ -shared -fPIC -I /usr/include/mysql -lboost_serialization -lboost_system -lboost_thread -o libmyredis.so anet.c test.cpp

编译时需要加上-lboost_serialization -lboost_system -lboost_thread，表示需要链接三个动态库：libboost_serialization.so、libboost_system.so、libboost_thread.so，否则在运行时会报缺少函数定义的错误。

编译出libmyredis.so之后，将其拷贝到mysql的插件目录下并提权：

[root@localhost mysql-redis-test]#

完成之后登录MySQL，创建关联函数测试一下：

mysql mysql> CREATE FUNCTION redis_hset RETURNS STRING SONAME 'libmyredis.so';
Query OK,0 rows affected (0.02 sec)

先删除老的UDF，注意函数名加反引号（``）。调用UDF测试，返回0，执行成功：