在服务端开采进度中,一般会选拔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()。合法文书档案(http://dev.mysql.com/doc/refman/5.7/en/adding-udf.html)交给了这几个API的证实。相关的构造体定义在mysql_com.h里,它又被mysql.h包罗,使用时只需#include<mysql.h>就可以。他们中间的涉及和举办种种能够以下图来代表:

图片 1

1. xxx()

那是主函数,5个函数至少要求xxx(),对MySQL操作的结果在此再次回到。函数的扬言如下:

char *xxx(UDF_INIT *initid, UDF_ARGS *args, char *result, unsigned
long *length, char *is_null, char *error);

long long xxx(UDF_INIT *initid, UDF_ARGS *args, char *is_null,
char *error);

double xxx(UDF_INIT *initid, UDF_ARGS *args, char *is_null, char
*error);

SQL的花色和C/C++类型的投射:

SQL Type C/C++ Type
STRING char *
INTEGER long long
REAL double

2. xxx_init()

xxx()主函数的起先化,假设定义了,则用来检查传入xxx()的参数数量、类型、分配内部存款和储蓄器空间等开头化操作。函数的宣示如下:

my_bool xxx_init(UDF_INIT *initid, UDF_ARGS *args, char
*message);

3. xxx_deinit()

xxx()主函数的反初阶化,假诺定义了,则用来刑满释放解除劳教起头化时分配的内部存款和储蓄器空间。函数的注脚如下:

Redis能够用来作为MySQL的缓存层。void xxx_deinit(UDF_INIT *initid);

4. xxx_add()

在聚合UDF中一再调用,将参数加入聚合参数中。函数的宣示如下:

void xxx_add(UDF_INIT *initid, UDF_ARGS *Redis能够用来作为MySQL的缓存层。args, char *is_null,char
*error);

5. xxx_clear()

在聚合UDF中多次调用,复位聚合参数,为下一行数据的操作做筹算。函数的注解如下:

void xxx_clear(UDF_INIT *initid, char *is_null, char *error);

二. UDF函数的主干选拔

以前,须求先安装mysql的开荒包:

[root@localhost zhxilin]# yum install mysql-devel -y

咱俩定义三个最轻易易行的UDF主函数:

图片 2

 1 /*simple.cpp*/
 2 #include <mysql.h>
 3 
 4 extern "C" long long simple_add(UDF_INIT *initid, UDF_ARGS *args, char *is_null, char *error)
 5 {
 6     int a = *((long long *)args->args[0]);
 7     int b = *((long long *)args->args[1]);
 8     return a + b;
 9 }
10 
11 extern "C" my_bool simple_add_init(UDF_INIT *initid, UDF_ARGS *args, char *message)
12 {
13     return 0;
14 }

图片 3

出于mysql提供的接口是C实现的,我们在C++中接纳时索要加上:

extern "C" { ... }

Redis能够用来作为MySQL的缓存层。接下去编写翻译成动态库.so:

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

-shared 表示编写翻译和链接时选用的是大局分享的类库;

-fPIC编写翻译器输出地点非亲非故的对象代码,适用于动态库;

-I /usr/include/mysql 指明包罗的头文件mysql.h所在的职责。

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

[root@localhost mysql-redis-test]# cp simple_add.so /usr/lib64/mysql/plugin/

随后能够在MySQL中创制函数推行了。登入MySQL,成立关联函数:

mysql> CREATE FUNCTION simple_add RETURNS INTEGER SONAME 'simple_add.so';
Query OK, 0 rows affected (0.04 sec)

测试UDF函数:

图片 4

mysql> select simple_add(10, 5);
+-------------------+
| simple_add(10, 5) |
+-------------------+
|                15 |
+-------------------+
1 row in set (0.00 sec)

图片 5

能够看看,UDF准确试行了加法。

创造UDF函数的语法是 CREATE FUNCTION xxx RETU奇骏NS [Redis能够用来作为MySQL的缓存层。INTEGER/STRING/REAL]
SONAME ‘[so name]’;

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

mysql> DROP FUNCTION simple_add;
Query OK, 0 rows affected (0.03 sec)

三. 在UDF中访问Redis

跟上述做法同样,只需在UDF里调用Redis提供的接口函数。Redis官方给出了Redis
C++ Client
(https://github.com/mrpi/redis-cplusplus-client),封装了Redis的基本操作。

源码是重视boost,须求先安装boost:

[root@localhost dev]# yum install boost boost-devel

下一场下载redis cpp client源码:

[root@localhost dev]# git clone https://github.com/mrpi/redis-cplusplus-client

利用时需求把redisclient.h、anet.h、fmacros.h、anet.c
那4个文本考到目录下,起初编写制定关于Redis的UDF。大家定义了redis_hset作为主函数,连接Redis并调用hset插入哈希表,redis_hset_init作为起始化,检查参数个数和类型。

图片 6

 1 /* test.cpp */
 2 #include <stdio.h>
 3 #include <mysql.h>
 4 #include "redisclient.h"
 5 using namespace boost;
 6 using namespace std;
 7 
 8 static redis::client *m_client = NULL;
 9 
10 extern "C" char *redis_hset(UDF_INIT *initid, UDF_ARGS *args, char *result, unsigned long *length, char *is_null, char *error) {
11     try {
12         // 连接Redis
13         if(NULL == m_client) {
14             const char* c_host = getenv("REDIS_HOST");
15             string host = "127.0.0.1";
16             if(c_host) {
17                 host = c_host;
18             }
19             m_client = new redis::client(host);
20         }        
21 
22         if(!(args->args && args->args[0] && args->args[1] && args->args[2])) {
23             *is_null = 1;
24             return result;
25         }
26 
27         // 调用hset插入一个哈希表
28         if(m_client->hset(args->args[0], args->args[1], args->args[2])) {
29             return result;
30         } else {
31             *error = 1;
32             return result;
33         }
34     } catch (const redis::redis_error& e) {
35         return result;
36     }
37 }
38 
39 extern "C" my_bool redis_hset_init(UDF_INIT *initid, UDF_ARGS *args, char *message) {
40     if (3 != args->arg_count) {
41         // hset(key, field, value) 需要三个参数
42         strncpy(message, "Please input 3 args for: hset('key', 'field', 'value');", MYSQL_ERRMSG_SIZE);
43         return -1;
44     }
45     if (args->arg_type[0] != STRING_RESULT  || 
46         args->arg_type[1] != STRING_RESULT  || 
47         args->arg_type[2] != STRING_RESULT) { 
48         // 检查参数类型
49         strncpy(message, "Args type error: hset('key', 'field', 'value');", MYSQL_ERRMSG_SIZE);
50         return -1;
51     }
52 
53     args->arg_type[0] = STRING_RESULT;
54     args->arg_type[1] = STRING_RESULT;
55     args->arg_type[2] = STRING_RESULT;
56 
57     initid->ptr = NULL;
58     return 0;
59 }

图片 7

编译链接:

[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]# cp libmyredis.so /usr/lib64/mysql/plugin/ & chmod 777 /usr/lib64/mysql/plugin/libmyredis.so 

成功未来登入MySQL,创制关联函数测量检验一下:

mysql> DROP FUNCTION IF EXISTS `redis_hset`;
Query OK, 0 rows affected (0.16 sec)

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

先删除老的UDF,注意函数名加反引号(“)。调用UDF测量试验,再次来到0,实施成功:

图片 8

mysql> SELECT redis_hset('zhxilin', 'id', '09388334');
+-----------------------------------------+
| redis_hset('zhxilin', 'id', '09388334') |
+-----------------------------------------+
| 0                                                     |
+-----------------------------------------+
1 row in set (0.00 sec)

图片 9

开垦redis-cli,查看结果:

127.0.0.1:6379> HGETALL zhxilin
1) "id"
2) "09388334"

四. 通过MySQL触发器刷新Redis

 在上一节的根底上,我们想让MySQL在增删改查的时候自动调用UDF,还索要信赖MySQL触发器。触发器能够监听INSERT、UPDATE、DELETE等基本操作。在MySQL中,创设触发器的大旨语法如下:

CREATE TRIGGER trigger_name
trigger_time
trigger_event ON table_name
FOR EACH ROW
trigger_statement

trigger_time表示触发机缘,值为AFTERBEFORE

trigger_event表示触发的平地风波,值为INSERTUPDATEDELETE等;

trigger_statement代表触发器的程序体,能够是一句SQL语句恐怕调用UDF。

在trigger_statement中,假若有多条SQL语句,供给用BEGIN…END包罗起来:

BEGIN
[statement_list]
END

鉴于MySQL暗中认可的截至分隔符是分号(;),要是大家在BEGIN…END中冒出了分店,将被标志成终结,此时无法达成触发器的定义。有八个方式,能够调用DELIMITEEvoque命令来权且修改完成分隔符,用完再改会分号就能够。譬喻改成$:

mysql> DELIMITER $

笔者们早先定义三个触发器,监听对Student表的插入操作,Student表在上一篇文章中开创的,能够查阅上一篇文章。

图片 10

mysql > DELIMITER $
      > CREATE TRIGGER tg_student 
      > AFTER INSERT on Student 
      > FOR EACH ROW 
      > BEGIN
      > SET @id = (SELECT redis_hset(CONCAT('stu_', new.Sid), 'id', CAST(new.Sid AS CHAR(8))));
      > SET @name = (SELECT redis_hset(CONCAT('stu_', new.Sid), 'name', CAST(new.Sname AS CHAR(20))));
      > Set @age = (SELECT redis_hset(CONCAT('stu_', new.Sid), 'age', CAST(new.Sage AS CHAR))); 
      > Set @gender = (SELECT redis_hset(CONCAT('stu_', new.Sid), 'gender', CAST(new.Sgen AS CHAR))); 
      > Set @dept = (SELECT redis_hset(CONCAT('stu_', new.Sid), 'department', CAST(new.Sdept AS CHAR(10))));    
      > END $

图片 11

始建完触发器能够因此show查看,大概drop删除:

mysql> SHOW TRIGGERS;

mysql> DROP TRIGGER tg_student;

接下去我们调用一句插入语句,然后观望Redis和MySQL数据的退换:

mysql> INSERT INTO Student VALUES('09388165', 'Rose', 19, 'F', 'SS3-205');
Query OK, 1 row affected (0.27 sec)

MySQL的结果:

图片 12

mysql> SELECT * FROM Student;
+----------+---------+------+------+---------+
| Sid      | Sname   | Sage | Sgen | Sdept   |
+----------+---------+------+------+---------+
| 09388123 | Lucy    |   18 | F    | AS2-123 |
| 09388165 | Rose    |   19 | F    | SS3-205 |
| 09388308 | zhsuiy  |   19 | F    | MD8-208 |
| 09388318 | daemon  |   18 | M    | ZS4-630 |
| 09388321 | David   |   20 | M    | ZS4-731 |
| 09388334 | zhxilin |   20 | M    | ZS4-722 |
+----------+---------+------+------+---------+
6 rows in set (0.00 sec)

图片 13

Redis的结果:

图片 14

127.0.0.1:6379> HGETALL stu_09388165
 1) "id"
 2) "09388165"
 3) "name"
 4) "Rose"
 5) "age"
 6) "19"
 7) "gender"
 8) "F"
 9) "department"
10) "SS3-205"

图片 15

上述结果表明,当MySQL插入数据时,通过触发器调用UDF,完结了电动刷新Redis的数额。其余,调用MySQL插入的通令,能够透过C++完结,进而就贯彻了在C++的事体逻辑里,只需调用MySQL++的接口就能够促成MySQL数据库和Redis缓存的更新,那部分内容在上一篇文章早已介绍过了。

 

总结

因此施行,能体会到MySQL和Redis是多么亲近相爱呢!^_^

本篇小说讲了从最基础的UDF伊始,再到通过UDF连接Redis插入数据,再进一步介绍通过MySQL
Trigger自动更新Redis数据的方方面面思路,实现了二个目的,即只在工作代码中更新MySQL数据库,进而Redis能够自行同步刷新。

MySQL对UDF函数和触发器的援助,使得完成Redis数据和MySQL自动同步成了说不定。当然UDF终归是通过插件的款式运转在MySQL中的,并从未过多的自贡干预,一旦插件产生致命性崩溃,有希望MySQL也会挂,所以在编写制定UDF的时候需求非常严刻!

 

如上内容来自:

相关文章