MySQL+Redis缓存+Gearman共同构建数据库缓存的方法

yum install unzip openssl-devel pcre-devel gcc make -y
tar -zxf nginx-1.22.0.tar.gz
./configure –with-http_stub_status_module –with-http_ssl_module –with-file-aio –add-module=/root/nginx-goodies-nginx-sticky-module-ng-08a395c66e42/
make -j 2 && make install
ln -s /usr/local/nginx/sbin/nginx /usr/local/bin/nginx

vim nginx.conf
location ~ \.php$ {
root html;
fastcgi_pass 127.0.0.1:9000;
fastcgi_index index.php;
# fastcgi_param SCRIPT_FILENAME /scripts$fastcgi_script_name;
include fastcgi.conf;
}

yum install php php-fpm -y
yum install php-pecl-gearman-1.1.2-1.el7.x86_64.rpm php-pecl-igbinary-1.2.1-1.el7.x86_64.rpm php-pecl-redis-2.2.8-1.el7.x86_64.rpm php-fpm-5.4.16-46.el7.x86_64.rpm -y
systemctl start php-fpm.serrvice

vim test.php
<?php
$redis = new Redis();
$redis->connect(‘192.168.63.102’,6379) or die (“could net connect redis server”);
# $query = “select * from test limit 9”;
$query = “select * from test”;
for ($key = 1; $key < 10; $key++)
{
if (!$redis->get($key))
{
$connect = mysql_connect(‘192.168.63.109′,’redis’,’dockerps-A1′);
mysql_select_db(test);
$result = mysql_query($query);
//如果没有找到$key,就将该查询sql的结果缓存到redis
while ($row = mysql_fetch_assoc($result))
{
$redis->set($row[‘id’],$row[‘name’]);
}
$myserver = ‘mysql’;
break;
}
else
{
$myserver = “redis”;
$data[$key] = $redis->get($key);
}
}
echo $myserver;
echo “<br>”;
for ($key = 1; $key < 10; $key++)
{
echo “number is <b><font color=#FF0000>$key</font></b>”;
echo “<br>”;
echo “name is <b><font color=#FF0000>$data[$key]</font></b>”;
echo “<br>”;
}
?>

yum install mariadb-server -y
systemctl start mariadb.service

MariaDB [test]> CREATE USER redis@’%’ IDENTIFIED BY ‘dockerps-A1′ ;
MariaDB [test]> CREATE TABLE `test` (`id` int(7) NOT NULL AUTO_INCREMENT, `name` char(8) DEFAULT NULL, PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;
MariaDB [test]> INSERT INTO `test` VALUES (1,’test1′),(2,’test2′),(3,’test3′),(4,’test4′),(5,’test5′),(6,’test6′),(7,’test7′),(8,’test8′),(9,’test9′);
MariaDB [test]> grant all on test.* to redis@’%’;

yum install mariadb-devel -y #下载对应的开发包
unzip lib_mysqludf_json-master.zip
gcc $(mysql_config –cflags) -shared -fPIC -o lib_mysqludf_json.so lib_mysqludf_json.c
#利用udf函数使得其生成UDF函数
MariaDB [(none)]> show global variables like ‘plugin_dir’;
#查看函数的存储目录
cp lib_mysqludf_json.so /usr/lib64/mysql/plugin/
MariaDB [(none)]> CREATE FUNCTION json_object RETURNS STRING SONAME ‘lib_mysqludf_json.so’;

make -j 2 && make install
./utils/install_server.sh

./configure –with-mysql=/usr/bin/mysql_config –libdir=/usr/lib64/mysql/plugin/
make -j 2 && make install
MariaDB [(none)]> CREATE FUNCTION gman_do_background RETURNS STRING SONAME ‘libgearman_mysql_udf.so’;
MariaDB [(none)]> CREATE FUNCTION gman_servers_set RETURNS STRING SONAME ‘libgearman_mysql_udf.so’;
#注册Gearman的UDF函数使其可以正常调用数据库的内容
MariaDB [(none)]> SELECT gman_servers_set(‘192.168.63.101:4730’);
#IP为S端IP以及端口为gearmand的运行端口

vim trigger.sql
use test;
DELIMITER $$
CREATE TRIGGER datatoredis AFTER UPDATE ON test FOR EACH ROW BEGIN
SET @RECV=gman_do_background(‘syncToRedis’, json_object(NEW.id as `id`, NEW.name as `name`));
END$$
DELIMITER ;

yum install gearmand-1.1.12-18.el7.x86_64.rpm libgearman-1.1.12-18.el7.x86_64.rpm -y
systemctl start gearmand.service

vim worker.php

<?php
$worker = new GearmanWorker();
$worker->addServer();
$worker->addFunction(‘syncToRedis’, ‘syncToRedis’);

$redis = new Redis();
$redis->connect(‘192.168.63.102’, 6379);

while($worker->work());
function syncToRedis($job)
{
global $redis;
$workString = $job->workload();
$work = json_decode($workString);
if(!isset($work->id)){
return false;
}
$redis->set($work->id, $work->name);
}
?>