This is a user-defined function (UDF) plugin for MySQL, which can provide some redis command support function to push data from MySQL to Redis.
This application just test on CentOS 6.2(Final),MySQL Server 5.1 and 5.5. In a Dell Server PowerEdge R601 (CPU Xeon(R) E5506 * 8, 24GB Memory), about 3000 calls in a second.
This branch supports multi-line commands, as well as properly escape mysql, and local sockets.
The original version of this library by jackeylu supported this:
do redis_command("127.0.0.1",6379,"incr x");
The issue with redis_command is that data can't be properly escaped since redis doesn't support escaping (it's protocol is too simple for that, and it relies on high level libraries to do escaping for it).
When trying to strike the right balance of sql and redis wire level protocols, I've added 'redis_commands' -- which supports separated parameters terminated by a blank parameter (I THINK this is safe because I haven't seen a case in redis where a blank parameter would ever be used)
do redis_commands("127.0.0.1",6379,"rpush","TEST","hello","","rpush","TEST","world"); do redis_commands("/path/to/local.socket",0,"rpush","TEST","hello","","rpush","TEST","world");
-
MySQL2Redis is built with HiRedis. So, you should install the library first.
-
MySQL2Redis is a plugin for MySQL, with the UDF support, so the MySQL server you used must support this feacture. See the UDF for more information.
Use the ./install.sh script.
See the test directory.
Using the uninstall.sh
When you do a lot of redis_command() calling in a short time, you may get a lot of error like this "Connection error on (xxxx/xxx): Cannot assign requested address" in the error log of MySQL Server. And, at the same time, you can see a lot of TIME_WAIT in the netstat command output.
In this case, you can set the kernel parameters or try to modify the code in hiredis on socket operation (setsockopt() with SO_REUSEADDR).
vi /etc/sysctl.conf
net.ipv4.tcp_syncookies=1
net.ipv4.tcp_tw_reuse=1
net.ipv4.tcp_tw_recycle=1
and /sbin/sysctl -p to make it be usefull.
use 'make solaris' to create a module using gcc (not sunstudio) that is compatible with the default mysql (64 bit) compiled/distributed by mysql.org
You may ask for help and discuss various other issues on the ... and report bugs on the bug tracker.
jackeylu - for the original version!